kubernetes

Documentation

Index

• func NewKubeconfig(server string) api.Config
• func Run(conn db.Conn, dk docker.Client)
• type SecretClient
  • func NewSecretClient() (SecretClient, error)

Functions

func NewKubeconfig

func NewKubeconfig(server string) api.Config

NewKubeconfig returns a Kubeconfig setup to connect to the given server, and using the Kelda authentication certificates.

func Run

func Run(conn db.Conn, dk docker.Client)

Run converts the containers specified by the user into deployments in the Kubernetes cluster. It also syncs the status of the deployment into the database. The module is implemented as several goroutines. One goroutine creates the ConfigMap and deployment objects for Kubernetes to deploy. Another goroutine tags the Kubernetes workers with metadata to be used by placement rules. The final goroutine syncs the status of the deployment into the database.

Types

type SecretClient

type SecretClient interface {
	// Exists returns whether a secret value exists for the given secret name.
	Exists(name string) bool

	// Get returns the secret value associated with the given name.
	Get(name string) (string, error)

	// Set associates the given name with the secret value.
	Set(name, val string) error
}

SecretClient provides an interface for writing and reading secrets from Kubernetes.

func NewSecretClient

func NewSecretClient() (SecretClient, error)

NewSecretClient returns a SecretClient connected to the local Kubernetes API server.