coordinator

package
v0.1.7 Latest Latest
Warning

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

Go to latest
Published: Sep 12, 2023 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

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

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

func (*Coordinator) SubmitJob added in v0.1.7

func (c *Coordinator) SubmitJob(ctx context.Context, ij *input.Job) (*tork.Job, error)

type Middleware added in v0.1.6

type Middleware struct {
	Web  []web.MiddlewareFunc
	Task []task.MiddlewareFunc
	Job  []job.MiddlewareFunc
	Node []node.MiddlewareFunc
	Echo []echo.MiddlewareFunc
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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