k8s

Documentation

Index

• Variables
• type Client
  • func New(conf *Config) (Client, error)
• type Config
• type Deploy
• type Error
• type Hpa
• type Namespace
• type Pod
• type Quota
• type Secret
• type Service
• type TeresaHealthCheck

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 interface {
	Namespace
	Pod
	Quota
	Secret
	Hpa
	Deploy
	Error
	Service
	TeresaHealthCheck
}

func New

func New(conf *Config) (Client, 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"`
}

type Deploy

type Deploy interface {
	DeploySetReplicas(namespace, name string, replicas int32) error
	CreateOrUpdateDeployEnvVars(namespace, name string, evs []*app.EnvVar) error
	DeleteDeployEnvVars(namespace, name string, evNames []string) error
	CreateOrUpdateDeploy(deploySpec *deploy.DeploySpec) error
	ExposeDeploy(namespace, name, vHost string, w io.Writer) error
	ReplicaSetListByLabel(namespace, label, value string) ([]*deploy.ReplicaSetListItem, error)
	DeployRollbackToRevision(namespace, name, revision string) error
}

type Error

type Error interface {
	IsNotFound(err error) bool
	IsAlreadyExists(err error) bool
}

type Hpa

type Hpa interface {
	Autoscale(namespace string) (*app.Autoscale, error)
	CreateOrUpdateAutoscale(a *app.App) error
}

type Namespace

type Namespace interface {
	NamespaceAnnotation(namespace, annotation string) (string, error)
	NamespaceLabel(namespace, label string) (string, error)
	CreateNamespace(a *app.App, userEmail string) error
	NamespaceListByLabel(label, value string) ([]string, error)
	DeleteNamespace(namespace string) error
	SetNamespaceLabels(namespace string, labels map[string]string) error
	SetNamespaceAnnotations(namespace string, annotations map[string]string) error
	Status(namespace string) (*app.Status, error)
}

type Pod

type Pod interface {
	PodList(namespace string) ([]*app.Pod, error)
	PodLogs(namespace, podName string, lines int64, follow bool) (io.ReadCloser, error)
	DeletePod(namespace, podName string) error
	PodRun(podSpec *deploy.PodSpec) (io.ReadCloser, <-chan int, error)
}

type Quota

type Quota interface {
	CreateQuota(a *app.App) error
	Limits(namespace, name string) (*app.Limits, error)
}

type Secret

type Secret interface {
	CreateSecret(appName, secretName string, data map[string][]byte) error
}

type Service

type Service interface {
	AddressList(namespace string) ([]*app.Address, error)
}

type TeresaHealthCheck

type TeresaHealthCheck interface {
	HealthCheck() error
}