Versions in this module Expand all Collapse all v1 v1.0.0 Jul 3, 2026 Changes in this version + type ClockValue struct + NodeID string + TS uint64 + Vector map[string]uint64 + func (cv ClockValue) After(other ClockValue) bool + func (cv ClockValue) Equal(other ClockValue) bool + type Options struct + BindAddr string + EvictInterval time.Duration + GossipSecret string + GracefulSave bool + MaxKeys int + NodeID string + Peers []string + Persist bool + RedisURL string + SnapshotPath string + type PubSub struct + type Store struct + func New(opts Options) *Store + func (s *Store) CompareAndSwap(key string, expected, newValue any, ttl time.Duration) bool + func (s *Store) Count(pattern string) int + func (s *Store) Decr(key string) int64 + func (s *Store) Delete(key string) + func (s *Store) Expire(key string, ttl time.Duration) bool + func (s *Store) Flush() + func (s *Store) Get(key string) (any, bool) + func (s *Store) GetInt64(key string) (int64, bool) + func (s *Store) GetString(key string) (string, bool) + func (s *Store) Has(key string) bool + func (s *Store) Incr(key string) int64 + func (s *Store) IncrBy(key string, n int64) int64 + func (s *Store) Keys(pattern string) []string + func (s *Store) Publish(topic string, payload any) + func (s *Store) Set(key string, value any, ttl time.Duration) + func (s *Store) Shutdown() error + func (s *Store) Subscribe(topic string, handler func(topic string, payload any)) func() + type VectorClock struct + func NewVectorClock(nodeID string) *VectorClock + func (vc *VectorClock) Merge(received ClockValue) + func (vc *VectorClock) Tick() ClockValue
Go to main page