kubernetes

Documentation

Index

• Constants
• type DeploymentCreateOpts
• type DeploymentDetails
• type DeploymentInfo
• type KubeClient
  • func NewInClusterKubeClient() (*KubeClient, error)
  • func NewKubeClient(inCluster bool, configPath string) (*KubeClient, error)
  • func NewOutOfClusterKubeClient(configPath string) (*KubeClient, error)
  • func (client *KubeClient) AppApi() app.AppsV1Interface
  • func (client *KubeClient) Close() error
  • func (client *KubeClient) CoreApi() core.CoreV1Interface
  • func (client *KubeClient) DeploymentCreate(opts *DeploymentCreateOpts) error
  • func (client *KubeClient) DeploymentDelete(namespace string, name string) error
  • func (client *KubeClient) DeploymentDescribe(namespace string, name string) (*DeploymentDetails, error)
  • func (client *KubeClient) DeploymentList(namespace string, namePrefix string, labelSelector string) ([]DeploymentInfo, error)
  • func (client *KubeClient) NamespaceApply(name string) error
  • func (client *KubeClient) NamespaceDelete(name string) error
  • func (client *KubeClient) PodDescribe(deployment *appsv1.Deployment) (*PodInfo, error)
  • func (client *KubeClient) PodExec(opts *PodExecOpts) error
  • func (client *KubeClient) PodPortForward(opts *PodPortForwardOpts) error
  • func (client *KubeClient) RestApi() *rest.Config
  • func (client *KubeClient) ServiceCreate(namespace string, spec *corev1.Service) error
  • func (client *KubeClient) ServiceDelete(namespace string, name string) error
  • func (client *KubeClient) ServiceDescribe(namespace string, name string) (*ServiceInfo, error)
• type KubeResource
• type PodExecOpts
• type PodInfo
• type PodPortForwardOpts
• type ServiceInfo
• type ServicePort

Constants

const (
	SingleReplica      = 1
	LabelKubeName      = "app.kubernetes.io/name"
	LabelKubeInstance  = "app.kubernetes.io/instance"
	LabelKubeVersion   = "app.kubernetes.io/version"
	LabelKubeManagedBy = "app.kubernetes.io/managed-by"
)

Types

type DeploymentCreateOpts

type DeploymentCreateOpts struct {
	Namespace             string
	Spec                  *appsv1.Deployment
	OnStatusEventCallback func(event string)
}

type DeploymentDetails

type DeploymentDetails struct {
	Info        *DeploymentInfo
	Created     time.Time
	Annotations map[string]string
}

type DeploymentInfo

type DeploymentInfo struct {
	Namespace string
	Name      string
	Healthy   bool
	PodInfo   *PodInfo
}

type KubeClient

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

func NewInClusterKubeClient

func NewInClusterKubeClient() (*KubeClient, error)

func NewKubeClient

func NewKubeClient(inCluster bool, configPath string) (*KubeClient, error)

func NewOutOfClusterKubeClient

func NewOutOfClusterKubeClient(configPath string) (*KubeClient, error)

func (*KubeClient) AppApi

func (client *KubeClient) AppApi() app.AppsV1Interface

func (*KubeClient) Close

func (client *KubeClient) Close() error

func (*KubeClient) CoreApi

func (client *KubeClient) CoreApi() core.CoreV1Interface

func (*KubeClient) DeploymentCreate

func (client *KubeClient) DeploymentCreate(opts *DeploymentCreateOpts) error

func (*KubeClient) DeploymentDelete

func (client *KubeClient) DeploymentDelete(namespace string, name string) error

func (*KubeClient) DeploymentDescribe

func (client *KubeClient) DeploymentDescribe(namespace string, name string) (*DeploymentDetails, error)

func (*KubeClient) DeploymentList

func (client *KubeClient) DeploymentList(namespace string, namePrefix string, labelSelector string) ([]DeploymentInfo, error)

func (*KubeClient) NamespaceApply

func (client *KubeClient) NamespaceApply(name string) error

func (*KubeClient) NamespaceDelete

func (client *KubeClient) NamespaceDelete(name string) error

func (*KubeClient) PodDescribe

func (client *KubeClient) PodDescribe(deployment *appsv1.Deployment) (*PodInfo, error)

func (*KubeClient) PodExec

func (client *KubeClient) PodExec(opts *PodExecOpts) error

func (*KubeClient) PodPortForward

func (client *KubeClient) PodPortForward(opts *PodPortForwardOpts) error

func (*KubeClient) RestApi

func (client *KubeClient) RestApi() *rest.Config

func (*KubeClient) ServiceCreate

func (client *KubeClient) ServiceCreate(namespace string, spec *corev1.Service) error

func (*KubeClient) ServiceDelete

func (client *KubeClient) ServiceDelete(namespace string, name string) error

func (*KubeClient) ServiceDescribe

func (client *KubeClient) ServiceDescribe(namespace string, name string) (*ServiceInfo, error)

type KubeResource

type KubeResource struct {
	Memory string
	Cpu    string
}

type PodExecOpts

type PodExecOpts struct {
	Namespace      string
	PodName        string
	PodId          string
	Shell          string
	InStream       io.ReadCloser
	OutStream      io.Writer
	ErrStream      io.Writer
	IsTty          bool
	OnExecCallback func()
}

type PodInfo

type PodInfo struct {
	Namespace     string
	PodName       string
	ContainerName string
	Env           map[string]string
}

type PodPortForwardOpts

type PodPortForwardOpts struct {
	Namespace             string
	PodId                 string
	Ports                 []string // format "LOCAL:REMOTE"
	IsWait                bool
	OnTunnelStartCallback func()
	OnTunnelErrorCallback func(error)
}

type ServiceInfo

type ServiceInfo struct {
	Namespace string
	Name      string
	Ports     []ServicePort
}

type ServicePort

type ServicePort struct {
	Name string
	Port string
}