backend

package

Go to main page

Versions in this module

v0

v0.2.1

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)

v0.2.0

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

v0.1.8

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)

v0.1.7

Aug 21, 2025

v0.1.6

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL