backend

May 13, 2026

Changes in this version

type DistMemory

+ func (dm *DistMemory) ListKeys(ctx context.Context, pattern string, maxResults int) (ListKeysResult, error)

type DistTransport

+ ListKeys func(ctx context.Context, nodeID, pattern string) ([]string, error)

type InProcessTransport

+ func (t *InProcessTransport) ListKeys(_ context.Context, nodeID, pattern string) ([]string, error)

+ type ListKeysResult struct

+ Keys []string

+ PartialNodes []string

+ Truncated bool

May 13, 2026

Changes in this version

type DistMetrics

+ WriteApplyRefused int64

May 12, 2026

Changes in this version

type DistMetrics

+ WriteForwardPromotion int64

May 12, 2026

Changes in this version

+ var ErrChaosDrop = ewrap.New("dist transport: chaos drop")

+ type Chaos struct

+ func NewChaos() *Chaos

+ func (c *Chaos) Drops() int64

+ func (c *Chaos) Latencies() int64

+ func (c *Chaos) SetDropRate(p float64)

+ func (c *Chaos) SetLatency(d time.Duration, rate float64)

type DistMemoryOption

+ func WithDistChaos(c *Chaos) DistMemoryOption

+ func WithDistReadRepairBatch(interval time.Duration, maxBatchSize int) DistMemoryOption

type DistMetrics

+ ChaosDrops int64

+ ChaosLatencies int64

+ ReadRepairBatched int64

+ ReadRepairCoalesced int64

May 11, 2026

Changes in this version

type DistMemoryOption

+ func WithDistMerkleAdaptiveBackoff(maxFactor int) DistMemoryOption

type DistMetrics

+ AutoSyncBackoffFactor int64

+ AutoSyncCleanTicks int64

+ MigrationHintDropped int64

+ MigrationHintExpired int64

+ MigrationHintLastAgeNanos int64

+ MigrationHintQueued int64

+ MigrationHintReplayed int64

May 9, 2026

Changes in this version

type DistMemory

+ func (dm *DistMemory) EventBus() *eventbus.Bus

May 6, 2026

Changes in this version

type DistHTTPTransport

+ func (t *DistHTTPTransport) Gossip(ctx context.Context, targetNodeID string, members []GossipMember) error

type DistTransport

+ Gossip func(ctx context.Context, targetNodeID string, members []GossipMember) error

+ type GossipMember struct

+ Address string

+ ID string

+ Incarnation uint64

+ State string

type InProcessTransport

+ func (t *InProcessTransport) Gossip(_ context.Context, targetNodeID string, members []GossipMember) error

May 5, 2026

Changes in this version

type ConsistencyLevel

+ func (l ConsistencyLevel) String() string

type DistHTTPLimits

+ CompressionThreshold int

type DistHTTPTransport

+ func (t *DistHTTPTransport) IndirectHealth(ctx context.Context, relayNodeID, targetNodeID string) error

type DistMemory

+ func (dm *DistMemory) Drain(_ context.Context) error

+ func (dm *DistMemory) IsDraining() bool

type DistMemoryOption

+ func WithDistIndirectProbes(k int, timeout time.Duration) DistMemoryOption

+ func WithDistLogger(logger *slog.Logger) DistMemoryOption

+ func WithDistMeterProvider(mp metric.MeterProvider) DistMemoryOption

+ func WithDistTracerProvider(tp trace.TracerProvider) DistMemoryOption

type DistMetrics

+ Drains int64

+ IndirectProbeFailure int64

+ IndirectProbeRefuted int64

+ IndirectProbeSuccess int64

type DistTransport

+ IndirectHealth func(ctx context.Context, relayNodeID, targetNodeID string) error

type InProcessTransport

+ func (t *InProcessTransport) IndirectHealth(ctx context.Context, relayNodeID, targetNodeID string) error

May 5, 2026

Changes in this version

type DistHTTPAuth

+ AllowAnonymousInbound bool

May 4, 2026

Changes in this version

+ type DistHTTPAuth struct

+ ClientSign func(*http.Request) error

+ ServerVerify func(fiber.Ctx) error

+ Token string

+ type DistHTTPLimits struct

+ BodyLimit int

+ ClientTimeout time.Duration

+ Concurrency int

+ IdleTimeout time.Duration

+ ReadTimeout time.Duration

+ ResponseLimit int64

+ TLSConfig *tls.Config

+ WriteTimeout time.Duration

type DistHTTPTransport

+ func NewDistHTTPTransportWithAuth(limits DistHTTPLimits, auth DistHTTPAuth, resolver func(string) (string, bool)) *DistHTTPTransport

