transport

Documentation

Index

• type TransportLayer

Types

type TransportLayer

type TransportLayer interface {
	// ComputeProxy enables orchestrator nodes to send job requests to compute nodes.
	ComputeProxy() compute.Endpoint

	// CallbackProxy enables compute nodes to send results and responses back to orchestrator nodes
	CallbackProxy() compute.Callback

	// RegistrationProxy enables compute nodes to register with the cluster
	ManagementProxy() compute.ManagementEndpoint

	// NodeInfoPubSub enables compute nodes to publish their info and capabilities
	// to orchestrator nodes for job matching and discovery.
	NodeInfoPubSub() pubsub.PubSub[models.NodeState]

	// NodeInfoDecorator enables transport layer to enrich node info with data
	// required for request routing
	NodeInfoDecorator() models.NodeInfoDecorator

	// DebugInfoProviders enables transport layer to provide meaningful debug info to operators
	DebugInfoProviders() []model.DebugInfoProvider

	// RegisterNodeInfoConsumer registers a node info consumer with the transport layer
	RegisterNodeInfoConsumer(ctx context.Context, infostore routing.NodeInfoStore) error

	// RegisterComputeCallback registers a compute callback with the transport layer
	// so that incoming compute responses are forwarded to the handler
	RegisterComputeCallback(callback compute.Callback) error

	// RegisterComputeEndpoint registers a compute endpoint with the transport layer
	// so that incoming orchestrator requests are forwarded to the handler
	RegisterComputeEndpoint(ctx context.Context, endpoint compute.Endpoint) error

	// RegisterRegistrationEndpoint registers a requester endpoint that computes nodes
	// can use to register with the cluster.
	RegisterManagementEndpoint(endpoint compute.ManagementEndpoint) error

	// Close closes the transport layer.
	Close(ctx context.Context) error
}

TransportLayer is the interface for the transport layer.