juju: github.com/juju/juju/worker/raft/raftclusterer Index | Files

package raftclusterer

import "github.com/juju/juju/worker/raft/raftclusterer"

Index

Package Files

manifold.go worker.go

func Manifold Uses

func Manifold(config ManifoldConfig) dependency.Manifold

func NewWorker Uses

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

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

type Config Uses

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 Uses

func (config Config) Validate() error

Validate validates the raft worker configuration.

type ManifoldConfig Uses

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 Uses

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

Worker is a worker that manages raft cluster configuration.

func (*Worker) Kill Uses

func (w *Worker) Kill()

Kill is part of the worker.Worker interface.

func (*Worker) Wait Uses

func (w *Worker) Wait() error

Wait is part of the worker.Worker interface.

Package raftclusterer imports 8 packages (graph) and is imported by 3 packages. Updated 2019-09-11. Refresh now. Tools for package owners.