peers

Documentation

Index

• Constants
• Variables
• func MockedMesh() *mockedMesh
• func NewPeerStore(mesh types.GossipServiceLayer) (*memDBStore, error)
• type Channel
• type Peer
• type PeerStore
• type SubscriptionSet
  • func (set SubscriptionSet) Apply(f func(s Peer))
  • func (set SubscriptionSet) ApplyE(f func(s Peer) error) error
  • func (set SubscriptionSet) ApplyIdx(f func(idx int, s Peer))
  • func (set SubscriptionSet) Filter(filters ...peerFilter) SubscriptionSet

Constants

const (
	PeerCreated string = "peer_created"
	PeerUpdated string = "peer_updated"
	PeerDeleted string = "peer_deleted"
)

Variables

var (
	ErrPeerNotFound = errors.New("peer not found")
)

Functions

func MockedMesh

func MockedMesh() *mockedMesh

func NewPeerStore

func NewPeerStore(mesh types.GossipServiceLayer) (*memDBStore, error)

Types

type Channel

type Channel interface {
	Broadcast(b []byte)
}

type Peer

type Peer struct {
	pb.Metadata
}

type PeerStore

type PeerStore interface {
	ByID(id string) (Peer, error)
	ByService(name string) (SubscriptionSet, error)
	EndpointsByService(name string) ([]*pb.NodeService, error)
	All() (SubscriptionSet, error)
	Exists(id string) bool
	Upsert(p Peer) error
	Update(id string, mutation func(peer Peer) Peer) error
	Delete(id string) error
	On(event string, handler func(Peer)) func()
}

type SubscriptionSet

type SubscriptionSet []Peer

func (SubscriptionSet) Apply

func (set SubscriptionSet) Apply(f func(s Peer))

func (SubscriptionSet) ApplyE

func (set SubscriptionSet) ApplyE(f func(s Peer) error) error

func (SubscriptionSet) ApplyIdx

func (set SubscriptionSet) ApplyIdx(f func(idx int, s Peer))

func (SubscriptionSet) Filter

func (set SubscriptionSet) Filter(filters ...peerFilter) SubscriptionSet