kubernetes

Documentation

Overview

Package kubernetes implements the connector that can pull data from the Kubernetes control plane.

Index

• Variables
• func CurrentContext() (string, error)
• func GetContexts() ([]*rpc.Context, error)
• type Runtime
  • func New() (*Runtime, error)
  • func (r *Runtime) AddContext(id string, data []byte) error
  • func (r *Runtime) Create(ctx context.Context, resource cosiresource.Resource, ...) error
  • func (r *Runtime) Delete(ctx context.Context, setters ...runtime.QueryOption) error
  • func (r *Runtime) Get(ctx context.Context, setters ...runtime.QueryOption) (interface{}, error)
  • func (r *Runtime) GetCapiProxy(ctx context.Context, context *common.Context) (*capi.Proxy, error)
  • func (r *Runtime) GetContext(ctx context.Context, context *common.Context, cluster *common.Cluster) ([]byte, error)
  • func (r *Runtime) GetKubeconfig(ctx context.Context, context *common.Context) (*rest.Config, error)
  • func (r *Runtime) List(ctx context.Context, setters ...runtime.QueryOption) ([]interface{}, error)
  • func (r *Runtime) Update(ctx context.Context, resource cosiresource.Resource, ...) error
  • func (r *Runtime) Watch(ctx context.Context, request *message.WatchSpec, events chan runtime.Event) error
• type Watch

Variables

var Name = common.Runtime_Kubernetes.String()

Name kubernetes runtime string id.

Functions

func CurrentContext

func CurrentContext() (string, error)

CurrentContext returns current local context.

func GetContexts

func GetContexts() ([]*rpc.Context, error)

GetContexts returns all locally defined context names.

Types

type Runtime

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

Runtime implements runtime.Runtime.

func New

func New() (*Runtime, error)

New creates new Runtime.

func (*Runtime) AddContext

func (r *Runtime) AddContext(id string, data []byte) error

AddContext implements runtime.Runtime.

func (*Runtime) Create

func (r *Runtime) Create(ctx context.Context, resource cosiresource.Resource, setters ...runtime.QueryOption) error

Create implements runtime.Runtime.

func (*Runtime) Delete

func (r *Runtime) Delete(ctx context.Context, setters ...runtime.QueryOption) error

Delete implements runtime.Runtime.

func (*Runtime) Get

func (r *Runtime) Get(ctx context.Context, setters ...runtime.QueryOption) (interface{}, error)

Get implements runtime.Runtime.

func (*Runtime) GetCapiProxy

func (r *Runtime) GetCapiProxy(ctx context.Context, context *common.Context) (*capi.Proxy, error)

GetCapiProxy returns capi proxy object.

func (*Runtime) GetContext

func (r *Runtime) GetContext(ctx context.Context, context *common.Context, cluster *common.Cluster) ([]byte, error)

GetContext implements runtime.Runtime.

func (*Runtime) GetKubeconfig

func (r *Runtime) GetKubeconfig(ctx context.Context, context *common.Context) (*rest.Config, error)

GetKubeconfig returns kubeconfig.

func (*Runtime) List

func (r *Runtime) List(ctx context.Context, setters ...runtime.QueryOption) ([]interface{}, error)

List implements runtime.Runtime.

func (*Runtime) Update

func (r *Runtime) Update(ctx context.Context, resource cosiresource.Resource, setters ...runtime.QueryOption) error

Update implements runtime.Runtime.

func (*Runtime) Watch

func (r *Runtime) Watch(ctx context.Context, request *message.WatchSpec, events chan runtime.Event) error

Watch creates new kubernetes watch.

type Watch

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

Watch watches kubernetes resources.