orchestrator

Documentation

Index

• type OpJoin
• type OpMove
• type OpSplit
• type Orchestrator
  • func New(ks *keyspace.Keyspace, rost *roster.Roster, srv *grpc.Server) *Orchestrator
  • func (b *Orchestrator) Run(t *time.Ticker)
  • func (b *Orchestrator) Tick()

Types

type OpJoin

type OpJoin struct {
	Left  api.RangeID
	Right api.RangeID
	Dest  api.NodeID
	Err   chan error
}

type OpMove

type OpMove struct {
	Range api.RangeID
	Src   api.NodeID
	Dest  api.NodeID
	Err   chan error
}

TODO: Split this into Add, Remove

type OpSplit

type OpSplit struct {
	Range api.RangeID
	Key   api.Key

	// TODO: Update this interface (and the proto) to accomodate replication.
	// Currently only the first placement can be placed deliberately. Others
	// just go wherever.
	Left  api.NodeID
	Right api.NodeID

	Err chan error
}

type Orchestrator

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

func New

func New(ks *keyspace.Keyspace, rost *roster.Roster, srv *grpc.Server) *Orchestrator

func (*Orchestrator) Run

func (b *Orchestrator) Run(t *time.Ticker)

func (*Orchestrator) Tick

func (b *Orchestrator) Tick()