Packages

object BackupClientInterface

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BackupClientInterface
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def calculateKey(offsetDateTime: OffsetDateTime, timeConfiguration: TimeConfiguration, maybeCompression: Option[Compression]): String

    Calculate an object storage key or filename for a ReducedConsumerRecord

    Calculate an object storage key or filename for a ReducedConsumerRecord

    offsetDateTime

    A given time

    returns

    A String that can be used either as some object key or a filename

  2. def formatOffsetDateTime(offsetDateTime: OffsetDateTime): String
  3. def isAtBoundary(dividedPeriodsBefore: Long, dividedPeriodsAfter: Long): Boolean

    Calculates whether we have rolled over a time period given number of divided periods.

    Calculates whether we have rolled over a time period given number of divided periods.

    dividedPeriodsBefore

    The number of divided periods in the first element of the slide. -1 is used as a sentinel value to indicate the start of the stream

    dividedPeriodsAfter

    The number of divided periods in the second element of the slide

    returns

    true if we have hit a time boundary otherwise false

  4. def reducedConsumerRecordAsString(reducedConsumerRecord: ReducedConsumerRecord): String