service

Documentation

Index

• Variables
• func WireService(ctx context.Context, srv server.Registrar, deps ServiceDeps)
• type RunningDeployment
• type Service
  • func (svc *Service) AreServicesReady(ctx context.Context, req *proto.AreServicesReadyRequest) (*proto.AreServicesReadyResponse, error)
  • func (svc *Service) Deploy(ctx context.Context, req *proto.DeployRequest) (*proto.DeployResponse, error)
  • func (svc *Service) DeploymentStatus(req *proto.DeploymentStatusRequest, ...) error
  • func (svc *Service) GetOrchestratorVersion(ctx context.Context, req *proto.GetOrchestratorVersionRequest) (*proto.GetOrchestratorVersionResponse, error)
• type ServiceDeps
• type TaskEventEntry

Variables

var (
	Package__v9aee7 = &core.Package{
		PackageName: "namespacelabs.dev/foundation/orchestration/service",
	}

	Provider__v9aee7 = core.Provider{
		Package:     Package__v9aee7,
		Instantiate: makeDeps__v9aee7,
	}
)

Functions

func WireService

func WireService(ctx context.Context, srv server.Registrar, deps ServiceDeps)

Types

type RunningDeployment

type RunningDeployment struct {
	ID string
}

type Service

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

func (*Service) AreServicesReady

func (svc *Service) AreServicesReady(ctx context.Context, req *proto.AreServicesReadyRequest) (*proto.AreServicesReadyResponse, error)

func (*Service) Deploy

func (svc *Service) Deploy(ctx context.Context, req *proto.DeployRequest) (*proto.DeployResponse, error)

func (*Service) DeploymentStatus

func (svc *Service) DeploymentStatus(req *proto.DeploymentStatusRequest, stream proto.OrchestrationService_DeploymentStatusServer) error

func (*Service) GetOrchestratorVersion

func (svc *Service) GetOrchestratorVersion(ctx context.Context, req *proto.GetOrchestratorVersionRequest) (*proto.GetOrchestratorVersionResponse, error)

type ServiceDeps

type ServiceDeps struct {
}

Dependencies that are instantiated once for the lifetime of the service.

type TaskEventEntry

type TaskEventEntry struct {
	Done      bool                                     `json:"done,omitempty"`
	Timestamp time.Time                                `json:"timestamp,omitempty"`
	Error     *spb.Status                              `json:"error,omitempty"`
	Log       *serializedMessage[*protolog.Log]        `json:"log,omitempty"`
	Event     *serializedMessage[*orchestration.Event] `json:"event,omitempty"`
}