utils

May 4, 2024

Changes in this version

+ const DeleteTenantTemplate

+ const InsertTenantTemplate

+ const TransactionTemplate

Jan 17, 2024

Changes in this version

+ func EnsureDBVersion(db *sql.DB) (version int, err error)

+ func IsSerializationRelatedError(err error) bool

+ func WaitWithBackoff(ctx context.Context, tenantID string, retries int)

Jan 12, 2024

Changes in this version

+ func IsContextRelatedError(err error) bool

Dec 5, 2023

Changes in this version

+ func HandleError(span trace.Span, err error, errorCode base.ErrorCode) error

Sep 12, 2023

Changes in this version

+ const BulkEntityFilterTemplate

+ func AttributesFilterQueryForSelectBuilder(sl squirrel.SelectBuilder, filter *base.AttributeFilter) squirrel.SelectBuilder

+ func AttributesFilterQueryForUpdateBuilder(sl squirrel.UpdateBuilder, filter *base.AttributeFilter) squirrel.UpdateBuilder

+ func BulkEntityFilterQuery(tenantID, entityType string, snap uint64) string

+ func GenerateGCQuery(table string, value uint64) squirrel.DeleteBuilder

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

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

May 4, 2023

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 GarbageCollectQuery(window time.Duration, tenantID string) squirrel.DeleteBuilder

+ func NewContinuousToken(value string) database.ContinuousToken

+ func NewNoopContinuousToken() database.ContinuousToken

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

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

+ 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