Documentation ¶
Index ¶
- Constants
- type CallbackHandler
- type CallbackHandlerParams
- type CallbackProxy
- func (p *CallbackProxy) OnBidComplete(ctx context.Context, result compute.BidResult)
- func (p *CallbackProxy) OnCancelComplete(ctx context.Context, result compute.CancelResult)
- func (p *CallbackProxy) OnComputeFailure(ctx context.Context, result compute.ComputeError)
- func (p *CallbackProxy) OnRunComplete(ctx context.Context, result compute.RunResult)
- type CallbackProxyParams
- type ComputeHandler
- type ComputeHandlerParams
- type ComputeProxy
- func (p *ComputeProxy) AskForBid(ctx context.Context, request compute.AskForBidRequest) (compute.AskForBidResponse, error)
- func (p *ComputeProxy) BidAccepted(ctx context.Context, request compute.BidAcceptedRequest) (compute.BidAcceptedResponse, error)
- func (p *ComputeProxy) BidRejected(ctx context.Context, request compute.BidRejectedRequest) (compute.BidRejectedResponse, error)
- func (p *ComputeProxy) CancelExecution(ctx context.Context, request compute.CancelExecutionRequest) (compute.CancelExecutionResponse, error)
- func (p *ComputeProxy) ExecutionLogs(ctx context.Context, request compute.ExecutionLogsRequest) (compute.ExecutionLogsResponse, error)
- type ComputeProxyParams
- type Result
Constants ¶
const ( ComputeEndpointSubjectPrefix = "node.compute" CallbackSubjectPrefix = "node.orchestrator" AskForBid = "AskForBid/v1" BidAccepted = "BidAccepted/v1" BidRejected = "BidRejected/v1" CancelExecution = "CancelExecution/v1" ExecutionLogs = "ExecutionLogs/v1" OnBidComplete = "OnBidComplete/v1" OnRunComplete = "OnRunComplete/v1" OnCancelComplete = "OnCancelComplete/v1" OnComputeFailure = "OnComputeFailure/v1" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CallbackHandler ¶
type CallbackHandler struct {
// contains filtered or unexported fields
}
CallbackHandler is a handler for callback events that registers for incoming nats requests to Bacalhau callback protocol, and delegates the handling of the request to the provided callback.
func NewCallbackHandler ¶
func NewCallbackHandler(params CallbackHandlerParams) (*CallbackHandler, error)
type CallbackHandlerParams ¶
type CallbackProxy ¶
type CallbackProxy struct {
// contains filtered or unexported fields
}
CallbackProxy is a proxy for a compute.Callback that can be used to send compute callbacks to the requester node, such as when the execution is completed or when a failure occurs. The proxy can forward callbacks to a remote requester node, or locally if the node is the requester and a LocalCallback is provided.
func NewCallbackProxy ¶
func NewCallbackProxy(params CallbackProxyParams) *CallbackProxy
func (*CallbackProxy) OnBidComplete ¶
func (p *CallbackProxy) OnBidComplete(ctx context.Context, result compute.BidResult)
func (*CallbackProxy) OnCancelComplete ¶
func (p *CallbackProxy) OnCancelComplete(ctx context.Context, result compute.CancelResult)
func (*CallbackProxy) OnComputeFailure ¶
func (p *CallbackProxy) OnComputeFailure(ctx context.Context, result compute.ComputeError)
func (*CallbackProxy) OnRunComplete ¶
func (p *CallbackProxy) OnRunComplete(ctx context.Context, result compute.RunResult)
type CallbackProxyParams ¶
type CallbackProxyParams struct {
Conn *nats.Conn
}
type ComputeHandler ¶
type ComputeHandler struct {
// contains filtered or unexported fields
}
ComputeHandler handles NATS messages for compute operations.
func NewComputeHandler ¶
func NewComputeHandler(params ComputeHandlerParams) (*ComputeHandler, error)
NewComputeHandler creates a new ComputeHandler.
type ComputeHandlerParams ¶
ComputeHandlerParams defines parameters for creating a new ComputeHandler.
type ComputeProxy ¶
type ComputeProxy struct {
// contains filtered or unexported fields
}
ComputeProxy is a proxy to a compute node endpoint that will forward requests to remote compute nodes, or to a local compute node if the target peer ID is the same as the local host, and a LocalEndpoint implementation is provided.
func NewComputeProxy ¶
func NewComputeProxy(params ComputeProxyParams) *ComputeProxy
func (*ComputeProxy) AskForBid ¶
func (p *ComputeProxy) AskForBid(ctx context.Context, request compute.AskForBidRequest) (compute.AskForBidResponse, error)
func (*ComputeProxy) BidAccepted ¶
func (p *ComputeProxy) BidAccepted(ctx context.Context, request compute.BidAcceptedRequest) (compute.BidAcceptedResponse, error)
func (*ComputeProxy) BidRejected ¶
func (p *ComputeProxy) BidRejected(ctx context.Context, request compute.BidRejectedRequest) (compute.BidRejectedResponse, error)
func (*ComputeProxy) CancelExecution ¶
func (p *ComputeProxy) CancelExecution( ctx context.Context, request compute.CancelExecutionRequest) (compute.CancelExecutionResponse, error)
func (*ComputeProxy) ExecutionLogs ¶
func (p *ComputeProxy) ExecutionLogs( ctx context.Context, request compute.ExecutionLogsRequest) (compute.ExecutionLogsResponse, error)
type ComputeProxyParams ¶
type ComputeProxyParams struct {
Conn *nats.Conn
}