Documentation
¶
Overview ¶
This file implements a local k8s kind cluster runtime, which is meant to be used for testing purposes.
Index ¶
- func NewKindRuntime(metaInstancesClient mrdspb.MetaInstancesClient, ...) runtime.RuntimeActivities
- type KindRuntime
- func (k *KindRuntime) Register(w worker.Registry)
- func (k *KindRuntime) StartInstance(ctx context.Context, req *runtime.RuntimeActivityRequest) (*runtime.RuntimeActivityResponse, error)
- func (k *KindRuntime) StopInstance(ctx context.Context, req *runtime.RuntimeActivityRequest) (*runtime.RuntimeActivityResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKindRuntime ¶
func NewKindRuntime( metaInstancesClient mrdspb.MetaInstancesClient, deploymentPlanClient mrdspb.DeploymentPlansClient, nodesClient mrdspb.NodesClient, k8sClientSet *kubernetes.Clientset, ) runtime.RuntimeActivities
Types ¶
type KindRuntime ¶
type KindRuntime struct {
// contains filtered or unexported fields
}
func (*KindRuntime) Register ¶
func (k *KindRuntime) Register(w worker.Registry)
func (*KindRuntime) StartInstance ¶
func (k *KindRuntime) StartInstance(ctx context.Context, req *runtime.RuntimeActivityRequest) (*runtime.RuntimeActivityResponse, error)
func (*KindRuntime) StopInstance ¶
func (k *KindRuntime) StopInstance(ctx context.Context, req *runtime.RuntimeActivityRequest) (*runtime.RuntimeActivityResponse, error)
Click to show internal directories.
Click to hide internal directories.