runtime

Documentation

Index

• type KubernetesRuntime
  • func (k *KubernetesRuntime) Apply(ctx context.Context, priorState, planState *states.ResourceState) (*states.ResourceState, status.Status)
  • func (k *KubernetesRuntime) Delete(ctx context.Context, resourceState *states.ResourceState) status.Status
  • func (k *KubernetesRuntime) Read(ctx context.Context, resourceState *states.ResourceState) (*states.ResourceState, status.Status)
  • func (k *KubernetesRuntime) Watch(ctx context.Context, resourceState *states.ResourceState) (*states.ResourceState, status.Status)
• type Runtime
  • func NewKubernetesRuntime() (Runtime, error)

Types

type KubernetesRuntime

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

func (*KubernetesRuntime) Apply

func (k *KubernetesRuntime) Apply(ctx context.Context, priorState, planState *states.ResourceState) (*states.ResourceState, status.Status)

Apply kubernetes resource by client-go

func (*KubernetesRuntime) Delete

func (k *KubernetesRuntime) Delete(ctx context.Context, resourceState *states.ResourceState) status.Status

Delete kubernetes resource by client-go

func (*KubernetesRuntime) Read

func (k *KubernetesRuntime) Read(ctx context.Context, resourceState *states.ResourceState) (*states.ResourceState, status.Status)

Read kubernetes resource by client-go

func (*KubernetesRuntime) Watch

func (k *KubernetesRuntime) Watch(ctx context.Context, resourceState *states.ResourceState) (*states.ResourceState, status.Status)

Watch kubernetes resource by client-go

type Runtime

type Runtime interface {
	// Apply resource with planState. priorState is given to Runtime for three-way-merge if it needs
	Apply(ctx context.Context, priorState, planState *states.ResourceState) (*states.ResourceState, status.Status)

	// Read the latest state of this resource
	Read(ctx context.Context, resourceState *states.ResourceState) (*states.ResourceState, status.Status)

	// Delete resource
	Delete(ctx context.Context, resourceState *states.ResourceState) status.Status

	// Watch the latest state or event of this resource. This is very helpful for us to know what is happening when apply resources
	Watch(ctx context.Context, resourceState *states.ResourceState) (*states.ResourceState, status.Status)
}

func NewKubernetesRuntime

func NewKubernetesRuntime() (Runtime, error)

NewKubernetesRuntime create a new KubernetesRuntime