k8sexp

Documentation

Index

• type K8sProviderExp
  • func NewK8sProvider(ctx context.Context, cid, app, cluster, level, namespace string) (*K8sProviderExp, error)
  • func (p *K8sProviderExp) Apply(ctx context.Context, name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *K8sProviderExp) ApplyConfig(ctx context.Context, config interface{}) error
  • func (p *K8sProviderExp) ApplyStatusCR(ctx context.Context, name string, content []byte) error
  • func (p *K8sProviderExp) CleanClientProvider() error
  • func (p *K8sProviderExp) Commit(ctx context.Context, ref interface{}) error
  • func (p *K8sProviderExp) Create(name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *K8sProviderExp) Delete(name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *K8sProviderExp) DeleteConfig(ctx context.Context, config interface{}) error
  • func (p *K8sProviderExp) DeleteStatusCR(ctx context.Context, name string, content []byte) error
  • func (p *K8sProviderExp) Get(ctx context.Context, name string, gvkRes []byte) ([]byte, error)
  • func (p *K8sProviderExp) IsReachable() error
  • func (c *K8sProviderExp) StartClusterWatcher(ctx context.Context) error
  • func (m *K8sProviderExp) TagResource(res []byte, label map[string]string) ([]byte, error)

Types

type K8sProviderExp

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

Connection is for a cluster

func NewK8sProvider

func NewK8sProvider(ctx context.Context, cid, app, cluster, level, namespace string) (*K8sProviderExp, error)

func (*K8sProviderExp) Apply

func (p *K8sProviderExp) Apply(ctx context.Context, name string, ref interface{}, content []byte) (interface{}, error)

Apply resource to the cluster

func (*K8sProviderExp) ApplyConfig

func (p *K8sProviderExp) ApplyConfig(ctx context.Context, config interface{}) error

For K8s this function is not required to do any operation at this time

func (*K8sProviderExp) ApplyStatusCR

func (p *K8sProviderExp) ApplyStatusCR(ctx context.Context, name string, content []byte) error

ApplyStatusCR applies status CR

func (*K8sProviderExp) CleanClientProvider

func (p *K8sProviderExp) CleanClientProvider() error

If file exists delete it

func (*K8sProviderExp) Commit

func (p *K8sProviderExp) Commit(ctx context.Context, ref interface{}) error

Commit resources to the cluster

func (*K8sProviderExp) Create

func (p *K8sProviderExp) Create(name string, ref interface{}, content []byte) (interface{}, error)

Creates a new resource if the not already existing

func (*K8sProviderExp) Delete

func (p *K8sProviderExp) Delete(name string, ref interface{}, content []byte) (interface{}, error)

Delete resource from the cluster

func (*K8sProviderExp) DeleteConfig

func (p *K8sProviderExp) DeleteConfig(ctx context.Context, config interface{}) error

func (*K8sProviderExp) DeleteStatusCR

func (p *K8sProviderExp) DeleteStatusCR(ctx context.Context, name string, content []byte) error

DeleteStatusCR deletes status CR

func (*K8sProviderExp) Get

func (p *K8sProviderExp) Get(ctx context.Context, name string, gvkRes []byte) ([]byte, error)

Get resource from the cluster

func (*K8sProviderExp) IsReachable

func (p *K8sProviderExp) IsReachable() error

IsReachable cluster reachablity test

func (*K8sProviderExp) StartClusterWatcher

func (c *K8sProviderExp) StartClusterWatcher(ctx context.Context) error

StartClusterWatcher watches for CR Same as K8s

func (*K8sProviderExp) TagResource

func (m *K8sProviderExp) TagResource(res []byte, label map[string]string) ([]byte, error)