k8s

Documentation

Index

• type KubeClient
  • func NewKubeClient(kc *capi.KubeConfig) (*KubeClient, error)
  • func (c *KubeClient) Apply(d *model.KVPair) (*model.KVPair, error)
  • func (c *KubeClient) Get(k model.Key) (*model.KVPair, error)
  • func (c *KubeClient) IsKDD() bool
  • func (c *KubeClient) List(l model.ListInterface) ([]*model.KVPair, error)
  • func (c *KubeClient) Update(d *model.KVPair) (*model.KVPair, error)

Types

type KubeClient

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

func NewKubeClient

func NewKubeClient(kc *capi.KubeConfig) (*KubeClient, error)

func (*KubeClient) Apply

func (c *KubeClient) Apply(d *model.KVPair) (*model.KVPair, error)

Set an existing entry in the datastore. This ignores whether an entry already exists.

func (*KubeClient) Get

func (c *KubeClient) Get(k model.Key) (*model.KVPair, error)

Get an entry from the datastore. This errors if the entry does not exist.

func (*KubeClient) IsKDD

func (c *KubeClient) IsKDD() bool

func (*KubeClient) List

func (c *KubeClient) List(l model.ListInterface) ([]*model.KVPair, error)

List entries in the datastore. This may return an empty list if there are no entries matching the request in the ListInterface.

func (*KubeClient) Update

func (c *KubeClient) Update(d *model.KVPair) (*model.KVPair, error)

Update an existing entry in the datastore. This errors if the entry does not exist. (Not implemented for KDD.)