gossip

Documentation

Index

• func Register(name string, f newGossipFunc)
• type GossipState
  • func GetGossipState(protocol, listen, channelName, gossipName string, gossipSecret []byte, ...) (GossipState, error)
• type GossipStateSnapshot
• type MultiGossipState
  • func (m *MultiGossipState) Snapshot() *GossipStateSnapshot
  • func (m *MultiGossipState) Start() error
  • func (m *MultiGossipState) UpdateValues(removeKeys []string, putKeys map[string]string) error
• type SeedProvider
• type StaticSeedProvider
  • func NewStaticSeedProvider(seeds []string) *StaticSeedProvider
  • func (s *StaticSeedProvider) GetSeeds() ([]string, error)

Functions

func Register

func Register(name string, f newGossipFunc)

Types

type GossipState

type GossipState interface {
	Snapshot() *GossipStateSnapshot
	UpdateValues(removeKeys []string, putKeys map[string]string) error
	Start() error
}

func GetGossipState

func GetGossipState(protocol, listen, channelName, gossipName string, gossipSecret []byte, gossipSeeds SeedProvider) (GossipState, error)

type GossipStateSnapshot

type GossipStateSnapshot struct {
	Values  map[string]string
	Version uint64
}

type MultiGossipState

type MultiGossipState struct {
	Primary   GossipState
	Secondary GossipState
}

MultiGossipState enables ramping between gossip mechanisms. This will replicaet all UpdateValue operations to the Secondary while still calling the primary for all Snapshot information

func (*MultiGossipState) Snapshot

func (m *MultiGossipState) Snapshot() *GossipStateSnapshot

func (*MultiGossipState) Start

func (m *MultiGossipState) Start() error

func (*MultiGossipState) UpdateValues

func (m *MultiGossipState) UpdateValues(removeKeys []string, putKeys map[string]string) error

type SeedProvider

type SeedProvider interface {
	GetSeeds() ([]string, error)
}

type StaticSeedProvider

type StaticSeedProvider struct {
	Seeds []string
}

func NewStaticSeedProvider

func NewStaticSeedProvider(seeds []string) *StaticSeedProvider

func (*StaticSeedProvider) GetSeeds

func (s *StaticSeedProvider) GetSeeds() ([]string, error)