k8s

Documentation

Index

• Constants
• func VethNameForWorkload(workload string) string
• type KubeClient
  • func NewKubeClient(kc *capi.KubeConfig) (*KubeClient, error)
  • func (c *KubeClient) Apply(d *model.KVPair) (*model.KVPair, error)
  • func (c *KubeClient) Create(d *model.KVPair) (*model.KVPair, error)
  • func (c *KubeClient) Delete(d *model.KVPair) error
  • func (c *KubeClient) EnsureCalicoNodeInitialized(node string) error
  • func (c *KubeClient) EnsureInitialized() error
  • func (c *KubeClient) Get(k model.Key) (*model.KVPair, error)
  • func (c *KubeClient) List(l model.ListInterface) ([]*model.KVPair, error)
  • func (c *KubeClient) Syncer(callbacks api.SyncerCallbacks) api.Syncer
  • func (c *KubeClient) Update(d *model.KVPair) (*model.KVPair, error)

Constants

const (
	KEY_NS  = "Namespace"
	KEY_PO  = "Pod"
	KEY_NP  = "NetworkPolicy"
	KEY_GNP = "GlobalNetworkPolicy"
	KEY_GC  = "GlobalFelixConfig"
	KEY_HC  = "HostConfig"
	KEY_IP  = "IPPool"
	KEY_NO  = "Node"
	KEY_RS  = "CalicoReadyState"
)

Keys used to identify various bits of state stored on a per-resource basis.

Functions

func VethNameForWorkload

func VethNameForWorkload(workload string) string

VethNameForWorkload returns a deterministic veth name for the given Kubernetes workload.

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) Create

func (c *KubeClient) Create(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(d *model.KVPair) error

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

func (*KubeClient) EnsureCalicoNodeInitialized

func (c *KubeClient) EnsureCalicoNodeInitialized(node string) error

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(k model.Key) (*model.KVPair, error)

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

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) Syncer

func (c *KubeClient) Syncer(callbacks api.SyncerCallbacks) api.Syncer

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.