models

type ASBXToken struct {
	Key     *a.Key
	Payload []byte
}

type BackupStats struct {

	// total number of records in database
	TotalRecords atomic.Uint64
	// contains filtered or unexported fields
}

type File struct {
	Name   string
	Reader io.ReadCloser
}

type Metrics struct {
	PipelineReadQueueSize  int
	PipelineWriteQueueSize int
	RecordsPerSecond       uint64
	KilobytesPerSecond     uint64
}

type PartitionFilterSerialized struct {
	Begin  int
	Count  int
	Digest []byte
	Cursor []byte
	// Worker number.
	N int
}

type Record struct {
	*a.Record

	// VoidTime is the time in seconds since the citrusleaf epoch when the
	// record will expire.
	VoidTime int64
}

type RestoreStats struct {

	// The number of records dropped because they were expired.
	RecordsExpired atomic.Uint64
	// The number of records dropped because they didn't contain any of the
	// selected bins or didn't belong to any of the selected sets.
	RecordsSkipped atomic.Uint64
	// The number of records ignored because of record level permanent error while
	// restoring.
	// E.g.: if RestoreConfig.IgnoreRecordError = true.
	RecordsIgnored atomic.Uint64

	// Total number of bytes read from source.
	TotalBytesRead atomic.Uint64
	// contains filtered or unexported fields
}

type RetryPolicy struct {
	// BaseTimeout is the initial delay between retry attempts.
	BaseTimeout time.Duration

	// Multiplier is used to increase the delay between subsequent retry attempts.
	// The actual delay is calculated as: BaseTimeout * (Multiplier ^ attemptNumber)
	Multiplier float64

	// MaxRetries is the maximum number of retry attempts that will be made.
	// If set to 0, no retries will be performed.
	MaxRetries uint
}

type SIPathBinType byte

type SIndex struct {
	Namespace  string
	Set        string
	Name       string
	Path       SIndexPath
	IndexType  SIndexType
	Expression string
}

type SIndexPath struct {
	BinName    string
	B64Context string
	BinType    SIPathBinType
}

type SIndexType byte

type Sizer interface {
	GetSize() uint64
}

type TimeBounds struct {
	FromTime *time.Time
	ToTime   *time.Time
}

type Token struct {
	SIndex *SIndex
	UDF    *UDF
	Record *Record
	Type   TokenType
	Size   uint64
	// Filter represents serialized partition filter for page, that record belongs to.
	// Is used only on pagination read, to save reading states.
	Filter *PartitionFilterSerialized
}

type TokenConstraint interface {
	Sizer
	*Token | *ASBXToken
}

type TokenType uint8

type UDF struct {
	Name    string
	Content []byte
	UDFType UDFType
}

type UDFType byte