orchestration

Documentation

Index

• Variables
• func CallDeploy(ctx context.Context, env cfg.Context, conn *grpc.ClientConn, ...) (string, error)
• func Deploy(ctx context.Context, env cfg.Context, cluster runtime.ClusterNamespace, ...) error
• func ExecuteOpts() execution.ExecuteOpts
• func MakeOrchestratorContext(ctx context.Context, conf cfg.Configuration) (cfg.Context, error)
• func MakeSyntheticConfiguration(wsproto *schema.Workspace, envName string, hostEnv *client.HostEnv, ...) cfg.Configuration
• func MakeSyntheticContext(wsproto *schema.Workspace, env *schema.Environment, hostEnv *client.HostEnv, ...) cfg.Context
• func PrepareOrchestrator(ctx context.Context, targetEnv cfg.Configuration, cluster runtime.Cluster, ...) (any, error)
• func RegisterPrepare()
• func WireDeploymentStatus(ctx context.Context, conn *grpc.ClientConn, id string, ...) error
• type RemoteOrchestrator
  • func (c *RemoteOrchestrator) Connect(ctx context.Context) (*grpc.ClientConn, error)

Variables

var (
	UseOrchestrator              = true
	UseHeadOrchestrator          = false
	SkipVersionCache             = false
	RenderOrchestratorDeployment = false
)

Functions

func CallDeploy

func CallDeploy(ctx context.Context, env cfg.Context, conn *grpc.ClientConn, plan *schema.DeployPlan) (string, error)

func Deploy

func Deploy(ctx context.Context, env cfg.Context, cluster runtime.ClusterNamespace, plan *schema.DeployPlan, wait, outputProgress bool) error

func ExecuteOpts

func ExecuteOpts() execution.ExecuteOpts

func MakeOrchestratorContext

func MakeOrchestratorContext(ctx context.Context, conf cfg.Configuration) (cfg.Context, error)

func MakeSyntheticConfiguration

func MakeSyntheticConfiguration(wsproto *schema.Workspace, envName string, hostEnv *client.HostEnv, extra ...proto.Message) cfg.Configuration

func MakeSyntheticContext

func MakeSyntheticContext(wsproto *schema.Workspace, env *schema.Environment, hostEnv *client.HostEnv, extra ...proto.Message) cfg.Context

func PrepareOrchestrator

func PrepareOrchestrator(ctx context.Context, targetEnv cfg.Configuration, cluster runtime.Cluster, wait bool) (any, error)

func RegisterPrepare

func RegisterPrepare()

func WireDeploymentStatus

func WireDeploymentStatus(ctx context.Context, conn *grpc.ClientConn, id string, ch chan *orchestration.Event) error

Types

type RemoteOrchestrator

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

func (*RemoteOrchestrator) Connect

func (c *RemoteOrchestrator) Connect(ctx context.Context) (*grpc.ClientConn, error)