requester

Documentation

Index

• type Endpoint
  • func NewEndpoint(params EndpointParams) *Endpoint
  • func (s *Endpoint) HandleJobEvent(ctx context.Context, event model.JobEvent) error
• type EndpointParams
• type Msg

Types

type Endpoint

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

func NewEndpoint

func NewEndpoint(params EndpointParams) *Endpoint

func (*Endpoint) HandleJobEvent

func (s *Endpoint) HandleJobEvent(ctx context.Context, event model.JobEvent) error

type EndpointParams

type EndpointParams struct {
	Router             *echo.Echo
	Requester          requester.Endpoint
	DebugInfoProviders []model.DebugInfoProvider
	JobStore           jobstore.Store
	NodeDiscoverer     orchestrator.NodeDiscoverer
}

type Msg

type Msg struct {
	Tag          uint8
	Data         string
	ErrorMessage string
}