k8s

Documentation

Index

• func NewKubeClient(ca *apiconfig.CalicoAPIConfigSpec) (api.Client, error)
• type KubeClient
  • func (c *KubeClient) Apply(ctx context.Context, kvp *model.KVPair) (*model.KVPair, error)
  • func (c *KubeClient) Clean() error
  • func (c *KubeClient) Create(ctx context.Context, d *model.KVPair) (*model.KVPair, error)
  • func (c *KubeClient) Delete(ctx context.Context, k model.Key, revision string) (*model.KVPair, error)
  • func (c *KubeClient) EnsureInitialized() error
  • func (c *KubeClient) Get(ctx context.Context, k model.Key, revision string) (*model.KVPair, error)
  • func (c *KubeClient) GetResourceClientFromResourceKind(kind string) resources.K8sResourceClient
  • func (c *KubeClient) List(ctx context.Context, l model.ListInterface, revision string) (*model.KVPairList, error)
  • func (c *KubeClient) Update(ctx context.Context, d *model.KVPair) (*model.KVPair, error)
  • func (c *KubeClient) Watch(ctx context.Context, l model.ListInterface, revision string) (api.WatchInterface, error)

Functions

func NewKubeClient

func NewKubeClient(ca *apiconfig.CalicoAPIConfigSpec) (api.Client, error)

Types

type KubeClient

type KubeClient struct {
	// Main Kubernetes clients.
	ClientSet *kubernetes.Clientset
	// contains filtered or unexported fields
}

func (*KubeClient) Apply

func (c *KubeClient) Apply(ctx context.Context, kvp *model.KVPair) (*model.KVPair, error)

Set an existing entry in the datastore. This ignores whether an entry already exists. This is not exposed in the main client - but we keep here for the backend API.

func (*KubeClient) Clean

func (c *KubeClient) Clean() error

Remove Calico-creatable data from the datastore. This is purely used for the test framework.

func (*KubeClient) Create

func (c *KubeClient) Create(ctx context.Context, d *model.KVPair) (*model.KVPair, error)

Create an entry in the datastore. This errors if the entry already exists.

func (*KubeClient) Delete

func (c *KubeClient) Delete(ctx context.Context, k model.Key, revision string) (*model.KVPair, error)

Delete an entry in the datastore. This is a no-op when using the k8s backend.

func (*KubeClient) EnsureInitialized

func (c *KubeClient) EnsureInitialized() error

EnsureInitialized checks that the necessary custom resource definitions exist in the backend. This usually passes when using etcd as a backend but can often fail when using KDD as it relies on various custom resources existing. To ensure the datastore is initialized, this function checks that a known custom resource is defined: GlobalFelixConfig. It accomplishes this by trying to set the ClusterType (an instance of GlobalFelixConfig).

func (*KubeClient) Get

func (c *KubeClient) Get(ctx context.Context, k model.Key, revision string) (*model.KVPair, error)

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

func (*KubeClient) GetResourceClientFromResourceKind

func (c *KubeClient) GetResourceClientFromResourceKind(kind string) resources.K8sResourceClient

getResourceClientFromKey returns the appropriate resource client for the v3 resource kind.

func (*KubeClient) List

func (c *KubeClient) List(ctx context.Context, l model.ListInterface, revision string) (*model.KVPairList, 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(ctx context.Context, d *model.KVPair) (*model.KVPair, error)

Update an existing entry in the datastore. This errors if the entry does not exist.

func (*KubeClient) Watch

func (c *KubeClient) Watch(ctx context.Context, l model.ListInterface, revision string) (api.WatchInterface, error)

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