+ func NewDistHTTPTransportWithLimits(limits DistHTTPLimits, resolver func(string) (string, bool)) *DistHTTPTransport

type DistMemory

+ func (dm *DistMemory) LifecycleContext() context.Context

type DistMemoryOption

+ func WithDistHTTPAuth(auth DistHTTPAuth) DistMemoryOption

+ func WithDistHTTPLimits(limits DistHTTPLimits) DistMemoryOption

Dec 23, 2025

Changes in this version

type DistMemory

+ func (dm *DistMemory) AddPeer(address string)

+ func (dm *DistMemory) IsOwner(key string) bool

+ func (dm *DistMemory) RemovePeer(address string)

+ func (dm *DistMemory) Touch(_ context.Context, key string) bool

type DistMemoryOption

+ func WithDistRemovalGrace(d time.Duration) DistMemoryOption

+ func WithDistReplicaDiffMaxPerTick(n int) DistMemoryOption

type DistMetrics

+ RebalanceReplicaDiffThrottle int64

+ RebalancedPrimary int64

+ RebalancedReplicaDiff int64

type InMemory

+ func (cacheBackend *InMemory) Touch(_ context.Context, key string) bool

Aug 24, 2025

Changes in this version

type DistMemory

+ func (dm *DistMemory) DistMembershipSnapshot() map[string]any

+ func (dm *DistMemory) LatencyHistograms() map[string][]uint64

type DistMemoryOption

+ func WithDistHeartbeatSample(k int) DistMemoryOption

+ func WithDistHintMaxBytes(b int64) DistMemoryOption

+ func WithDistHintMaxTotal(n int) DistMemoryOption

+ func WithDistRebalanceBatchSize(n int) DistMemoryOption

+ func WithDistRebalanceInterval(d time.Duration) DistMemoryOption

+ func WithDistRebalanceMaxConcurrent(n int) DistMemoryOption

type DistMetrics

+ HintedBytes int64

+ HintedGlobalDropped int64

+ MembersAlive int64

+ MembersDead int64

+ MembersSuspect int64

+ MembershipVersion uint64

+ NodesDead int64

+ NodesSuspect int64

+ RebalanceBatches int64

+ RebalanceLastNanos int64

+ RebalanceThrottle int64

+ RebalancedKeys int64

+ WriteAcks int64

+ WriteAttempts int64

+ WriteQuorumFailures int64

type IBackend

+ func NewDistMemoryWithConfig(ctx context.Context, cfg any, opts ...DistMemoryOption) (IBackend[DistMemory], error)

Aug 23, 2025

Changes in this version

+ type ConsistencyLevel int

+ const ConsistencyAll

+ const ConsistencyOne

+ const ConsistencyQuorum

+ type DistHTTPTransport struct

+ func NewDistHTTPTransport(timeout time.Duration, resolver func(string) (string, bool)) *DistHTTPTransport

+ func (t *DistHTTPTransport) FetchMerkle(ctx context.Context, nodeID string) (*MerkleTree, error)

+ func (t *DistHTTPTransport) ForwardGet(ctx context.Context, nodeID, key string) (*cache.Item, bool, error)

+ func (t *DistHTTPTransport) ForwardRemove(ctx context.Context, nodeID, key string, replicate bool) error

+ func (t *DistHTTPTransport) ForwardSet(ctx context.Context, nodeID string, item *cache.Item, replicate bool) error

+ func (t *DistHTTPTransport) Health(ctx context.Context, nodeID string) error

+ func (t *DistHTTPTransport) ListKeys(ctx context.Context, nodeID string) ([]string, error)

+ type DistMemory struct

+ func (dm *DistMemory) BuildMerkleTree() *MerkleTree

+ func (dm *DistMemory) Capacity() int

+ func (dm *DistMemory) Clear(ctx context.Context) error

+ func (dm *DistMemory) Count(_ context.Context) int

+ func (dm *DistMemory) DebugDropLocal(key string)

+ func (dm *DistMemory) DebugInject(it *cache.Item)

+ func (dm *DistMemory) DebugOwners(key string) []cluster.NodeID

+ func (dm *DistMemory) Get(ctx context.Context, key string) (*cache.Item, bool)

+ func (dm *DistMemory) List(_ context.Context, _ ...IFilter) ([]*cache.Item, error)

+ func (dm *DistMemory) LocalContains(key string) bool

+ func (dm *DistMemory) LocalNodeAddr() string

+ func (dm *DistMemory) LocalNodeID() cluster.NodeID

+ func (dm *DistMemory) Membership() *cluster.Membership

+ func (dm *DistMemory) Metrics() DistMetrics

