coordinator

Documentation

Index

• type Config
• type Coordinator
  • func NewCoordinator(cfg Config) (*Coordinator, error)
  • func (c *Coordinator) Start() error
  • func (c *Coordinator) Stop() error

Types

type Config

type Config struct {
	Broker      mq.Broker
	DataStore   datastore.Datastore
	Address     string
	Queues      map[string]int
	Middlewares []middleware.MiddlewareFunc
	Endpoints   map[string]middleware.HandlerFunc
	Enabled     map[string]bool
}

type Coordinator

type Coordinator struct {
	Name string
	// contains filtered or unexported fields
}

Coordinator is responsible for accepting tasks from clients, scheduling tasks for workers to execute and for exposing the cluster's state to the outside world.

func NewCoordinator

func NewCoordinator(cfg Config) (*Coordinator, error)

func (*Coordinator) Start

func (c *Coordinator) Start() error

func (*Coordinator) Stop

func (c *Coordinator) Stop() error