storage

func (*AppStorage) AtomicIncrement ¶ added in v0.1.11

func (s *AppStorage) AtomicIncrement(key string) (newValue int64, err error)

func (*AppStorage) BatchWrite ¶ added in v0.1.11

func (s *AppStorage) BatchWrite(ops []ports.WriteOp) error

func (*AppStorage) CleanExpired ¶ added in v0.1.11

func (s *AppStorage) CleanExpired() (cleanedCount int, err error)

func (*AppStorage) Close ¶ added in v0.1.11

func (s *AppStorage) Close() error

func (*AppStorage) CountPrefix ¶ added in v0.1.11

func (s *AppStorage) CountPrefix(prefix string) (count int, err error)

func (*AppStorage) Delete ¶ added in v0.1.11

func (s *AppStorage) Delete(key string) error

func (*AppStorage) DeleteByPrefix ¶ added in v0.1.11

func (s *AppStorage) DeleteByPrefix(prefix string) (deletedCount int, err error)

func (*AppStorage) Exists ¶ added in v0.1.11

func (s *AppStorage) Exists(key string) (bool, error)

func (*AppStorage) ExpireAt ¶ added in v0.1.11

func (s *AppStorage) ExpireAt(key string, expireTime time.Time) error

func (*AppStorage) Get ¶ added in v0.1.11

func (s *AppStorage) Get(key string) (value []byte, version int64, exists bool, err error)

func (*AppStorage) GetMetadata ¶ added in v0.1.11

func (s *AppStorage) GetMetadata(key string) (*ports.KeyMetadata, error)

func (*AppStorage) GetNext ¶ added in v0.1.11

func (s *AppStorage) GetNext(prefix string) (key string, value []byte, exists bool, err error)

func (*AppStorage) GetNextAfter ¶ added in v0.1.11

func (s *AppStorage) GetNextAfter(prefix string, afterKey string) (key string, value []byte, exists bool, err error)

func (*AppStorage) GetTTL ¶ added in v0.1.11

func (s *AppStorage) GetTTL(key string) (time.Duration, error)

func (*AppStorage) GetVersion ¶ added in v0.1.11

func (s *AppStorage) GetVersion(key string) (int64, error)

func (*AppStorage) ListByPrefix ¶ added in v0.1.11

func (s *AppStorage) ListByPrefix(prefix string) ([]ports.KeyValueVersion, error)

func (*AppStorage) Put ¶ added in v0.1.11

func (s *AppStorage) Put(key string, value []byte, version int64) error

func (*AppStorage) PutWithTTL ¶ added in v0.1.11

func (s *AppStorage) PutWithTTL(key string, value []byte, version int64, ttl time.Duration) error

func (*AppStorage) RunInTransaction ¶ added in v0.1.11

func (s *AppStorage) RunInTransaction(fn func(tx ports.Transaction) error) error

func (*AppStorage) SetEventManager ¶ added in v0.3.2

func (s *AppStorage) SetEventManager(ev ports.EventManager)

SetEventManager injects the event manager as the single event hub

func (*AppStorage) SetRaftNode ¶ added in v0.1.11

func (s *AppStorage) SetRaftNode(node ports.RaftNode)

func (*LeaseManager) ForceRelease ¶ added in v0.3.11

func (m *LeaseManager) ForceRelease(key string) error

ForceRelease removes the lease unconditionally.

func (*LeaseManager) Get ¶ added in v0.3.11

func (m *LeaseManager) Get(key string) (*ports.LeaseRecord, bool, error)

Get fetches the current lease record.

func (*LeaseManager) Key ¶ added in v0.3.11

func (m *LeaseManager) Key(namespace, id string) string

Key returns the storage key for a lease scoped to the provided namespace and identifier.

func (*LeaseManager) Release ¶ added in v0.3.11

func (m *LeaseManager) Release(key, owner string) error

Release relinquishes the lease if owned by the caller.

func (*LeaseManager) Renew ¶ added in v0.3.11

func (m *LeaseManager) Renew(key, owner string, ttl time.Duration) (*ports.LeaseRecord, error)

Renew extends the lease expiration if the caller still holds it.

func (*LeaseManager) TryAcquire ¶ added in v0.3.11

func (m *LeaseManager) TryAcquire(key, owner string, ttl time.Duration, metadata map[string]string) (*ports.LeaseRecord, bool, error)

TryAcquire attempts to obtain the lease for the provided key.