elastic

Documentation

Index

• type Elastic
  • func NewElastic(conf config.Elastic) (*Elastic, error)
  • func (es *Elastic) Close()
  • func (es *Elastic) DeleteNode(ctx context.Context, node *scheduler.Node) (*scheduler.DeleteNodeResponse, error)
  • func (es *Elastic) GetNode(ctx context.Context, req *scheduler.GetNodeRequest) (*scheduler.Node, error)
  • func (es *Elastic) GetTask(ctx context.Context, req *tes.GetTaskRequest) (*tes.Task, error)
  • func (es *Elastic) Init() error
  • func (es *Elastic) ListNodes(ctx context.Context, req *scheduler.ListNodesRequest) (*scheduler.ListNodesResponse, error)
  • func (es *Elastic) ListTasks(ctx context.Context, req *tes.ListTasksRequest) (*tes.ListTasksResponse, error)
  • func (es *Elastic) PutNode(ctx context.Context, node *scheduler.Node) (*scheduler.PutNodeResponse, error)
  • func (es *Elastic) ReadQueue(n int) []*tes.Task
  • func (es *Elastic) WriteEvent(ctx context.Context, ev *events.Event) error

Types

type Elastic

type Elastic struct {
	scheduler.UnimplementedSchedulerServiceServer
	// contains filtered or unexported fields
}

Elastic provides an elasticsearch database server backend.

func NewElastic

func NewElastic(conf config.Elastic) (*Elastic, error)

NewElastic returns a new Elastic instance.

func (*Elastic) Close

func (es *Elastic) Close()

Close closes the database client.

func (*Elastic) DeleteNode

func (es *Elastic) DeleteNode(ctx context.Context, node *scheduler.Node) (*scheduler.DeleteNodeResponse, error)

DeleteNode deletes a node by ID.

func (*Elastic) GetNode

func (es *Elastic) GetNode(ctx context.Context, req *scheduler.GetNodeRequest) (*scheduler.Node, error)

GetNode gets a node

func (*Elastic) GetTask

func (es *Elastic) GetTask(ctx context.Context, req *tes.GetTaskRequest) (*tes.Task, error)

GetTask gets a task by ID.

func (*Elastic) Init

func (es *Elastic) Init() error

Init creates the Elasticsearch indices.

func (*Elastic) ListNodes

func (es *Elastic) ListNodes(ctx context.Context, req *scheduler.ListNodesRequest) (*scheduler.ListNodesResponse, error)

ListNodes is an API endpoint that returns a list of nodes.

func (*Elastic) ListTasks

func (es *Elastic) ListTasks(ctx context.Context, req *tes.ListTasksRequest) (*tes.ListTasksResponse, error)

ListTasks lists tasks, duh.

func (*Elastic) PutNode

func (es *Elastic) PutNode(ctx context.Context, node *scheduler.Node) (*scheduler.PutNodeResponse, error)

PutNode puts a node in the database.

For optimisic locking, if the node already exists and node.Version doesn't match the version in the database, an error is returned.

func (*Elastic) ReadQueue

func (es *Elastic) ReadQueue(n int) []*tes.Task

ReadQueue returns a slice of queued Tasks. Up to "n" tasks are returned.

func (*Elastic) WriteEvent

func (es *Elastic) WriteEvent(ctx context.Context, ev *events.Event) error

WriteEvent writes a task update event.