orchestrator

package
v0.0.0-...-ba27772 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 18, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL