raftclusterer

Documentation

Index

• func Manifold(config ManifoldConfig) dependency.Manifold
• func NewWorker(config Config) (worker.Worker, error)
• type Config
  • func (config Config) Validate() error
• type ManifoldConfig
• type Worker
  • func (w *Worker) Kill()
  • func (w *Worker) Wait() error

Functions

func Manifold

func Manifold(config ManifoldConfig) dependency.Manifold

func NewWorker

func NewWorker(config Config) (worker.Worker, error)

NewWorker returns a new worker responsible for maintaining the raft cluster configuration.

Types

type Config

type Config struct {
	Raft *raft.Raft
	Hub  *pubsub.StructuredHub
}

Config holds the configuration necessary to run a worker for maintaining the raft cluster configuration.

func (Config) Validate

func (config Config) Validate() error

Validate validates the raft worker configuration.

type ManifoldConfig

type ManifoldConfig struct {
	RaftName       string
	CentralHubName string

	NewWorker func(Config) (worker.Worker, error)
}

ManifoldConfig holds the information necessary to run a worker for maintaining the raft cluster configuration in a dependency.Engine.

type Worker

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

Worker is a worker that manages raft cluster configuration.

func (*Worker) Kill

func (w *Worker) Kill()

Kill is part of the worker.Worker interface.

func (*Worker) Wait

func (w *Worker) Wait() error

Wait is part of the worker.Worker interface.