client

Documentation

Index

• Constants
• Variables
• func CallAreServicesReady(ctx context.Context, conn *grpc.ClientConn, srv runtime.Deployable, ns string) (*proto.AreServicesReadyResponse, error)
• func CallDeploy(ctx context.Context, env cfg.Context, conn *grpc.ClientConn, ...) (string, error)
• func ConnectToOrchestrator(ctx context.Context, cluster runtime.Cluster) (*grpc.ClientConn, error)
• func RegisterOrchestrator(...)
• func RemoteOrchestrator(cluster runtime.ClusterNamespace, server runtime.Deployable) *remoteOrchestrator
• func WireDeploymentStatus(ctx context.Context, conn *grpc.ClientConn, id string, ...) error

Constants

const (
	ConnTimeout = time.Minute // TODO reduce - we've seen slow connections in CI
)

Variables

var UseOrchestrator = true

Functions

func CallAreServicesReady

func CallAreServicesReady(ctx context.Context, conn *grpc.ClientConn, srv runtime.Deployable, ns string) (*proto.AreServicesReadyResponse, error)

func CallDeploy

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

func ConnectToOrchestrator

func ConnectToOrchestrator(ctx context.Context, cluster runtime.Cluster) (*grpc.ClientConn, error)

func RegisterOrchestrator

func RegisterOrchestrator(prepare func(ctx context.Context, target cfg.Configuration, cluster runtime.Cluster) (any, error))

func RemoteOrchestrator

func RemoteOrchestrator(cluster runtime.ClusterNamespace, server runtime.Deployable) *remoteOrchestrator

func WireDeploymentStatus

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