+ func (dm *DistMemory) Remove(ctx context.Context, keys ...string) error

+ func (dm *DistMemory) Ring() *cluster.Ring

+ func (dm *DistMemory) Set(ctx context.Context, item *cache.Item) error

+ func (dm *DistMemory) SetCapacity(capacity int)

+ func (dm *DistMemory) SetLocalNode(node *cluster.Node)

+ func (dm *DistMemory) SetTransport(t DistTransport)

+ func (dm *DistMemory) Stop(ctx context.Context) error

+ func (dm *DistMemory) SyncWith(ctx context.Context, nodeID string) error

+ type DistMemoryOption func(*DistMemory)

+ func WithDistCapacity(capacity int) DistMemoryOption

+ func WithDistGossipInterval(d time.Duration) DistMemoryOption

+ func WithDistHeartbeat(interval, suspectAfter, deadAfter time.Duration) DistMemoryOption

+ func WithDistHintMaxPerNode(n int) DistMemoryOption

+ func WithDistHintReplayInterval(d time.Duration) DistMemoryOption

+ func WithDistHintTTL(d time.Duration) DistMemoryOption

+ func WithDistListKeysCap(n int) DistMemoryOption

+ func WithDistMembership(m *cluster.Membership, node *cluster.Node) DistMemoryOption

+ func WithDistMerkleAutoSync(interval time.Duration) DistMemoryOption

+ func WithDistMerkleAutoSyncPeers(n int) DistMemoryOption

+ func WithDistMerkleChunkSize(n int) DistMemoryOption

+ func WithDistNode(id, address string) DistMemoryOption

+ func WithDistParallelReads(enable bool) DistMemoryOption

+ func WithDistReadConsistency(l ConsistencyLevel) DistMemoryOption

+ func WithDistReplication(n int) DistMemoryOption

+ func WithDistSeeds(addresses []string) DistMemoryOption

+ func WithDistShardCount(n int) DistMemoryOption

+ func WithDistTombstoneSweep(interval time.Duration) DistMemoryOption

+ func WithDistTombstoneTTL(d time.Duration) DistMemoryOption

+ func WithDistTransport(t DistTransport) DistMemoryOption

+ func WithDistVirtualNodes(n int) DistMemoryOption

+ func WithDistWriteConsistency(l ConsistencyLevel) DistMemoryOption

+ type DistMetrics struct

+ AutoSyncLoops int64

+ ForwardGet int64

+ ForwardRemove int64

+ ForwardSet int64

+ HeartbeatFailure int64

+ HeartbeatSuccess int64

+ HintedDropped int64

+ HintedExpired int64

+ HintedQueued int64

+ HintedReplayed int64

+ LastAutoSyncError string

+ LastAutoSyncNanos int64

+ MerkleBuildNanos int64

+ MerkleDiffNanos int64

+ MerkleFetchNanos int64

+ MerkleKeysPulled int64

+ MerkleSyncs int64

+ NodesRemoved int64

+ ReadPrimaryPromote int64

+ ReadRepair int64

+ ReplicaFanoutRemove int64

+ ReplicaFanoutSet int64

+ ReplicaGetMiss int64

+ TombstonesActive int64

+ TombstonesPurged int64

+ VersionConflicts int64

+ VersionTieBreaks int64

+ type DistTransport interface

+ FetchMerkle func(ctx context.Context, nodeID string) (*MerkleTree, error)

+ ForwardGet func(ctx context.Context, nodeID string, key string) (*cache.Item, bool, error)

+ ForwardRemove func(ctx context.Context, nodeID string, key string, replicate bool) error

+ ForwardSet func(ctx context.Context, nodeID string, item *cache.Item, replicate bool) error

+ Health func(ctx context.Context, nodeID string) error

type IBackend

+ func NewDistMemory(ctx context.Context, opts ...DistMemoryOption) (IBackend[DistMemory], error)

+ type InProcessTransport struct

+ func NewInProcessTransport() *InProcessTransport

+ func (t *InProcessTransport) FetchMerkle(_ context.Context, nodeID string) (*MerkleTree, error)

+ func (t *InProcessTransport) ForwardGet(_ context.Context, nodeID string, key string) (*cache.Item, bool, error)

+ func (t *InProcessTransport) ForwardRemove(ctx context.Context, nodeID string, key string, replicate bool) error

+ func (t *InProcessTransport) ForwardSet(ctx context.Context, nodeID string, item *cache.Item, replicate bool) error

+ func (t *InProcessTransport) Health(_ context.Context, nodeID string) error

+ func (t *InProcessTransport) Register(b *DistMemory)

