k8s

Documentation

Index

• func VethNameForWorkload(workload string) string
• type KubeClient
  • func NewKubeClient(kc *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) 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)
• type KubeConfig

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 *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) 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 of 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.

type KubeConfig

type KubeConfig struct {
	KubeconfigFile       string `json:"kubeconfig" envconfig:"KUBECONFIG" default:""`
	Server               string `json:"server" envconfig:"K8S_API_ENDPOINT" default:""`
	ClientCertificate    string `json:"clientCertificate" envconfig:"K8S_CERT_FILE" default:""`
	ClientKey            string `json:"clientKey" envconfig:"K8S_KEY_FILE" default:""`
	CertificateAuthority string `json:"certificateAuthority" envconfig:"K8S_CA_FILE" default:""`
	Token                string `json:"token" envconfig:"K8S_API_TOKEN" default:""`
}