Versions in this module Expand all Collapse all v0 v0.0.1 Dec 13, 2025 Changes in this version + var ErrInternal = errors.New("internal error") + type Config struct + Gossip gossip.Config + Membership MembershipConfig + Node NodeConfig + Persistence PersistenceConfig + Replication ReplicationConfig + Security SecurityConfig + Seeds []string + TraceConfig TraceConfig + Transport transport.TransportConfig + type MembershipConfig struct + Port uint16 + type NodeConfig struct + BindAddress string + ID string + Port uint16 + type PersistenceConfig struct + SnapDir string + SnapshotIntervalMs int + WalConfig wal.Config + type ReplicationConfig struct + type SecurityConfig struct + CaCert string + CaKey string + Cert string + Enabled bool + Key string + type Storage struct + func NewStorage(config *Config) (*Storage, error) + func (s *Storage) ApplyDec(ctx context.Context, key string, val int64) (bool, error) + func (s *Storage) ApplyInc(ctx context.Context, key string, val int64) (bool, error) + func (s *Storage) ApplySetRegister(ctx context.Context, key string, val []byte) (bool, error) + func (s *Storage) Delete(ctx context.Context, key string) (bool, error) + func (s *Storage) Get(ctx context.Context, key string) (val any, t crdt.CRDTType, ok bool) + func (s *Storage) GracefulStop() error + func (s *Storage) Put(ctx context.Context, key string, t crdt.CRDTType) error + func (s *Storage) StartUp(ctx context.Context) error + type TraceConfig struct + Enable bool + Endpoint string
Go to main page