models

Sep 28, 2026

Changes in this version

type SIPathBinType

+ const EmptySIDataType

+ type SIndexInfo struct

+ HasExpression bool

+ HasSet bool

type SIndexPath

+ func NewEmptySIndexPath() SIndexPath

type SIndexType

+ const SetSIndex

Jan 6, 2026

Changes in this version

type RestoreStats

+ func (rs *RestoreStats) AddErrorsInDoubt(n uint64)

+ func (rs *RestoreStats) GetRetryPolicyAttempts() uint64

+ func (rs *RestoreStats) IncrRetryPolicyAttempts()

Nov 5, 2025

Changes in this version

type RetryPolicy

+ func (p *RetryPolicy) Do(ctx context.Context, operation func() error) error

Sep 16, 2025

Changes in this version

type RetryPolicy

+ func (p *RetryPolicy) AttemptsLeft(attempt uint) bool

+ func (p *RetryPolicy) Sleep(attempt uint)

Aug 18, 2025

Changes in this version

type SIndex

+ Expression string

Jun 29, 2025

Changes in this version

+ const ExpirationNever

+ const MonitorRecordsSetName

+ const VoidTimeNeverExpire

+ var ErrFilteredOut = errors.New("filtered out")

+ type ASBXToken struct

+ Key *a.Key

+ Payload []byte

+ func NewASBXToken(key *a.Key, payload []byte) *ASBXToken

+ func (t *ASBXToken) GetSize() uint64

+ type BackupStats struct

+ TotalRecords atomic.Uint64

+ func NewBackupStats() *BackupStats

+ func SumBackupStats(stats ...*BackupStats) *BackupStats

+ func (b *BackupStats) GetFileCount() uint64

+ func (b *BackupStats) IncFiles()

+ func (b *BackupStats) IsEmpty() bool

+ func (s BackupStats) AddSIndexes(num uint32)

+ func (s BackupStats) AddUDFs(num uint32)

+ func (s BackupStats) GetBytesWritten() uint64

+ func (s BackupStats) GetDuration() time.Duration

+ func (s BackupStats) GetReadRecords() uint64

+ func (s BackupStats) GetSIndexes() uint32

+ func (s BackupStats) GetUDFs() uint32

+ func (s BackupStats) Start()

+ func (s BackupStats) Stop()

+ type File struct

+ Name string

+ Reader io.ReadCloser

+ type Metrics struct

+ KilobytesPerSecond uint64

+ PipelineReadQueueSize int

+ PipelineWriteQueueSize int

+ RecordsPerSecond uint64

+ func NewMetrics(pr, pw int, rps, kbps uint64) *Metrics

+ func SumMetrics(metrics ...*Metrics) *Metrics

+ type PartitionFilterSerialized struct

+ Begin int

+ Count int

+ Cursor []byte

+ Digest []byte

+ N int

+ func NewPartitionFilterSerialized(pf *a.PartitionFilter) (PartitionFilterSerialized, error)

+ func (p *PartitionFilterSerialized) Decode() (*a.PartitionFilter, error)

+ func (p *PartitionFilterSerialized) IsEmpty() bool

+ type Record struct

+ VoidTime int64

+ type RestoreStats struct

+ RecordsExpired atomic.Uint64

+ RecordsIgnored atomic.Uint64

+ RecordsSkipped atomic.Uint64

+ TotalBytesRead atomic.Uint64

+ func NewRestoreStats() *RestoreStats

+ func SumRestoreStats(stats ...*RestoreStats) *RestoreStats

+ func (rs *RestoreStats) GetErrorsInDoubt() uint64

+ func (rs *RestoreStats) GetRecordsExisted() uint64

+ func (rs *RestoreStats) GetRecordsExpired() uint64

+ func (rs *RestoreStats) GetRecordsFresher() uint64

+ func (rs *RestoreStats) GetRecordsIgnored() uint64

+ func (rs *RestoreStats) GetRecordsInserted() uint64

+ func (rs *RestoreStats) GetRecordsSkipped() uint64

+ func (rs *RestoreStats) GetTotalBytesRead() uint64

+ func (rs *RestoreStats) IncrErrorsInDoubt()

+ func (rs *RestoreStats) IncrRecordsExisted()

+ func (rs *RestoreStats) IncrRecordsFresher()

+ func (rs *RestoreStats) IncrRecordsIgnored()

+ func (rs *RestoreStats) IncrRecordsInserted()

+ func (s RestoreStats) AddSIndexes(num uint32)

+ func (s RestoreStats) AddUDFs(num uint32)

+ func (s RestoreStats) GetBytesWritten() uint64

+ func (s RestoreStats) GetDuration() time.Duration

+ func (s RestoreStats) GetReadRecords() uint64

+ func (s RestoreStats) GetSIndexes() uint32

+ func (s RestoreStats) GetUDFs() uint32

+ func (s RestoreStats) Start()

+ func (s RestoreStats) Stop()

+ type RetryPolicy struct

+ BaseTimeout time.Duration

+ MaxRetries uint

+ Multiplier float64

+ func NewDefaultRetryPolicy() *RetryPolicy

+ func NewRetryPolicy(baseTimeout time.Duration, multiplier float64, maxRetries uint) *RetryPolicy

+ func (p *RetryPolicy) Validate() error

+ type SIPathBinType byte

+ const BlobSIDataType

+ const GEO2DSphereSIDataType

+ const InvalidSIDataType

+ const NumericSIDataType

+ const StringSIDataType

+ type SIndex struct

+ IndexType SIndexType

+ Name string

+ Namespace string

+ Path SIndexPath

+ Set string

+ type SIndexPath struct

+ B64Context string

+ BinName string

+ BinType SIPathBinType

+ type SIndexType byte

+ const BinSIndex

+ const InvalidSIndex

+ const ListElementSIndex

+ const MapKeySIndex

+ const MapValueSIndex

+ type Sizer interface

+ GetSize func() uint64

+ type TimeBounds struct

+ FromTime *time.Time

+ ToTime *time.Time

+ type Token struct

+ Filter *PartitionFilterSerialized

+ Record *Record

+ SIndex *SIndex

+ Size uint64

+ Type TokenType

+ UDF *UDF

+ func NewRecordToken(r *Record, size uint64, filter *PartitionFilterSerialized) *Token

+ func NewSIndexToken(s *SIndex, size uint64) *Token

+ func NewUDFToken(u *UDF, size uint64) *Token

+ func (t *Token) GetSize() uint64

+ type TokenConstraint interface

+ type TokenType uint8

+ const TokenTypeInvalid

+ const TokenTypeRecord

+ const TokenTypeSIndex

+ const TokenTypeUDF

+ type UDF struct

+ Content []byte

+ Name string

+ UDFType UDFType

+ type UDFType byte

+ const UDFTypeLUA