gossip

Documentation

Index

• type BaseStore
  • 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
• type Node
  • 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[query.CacheKey]
  • 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) StatsKeyRouter() client.KeyRouter[pb.StatsInfoKey]
  • func (n *Node) UnsetJoined()
• type Option
  • func WithCacheServerAddrFn(f func() string) Option
  • func WithListenAddrFn(f func() string) Option
  • func WithServiceAddrFn(f func() string) Option

Types

type BaseStore

type BaseStore[K comparable] struct {
	// contains filtered or unexported fields
}

func (*BaseStore[K]) AddItem

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

AddItem implements the client.KeyRouter interface.

func (*BaseStore[K]) Data

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

Data implements the Module interface.

func (*BaseStore[K]) Target

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

Target implements the client.KeyRouter interface.

type Module

type Module interface {
	// Data returns all data that need to send to other nodes.
	// The second return value is the left size of the limit size.
	Data(limit int) ([]gossip.GossipData, int)
}

type Node

type Node struct {
	// contains filtered or unexported fields
}

func NewNode

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

func (*Node) Create

func (n *Node) Create() error

func (*Node) Created

func (n *Node) Created() bool

func (*Node) DistKeyCacheGetter

func (n *Node) DistKeyCacheGetter() fileservice.KeyRouterFactory[query.CacheKey]

func (*Node) Join

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

func (*Node) Joined

func (n *Node) Joined() bool

func (*Node) Leave

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

func (*Node) NumMembers

func (n *Node) NumMembers() int

func (*Node) SetCacheServerAddrFn

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

func (*Node) SetJoined

func (n *Node) SetJoined()

func (*Node) SetListenAddrFn

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

func (*Node) SetServiceAddrFn

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

func (*Node) StatsKeyRouter

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

func (*Node) UnsetJoined

func (n *Node) UnsetJoined()

type Option

type Option func(*Node)

func WithCacheServerAddrFn

func WithCacheServerAddrFn(f func() string) Option

func WithListenAddrFn

func WithListenAddrFn(f func() string) Option

func WithServiceAddrFn

func WithServiceAddrFn(f func() string) Option