in_red_ck

Mar 10, 2024

Changes in this version

+ const ForReading

+ const ForWriting

+ const NoCheck

+ type TransactionMode int

Feb 18, 2024

Changes in this version

+ type StoreInfo struct

+ Description string

+ IsUnique bool

+ IsValueDataActivelyPersisted bool

+ IsValueDataGloballyCached bool

+ IsValueDataInNodeSegment bool

+ LeafLoadBalancing bool

+ Name string

+ SlotLength int

Feb 18, 2024

Changes in this version

type Transaction

+ func NewMockTransactionWithLogging(t *testing.T, forWriting bool, maxTime time.Duration) (Transaction, error)

Feb 9, 2024

Changes in this version

type Transaction

+ func NewMockTransaction(t *testing.T, forWriting bool, maxTime time.Duration) (Transaction, error)

Feb 4, 2024

Changes in this version

+ func NewBtreeExt[TK btree.Comparable, TV any](ctx context.Context, name string, slotLength int, isUnique bool, ...) (btree.BtreeInterface[TK, TV], error)

Jan 16, 2024

Changes in this version

+ func RemoveBtree(ctx context.Context, name string) error

Jan 12, 2024

Changes in this version

+ var IsDeleteServiceEnabled bool

+ var Now = time.Now().UnixMilli

+ var ServiceIntervalInHour int = 2

+ func DeleteService(ctx context.Context)

+ func DoDeletedItemsProcessing(ctx context.Context)

+ func EnableDeleteService(yes bool)

+ func Initialize(cassandraConfig cas.Config, redisConfig redis.Options) error

+ func IsInitialized() bool

+ func NewBtree[TK btree.Comparable, TV any](ctx context.Context, name string, slotLength int, isUnique bool, ...) (btree.BtreeInterface[TK, TV], error)

+ func OpenBtree[TK btree.Comparable, TV any](ctx context.Context, name string, t Transaction) (btree.BtreeInterface[TK, TV], error)

+ func SetNodeCacheDuration(duration time.Duration)

+ func Shutdown()

+ type StoreInterface struct

+ type Transaction interface

+ AddPhasedTransaction func(otherTransaction ...TwoPhaseCommitTransaction)

+ Begin func() error

+ Commit func(ctx context.Context) error

+ GetPhasedTransaction func() TwoPhaseCommitTransaction

+ HasBegun func() bool

+ Rollback func(ctx context.Context) error

+ func NewTransaction(forWriting bool, maxTime time.Duration) (Transaction, error)

+ type TwoPhaseCommitTransaction interface

+ Begin func() error

+ HasBegun func() bool

+ Phase1Commit func(ctx context.Context) error

+ Phase2Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

+ func NewTwoPhaseCommitTransaction(forWriting bool, maxTime time.Duration) (TwoPhaseCommitTransaction, error)