replication

Documentation

Index

• type Delta
  • func ComputeDelta(before, after []Replica) []Delta
• type DeltaKind
• type Manager
  • func NewManager(seeker dbLog.SeekingLog) *Manager
  • func (m *Manager) Reconcile(replicas []Replica) error
  • func (m *Manager) Start(ctx context.Context) <-chan struct{}
• type Replica
  • func FromMetadata(m protocol.Metadata, coordinator uuid.UUID) []Replica
  • func (r *Replica) String() string

Types

type Delta

type Delta struct {
	Kind    DeltaKind
	Replica Replica
}

func ComputeDelta

func ComputeDelta(before, after []Replica) []Delta

type DeltaKind

type DeltaKind uint8

const (
	Removed DeltaKind = iota + 1
	Added
)

type Manager

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

Manager is responsible for the runtime management of replicas. It maintains connections to replicas and periodically flushes new log entries to the tasks

func NewManager

func NewManager(seeker dbLog.SeekingLog) *Manager

func (*Manager) Reconcile

func (m *Manager) Reconcile(replicas []Replica) error

Reconcile - Every time we receive new metadata we need to reconcile them with the old version to see if our replica membership has changed, and then act accordingly

func (*Manager) Start

func (m *Manager) Start(ctx context.Context) <-chan struct{}

type Replica

type Replica struct {
	Start, End  uint128.Uint128
	PrivateAddr *net.TCPAddr
}

func FromMetadata

func FromMetadata(m protocol.Metadata, coordinator uuid.UUID) []Replica

FromMetadata - get tasks for a given coordinator

func (*Replica) String

func (r *Replica) String() string