grpc

Documentation

Overview

Package grpc provides a gRPC service to effectively run task instances on multiple workers.

Index

• Constants
• type Handler
  • func (h *Handler) Control(ctx context.Context, command *jobs.CtrlCommand) (*jobs.CtrlCommandResponse, error)
  • func (h *Handler) Name() string

Constants

const ServiceName = common.ServiceGrpcNamespace_ + common.ServiceTasks

Types

type Handler

type Handler struct {
	jobs.UnimplementedTaskServiceServer
}

Handler implements the TaskService API

func (*Handler) Control

func (h *Handler) Control(ctx context.Context, command *jobs.CtrlCommand) (*jobs.CtrlCommandResponse, error)

Control publishes the passed command

func (*Handler) Name

func (h *Handler) Name() string