server

Documentation

Index

• type Heartbeat
  • func NewHeartbeat(config *config.Config, client sdk_v1.ManagerServiceClient) *Heartbeat
  • func (h *Heartbeat) Start()
  • func (h *Heartbeat) Stop()
• type Server
  • func NewServer(cfg *config.Config, worker sdk_v1.Worker, client sdk_v1.ManagerServiceClient) *Server
  • func (s Server) ExecuteJob(ctx context.Context, request *sdk_v1.ExecuteJobRequest) (*sdk_v1.ExecuteJobResponse, error)
  • func (s Server) Start() error
  • func (s Server) Stop()

Types

type Heartbeat

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

func NewHeartbeat

func NewHeartbeat(config *config.Config, client sdk_v1.ManagerServiceClient) *Heartbeat

func (*Heartbeat) Start

func (h *Heartbeat) Start()

func (*Heartbeat) Stop

func (h *Heartbeat) Stop()

type Server

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

func NewServer

func NewServer(cfg *config.Config, worker sdk_v1.Worker, client sdk_v1.ManagerServiceClient) *Server

func (Server) ExecuteJob

func (s Server) ExecuteJob(ctx context.Context, request *sdk_v1.ExecuteJobRequest) (*sdk_v1.ExecuteJobResponse, error)

func (Server) Start

func (s Server) Start() error

func (Server) Stop

func (s Server) Stop()