utils

Apr 15, 2023

Changes in this version

+ func GarbageCollectQuery(window time.Duration, tenantID string) squirrel.DeleteBuilder

Jan 25, 2023

Changes in this version

+ func NewContinuousToken(value string) database.ContinuousToken

+ func NewNoopContinuousToken() database.ContinuousToken

+ type ContinuousToken struct

+ Value string

+ func (t ContinuousToken) Encode() database.EncodedContinuousToken

+ type EncodedContinuousToken struct

+ Value string

+ func (t EncodedContinuousToken) Decode() (database.ContinuousToken, error)

+ func (t EncodedContinuousToken) String() string

+ type NoopContinuousToken struct

+ Value string

+ func (t NoopContinuousToken) Encode() database.EncodedContinuousToken

+ type NoopEncodedContinuousToken struct

+ Value string

+ func (t NoopEncodedContinuousToken) Decode() (database.ContinuousToken, error)

+ func (t NoopEncodedContinuousToken) String() string

Jan 20, 2023

Changes in this version

+ func Rollback(tx *sql.Tx, logger logger.Interface)

Dec 17, 2022

Changes in this version

+ func FilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.TupleFilter) squirrel.SelectBuilder

+ func FilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.TupleFilter) squirrel.UpdateBuilder

+ func NewTransactionQuery() string

+ func SnapshotQuery(sl squirrel.SelectBuilder, revision uint64) squirrel.SelectBuilder