requester

Documentation

Index

• type BaseEndpoint
  • func NewBaseEndpoint(params *BaseEndpointParams) *BaseEndpoint
  • func (e *BaseEndpoint) OnBidComplete(ctx context.Context, response compute.BidResult)
  • func (e *BaseEndpoint) OnCancelComplete(ctx context.Context, result compute.CancelResult)
  • func (e *BaseEndpoint) OnComputeFailure(ctx context.Context, result compute.ComputeError)
  • func (e *BaseEndpoint) OnRunComplete(ctx context.Context, result compute.RunResult)
• type BaseEndpointParams

Types

type BaseEndpoint

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

BaseEndpoint base implementation of requester Endpoint

func NewBaseEndpoint

func NewBaseEndpoint(params *BaseEndpointParams) *BaseEndpoint

func (*BaseEndpoint) OnBidComplete

func (e *BaseEndpoint) OnBidComplete(ctx context.Context, response compute.BidResult)

OnBidComplete implements compute.Callback

func (*BaseEndpoint) OnCancelComplete

func (e *BaseEndpoint) OnCancelComplete(ctx context.Context, result compute.CancelResult)

func (*BaseEndpoint) OnComputeFailure

func (e *BaseEndpoint) OnComputeFailure(ctx context.Context, result compute.ComputeError)

func (*BaseEndpoint) OnRunComplete

func (e *BaseEndpoint) OnRunComplete(ctx context.Context, result compute.RunResult)

type BaseEndpointParams

type BaseEndpointParams struct {
	ID           string
	Store        jobstore.Store
	EventEmitter orchestrator.EventEmitter
}