gossip

Documentation

Index

• type DistKeyCache
  • func (dc *DistKeyCache) AddItem(key cache.CacheKey, operation gossip.Operation)
  • func (dc *DistKeyCache) Target(k cache.CacheKey) string
• 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
  • 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 WithCacheServerAddrFn(f func() string) Option
  • func WithListenAddrFn(f func() string) Option
  • func WithServiceAddrFn(f func() string) Option

Types

type DistKeyCache

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

DistKeyCache keeps the key cache of local set/delete items and key information on remote nodes.

func (*DistKeyCache) AddItem

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

AddItem implements the fileservice.KeyRouter interface.

func (*DistKeyCache) Target

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

Target implements the fileservice.KeyRouter interface.

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

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) 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