k8s

Documentation

Index

• Variables
• type Client
  • func New(conf *Config) (*Client, error)
  • func (k *Client) AddressList(namespace string) ([]*app.Address, error)
  • func (k *Client) Autoscale(namespace string) (*app.Autoscale, error)
  • func (k *Client) CreateNamespace(a *app.App, user string) error
  • func (k *Client) CreateOrUpdateAutoscale(a *app.App) error
  • func (k *Client) CreateOrUpdateDeploy(deploySpec *spec.Deploy) error
  • func (k *Client) CreateOrUpdateDeployEnvVars(namespace, name string, evs []*app.EnvVar) error
  • func (k *Client) CreateQuota(a *app.App) error
  • func (k *Client) CreateSecret(appName, secretName string, data map[string][]byte) error
  • func (k *Client) DeleteDeployEnvVars(namespace, name string, evNames []string) error
  • func (k *Client) DeleteNamespace(namespace string) error
  • func (k *Client) DeletePod(namespace, podName string) error
  • func (k *Client) DeployAnnotation(namespace, deployName, annotation string) (string, error)
  • func (k *Client) DeployRollbackToRevision(namespace, name, revision string) error
  • func (k *Client) DeploySetReplicas(namespace, name string, replicas int32) error
  • func (k *Client) ExposeDeploy(namespace, appName, vHost string, w io.Writer) error
  • func (k *Client) HealthCheck() error
  • func (k *Client) IsAlreadyExists(err error) bool
  • func (k *Client) IsNotFound(err error) bool
  • func (k *Client) Limits(namespace, name string) (*app.Limits, error)
  • func (k *Client) NamespaceAnnotation(namespace, annotation string) (string, error)
  • func (k *Client) NamespaceLabel(namespace, label string) (string, error)
  • func (k *Client) NamespaceListByLabel(label, value string) ([]string, error)
  • func (k *Client) PodList(namespace string) ([]*app.Pod, error)
  • func (k *Client) PodLogs(namespace string, podName string, lines int64, follow bool) (io.ReadCloser, error)
  • func (k *Client) PodRun(podSpec *spec.Pod) (io.ReadCloser, <-chan int, error)
  • func (k *Client) ReplicaSetListByLabel(namespace, label, value string) ([]*deploy.ReplicaSetListItem, error)
  • func (k *Client) SetNamespaceAnnotations(namespace string, annotations map[string]string) error
  • func (k *Client) SetNamespaceLabels(namespace string, labels map[string]string) error
  • func (k *Client) Status(namespace string) (*app.Status, error)
• type Config

Variables

var (
	ErrInvalidServiceType = errors.New("Invalid service type")
	ErrNotFound           = status.Errorf(codes.NotFound, "Resource not found")
	ErrPodRunFailed       = status.Errorf(codes.Aborted, "Pod went into failed status")
	ErrPodStillRunning    = status.Errorf(codes.Unknown, "Pod still running")
)

Types

type Client

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

func New

func New(conf *Config) (*Client, error)

func (*Client) AddressList

func (k *Client) AddressList(namespace string) ([]*app.Address, error)

func (*Client) Autoscale

func (k *Client) Autoscale(namespace string) (*app.Autoscale, error)

func (*Client) CreateNamespace

func (k *Client) CreateNamespace(a *app.App, user string) error

func (*Client) CreateOrUpdateAutoscale

func (k *Client) CreateOrUpdateAutoscale(a *app.App) error

func (*Client) CreateOrUpdateDeploy

func (k *Client) CreateOrUpdateDeploy(deploySpec *spec.Deploy) error

func (*Client) CreateOrUpdateDeployEnvVars

func (k *Client) CreateOrUpdateDeployEnvVars(namespace, name string, evs []*app.EnvVar) error

func (*Client) CreateQuota

func (k *Client) CreateQuota(a *app.App) error

func (*Client) CreateSecret

func (k *Client) CreateSecret(appName, secretName string, data map[string][]byte) error

func (*Client) DeleteDeployEnvVars

func (k *Client) DeleteDeployEnvVars(namespace, name string, evNames []string) error

func (*Client) DeleteNamespace

func (k *Client) DeleteNamespace(namespace string) error

func (*Client) DeletePod

func (k *Client) DeletePod(namespace, podName string) error

func (*Client) DeployAnnotation

func (k *Client) DeployAnnotation(namespace, deployName, annotation string) (string, error)

func (*Client) DeployRollbackToRevision

func (k *Client) DeployRollbackToRevision(namespace, name, revision string) error

func (*Client) DeploySetReplicas

func (k *Client) DeploySetReplicas(namespace, name string, replicas int32) error

func (*Client) ExposeDeploy

func (k *Client) ExposeDeploy(namespace, appName, vHost string, w io.Writer) error

ExposeDeploy creates a service and/or a ingress if needed

func (*Client) HealthCheck

func (k *Client) HealthCheck() error

func (*Client) IsAlreadyExists

func (k *Client) IsAlreadyExists(err error) bool

func (*Client) IsNotFound

func (k *Client) IsNotFound(err error) bool

func (*Client) Limits

func (k *Client) Limits(namespace, name string) (*app.Limits, error)

func (*Client) NamespaceAnnotation

func (k *Client) NamespaceAnnotation(namespace, annotation string) (string, error)

func (*Client) NamespaceLabel

func (k *Client) NamespaceLabel(namespace, label string) (string, error)

func (*Client) NamespaceListByLabel

func (k *Client) NamespaceListByLabel(label, value string) ([]string, error)

func (*Client) PodList

func (k *Client) PodList(namespace string) ([]*app.Pod, error)

func (*Client) PodLogs

func (k *Client) PodLogs(namespace string, podName string, lines int64, follow bool) (io.ReadCloser, error)

func (*Client) PodRun

func (k *Client) PodRun(podSpec *spec.Pod) (io.ReadCloser, <-chan int, error)

func (*Client) ReplicaSetListByLabel

func (k *Client) ReplicaSetListByLabel(namespace, label, value string) ([]*deploy.ReplicaSetListItem, error)

func (*Client) SetNamespaceAnnotations

func (k *Client) SetNamespaceAnnotations(namespace string, annotations map[string]string) error

func (*Client) SetNamespaceLabels

func (k *Client) SetNamespaceLabels(namespace string, labels map[string]string) error

func (*Client) Status

func (k *Client) Status(namespace string) (*app.Status, error)

type Config

type Config struct {
	ConfigFile         string        `split_words:"true"`
	DefaultServiceType string        `split_words:"true" default:"LoadBalancer"`
	PodRunTimeout      time.Duration `split_words:"true" default:"30m"`
	Ingress            bool          `split_words:"true" default:"false"`
}