gossip

May 17, 2024

Changes in this version

+ type BaseStore struct

+ func (s *BaseStore[K]) AddItem(item gossip.CommonItem)

+ func (s *BaseStore[K]) Data(limit int) ([]gossip.CommonItem, int)

+ func (s *BaseStore[K]) Target(k K) string

+ type Module interface

+ Data func(limit int) ([]gossip.GossipData, int)

type Node

+ func (n *Node) StatsKeyRouter() client.KeyRouter[pb.StatsInfoKey]

Nov 13, 2023

Changes in this version

+ type DistKeyCache struct

+ func (dc *DistKeyCache) AddItem(key cache.CacheKey, operation gossip.Operation)

+ func (dc *DistKeyCache) Target(k cache.CacheKey) string

+ type Node struct

+ func NewNode(ctx context.Context, nid string, opts ...Option) (*Node, error)

+ func (n *Node) Create() error

+ func (n *Node) Created() bool

+ func (n *Node) DistKeyCacheGetter() fileservice.KeyRouterFactory

+ func (n *Node) Join(existing []string) error

+ func (n *Node) Joined() bool

+ func (n *Node) Leave(timeout time.Duration) error

+ func (n *Node) NumMembers() int

+ func (n *Node) SetCacheServerAddrFn(f func() string)

+ func (n *Node) SetJoined()

+ func (n *Node) SetListenAddrFn(f func() string)

+ func (n *Node) SetServiceAddrFn(f func() string)

+ func (n *Node) UnsetJoined()

+ type Option func(*Node)

+ func WithCacheServerAddrFn(f func() string) Option

+ func WithListenAddrFn(f func() string) Option

+ func WithServiceAddrFn(f func() string) Option