+ func (t *InProcessTransport) Unregister(id string)

+ type MerkleTree struct

+ ChunkSize int

+ LeafHashes [][]byte

+ Root []byte

+ func (mt *MerkleTree) DiffLeafRanges(other *MerkleTree) []int

Aug 21, 2025

Changes in this version

type IBackend

+ func NewRedisCluster(redisOptions ...Option[RedisCluster]) (IBackend[RedisCluster], error)

type Option

+ func WithClusterKeysSetName[T RedisCluster](keysSetName string) Option[RedisCluster]

+ func WithClusterSerializer[T RedisCluster](ser serializer.ISerializer) Option[RedisCluster]

+ func WithRedisClusterClient[T RedisCluster](client *redis.ClusterClient) Option[RedisCluster]

+ type RedisCluster struct

+ Serializer serializer.ISerializer

+ func (cacheBackend *RedisCluster) Capacity() int

+ func (cacheBackend *RedisCluster) Clear(ctx context.Context) error

+ func (cacheBackend *RedisCluster) Count(ctx context.Context) int

+ func (cacheBackend *RedisCluster) Get(ctx context.Context, key string) (*cache.Item, bool)

+ func (cacheBackend *RedisCluster) List(ctx context.Context, filters ...IFilter) ([]*cache.Item, error)

+ func (cacheBackend *RedisCluster) Remove(ctx context.Context, keys ...string) error

+ func (cacheBackend *RedisCluster) Set(ctx context.Context, item *cache.Item) error

+ func (cacheBackend *RedisCluster) SetCapacity(capacity int)

Aug 20, 2025

Changes in this version

+ func ApplyOptions[T IBackendConstrain](backend *T, options ...Option[T])

+ type IBackend interface

+ Capacity func() int

+ Clear func(ctx context.Context) error

+ Count func(ctx context.Context) int

+ Get func(ctx context.Context, key string) (item *cache.Item, ok bool)

+ List func(ctx context.Context, filters ...IFilter) (items []*cache.Item, err error)

+ Remove func(ctx context.Context, keys ...string) error

+ Set func(ctx context.Context, item *cache.Item) error

+ SetCapacity func(capacity int)

+ func NewInMemory(opts ...Option[InMemory]) (IBackend[InMemory], error)

+ func NewRedis(redisOptions ...Option[Redis]) (IBackend[Redis], error)

+ type IBackendConstrain interface

+ type IFilter interface

+ ApplyFilter func(backendType string, items []*cache.Item) ([]*cache.Item, error)

+ func WithFilterFunc(fn func(item *cache.Item) bool) IFilter

+ func WithSortBy(field string) IFilter

+ type InMemory struct

+ func (cacheBackend *InMemory) Capacity() int

+ func (cacheBackend *InMemory) Clear(ctx context.Context) error

+ func (cacheBackend *InMemory) Count(_ context.Context) int

+ func (cacheBackend *InMemory) Get(_ context.Context, key string) (*cache.Item, bool)

+ func (cacheBackend *InMemory) List(_ context.Context, filters ...IFilter) ([]*cache.Item, error)

+ func (cacheBackend *InMemory) Remove(ctx context.Context, keys ...string) error

+ func (cacheBackend *InMemory) Set(_ context.Context, item *cache.Item) error

+ func (cacheBackend *InMemory) SetCapacity(capacity int)

+ type Option func(*T)

+ func WithCapacity[T IBackendConstrain](capacity int) Option[T]

+ func WithKeysSetName[T Redis](keysSetName string) Option[Redis]

+ func WithRedisClient[T Redis](client *redis.Client) Option[Redis]

+ func WithSerializer[T Redis](serializer serializer.ISerializer) Option[Redis]

+ type Redis struct

+ Serializer serializer.ISerializer

+ func (cacheBackend *Redis) Capacity() int

+ func (cacheBackend *Redis) Clear(ctx context.Context) error

+ func (cacheBackend *Redis) Count(ctx context.Context) int

+ func (cacheBackend *Redis) Get(ctx context.Context, key string) (*cache.Item, bool)

+ func (cacheBackend *Redis) List(ctx context.Context, filters ...IFilter) ([]*cache.Item, error)

+ func (cacheBackend *Redis) Remove(ctx context.Context, keys ...string) error

+ func (cacheBackend *Redis) Set(ctx context.Context, item *cache.Item) error

+ func (cacheBackend *Redis) SetCapacity(capacity int)

+ type SortOrderFilter struct

+ func WithSortOrderAsc(ascending bool) SortOrderFilter

+ func (f SortOrderFilter) ApplyFilter(_ string, items []*cache.Item) ([]*cache.Item, error)