server

Documentation

Index

• type AntiEntropyRound
  • func NewAntiEntropyRound(peer Peer, tree *mst.MerkleSearchTree) AntiEntropyRound
• type EndRoundFunc
• type MSTManagerServer
  • func NewMSTManagerServer(server *MSTServer, kr mst.KeyReader, vr mst.ValueReader) *MSTManagerServer
  • func (s *MSTManagerServer) RoundStart(ctx context.Context, in *rpc.MSTRoundStartRequest) (*rpc.MSTRoundStepResponse, error)
  • func (s *MSTManagerServer) RoundStep(ctx context.Context, in *rpc.MSTRoundStepRequest) (*rpc.MSTRoundStepResponse, error)
• type MSTServer
  • func NewMSTServer(tree *mst.MerkleSearchTree, peers *Peers) *MSTServer
  • func (s *MSTServer) Get(ctx context.Context, in *rpc.MSTGetRequest) (*rpc.MSTGetResponse, error)
  • func (s *MSTServer) Put(ctx context.Context, in *rpc.MSTPutRequest) (*empty.Empty, error)
• type Peer
• type PeerSelectionStrategy
• type Peers
  • func NewPeers(selectionStrategy PeerSelectionStrategy) *Peers
  • func (ps *Peers) Add(hostname string, port int)
  • func (ps *Peers) Select() []Peer
• type SelectAll
  • func (s *SelectAll) Select(peerSet map[Peer]bool) []Peer

Types

type AntiEntropyRound

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

AntiEntropyRound represents a round of anti-entropy with another vulture host.

func NewAntiEntropyRound

func NewAntiEntropyRound(peer Peer, tree *mst.MerkleSearchTree) AntiEntropyRound

NewAntiEntropyRound creates new AntiEntropyRound

type EndRoundFunc

type EndRoundFunc func()

EndRoundFunc is the signature for ending the anti entropy round When called, it tells the caller that the round is over so that it can clean up whatever needs to be cleaned up

type MSTManagerServer

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

MSTManagerServer stores data required for managing the Vulture server TODO: right now we don't do any cleanup of destination rounds, so there may be a memory leak if we have stray rounds. We could include a garbage collection round at some point here.

func NewMSTManagerServer

func NewMSTManagerServer(
	server *MSTServer,
	kr mst.KeyReader,
	vr mst.ValueReader,
) *MSTManagerServer

NewMSTManagerServer creates a new Vulture management server

func (*MSTManagerServer) RoundStart

func (s *MSTManagerServer) RoundStart(
	ctx context.Context,
	in *rpc.MSTRoundStartRequest,
) (*rpc.MSTRoundStepResponse, error)

RoundStart starts a round of anti entropy

func (*MSTManagerServer) RoundStep

func (s *MSTManagerServer) RoundStep(
	ctx context.Context,
	in *rpc.MSTRoundStepRequest,
) (*rpc.MSTRoundStepResponse, error)

RoundStep does a step of anti entropy

type MSTServer

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

MSTServer stores all local data required for running the Vulture server

func NewMSTServer

func NewMSTServer(tree *mst.MerkleSearchTree, peers *Peers) *MSTServer

NewMSTServer creates a new Vulture server

func (*MSTServer) Get

func (s *MSTServer) Get(ctx context.Context, in *rpc.MSTGetRequest) (*rpc.MSTGetResponse, error)

Get returns the value for a given key

func (*MSTServer) Put

func (s *MSTServer) Put(ctx context.Context, in *rpc.MSTPutRequest) (*empty.Empty, error)

Put inserts the given value for the given key

type Peer

type Peer struct {
	Hostname string
	Port     int
}

type PeerSelectionStrategy

type PeerSelectionStrategy interface {
	Select(peers map[Peer]bool) []Peer
}

type Peers

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

func NewPeers

func NewPeers(selectionStrategy PeerSelectionStrategy) *Peers

func (*Peers) Add

func (ps *Peers) Add(hostname string, port int)

func (*Peers) Select

func (ps *Peers) Select() []Peer

type SelectAll

type SelectAll struct{}

func (*SelectAll) Select

func (s *SelectAll) Select(peerSet map[Peer]bool) []Peer