requester

Documentation

Index

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

Constants

const UseDeprecatedEndpointsForTesting = "REQUESTER_ENDPOINT_USE_DEPRECATED_ENV"

NB: to whomever removes this, grep for the env var when doing so, we can't use this variable everywhere due to circular deps TODO: https://github.com/bacalhau-project/bacalhau/issues/4119

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
}