kubernetes

Oct 24, 2023

Changes in this version

type KubeClient

+ func (client *KubeClient) PodLogs(opts *PodLogsOpts) error

type PodLogsOpts

+ OutStream io.Writer

Oct 22, 2023

Changes in this version

type PodExecOpts

+ ContainerName string

type PodLogsOpts

+ ContainerName string

type PodPortForwardOpts

+ PodName string

Oct 18, 2023

Changes in this version

+ func BuildJob(opts *JobOpts) *batchv1.Job

+ func ObjectToYaml(object runtime.Object) string

+ func YamlToDeployment(data string) *appsv1.Deployment

+ type CopyPodOpts struct

+ ContainerName string

+ LocalPath string

+ Namespace string

+ PodName string

+ RemotePath string

+ type JobCreateOpts struct

+ CaptureInterrupt bool

+ Namespace string

+ OnContainerInterruptCallback func(name string)

+ OnStatusEventCallback func(event string)

+ Spec *batchv1.Job

+ type JobOpts struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ Namespace string

+ PodInfo *PodInfo

type KubeClient

+ func (client *KubeClient) BatchApi() batch.BatchV1Interface

+ func (client *KubeClient) CopyToPod(opts *CopyPodOpts) error

+ func (client *KubeClient) JobCreate(opts *JobCreateOpts) error

+ func (client *KubeClient) JobDelete(namespace string, name string) error

+ func (client *KubeClient) JobDescribe(namespace string, name string) (*PodInfo, error)

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

+ func (client *KubeClient) PodExecCommand(opts *PodExecOpts) error

+ func (client *KubeClient) PodExecShell(opts *PodExecOpts) error

+ func (client *KubeClient) PodLogsStd(opts *PodLogsOpts) error

+ func (client *KubeClient) PodLogsTee(opts *PodLogsOpts, logFileName string) error

+ func (client *KubeClient) SecretCreate(namespace string, spec *corev1.Secret) error

+ func (client *KubeClient) SecretDelete(namespace string, name string) (bool, error)

type PodExecOpts

+ Commands []string

type PodInfo

+ Arguments []string

+ type PodLogsOpts struct

+ Namespace string

+ PodId string

+ PodName string

Sep 10, 2023

Changes in this version

+ const SidecarPrefix

Aug 17, 2023

Changes in this version

+ func BuildLabels(name, instance, version string, extra map[string]string) map[string]string

+ func BuildResources(opts *ResourcesOpts) (*appsv1.Deployment, *corev1.Service, error)

+ func NewInClusterKubeConfig() (*rest.Config, *kubernetes.Clientset, error)

+ func NewOutOfClusterKubeConfig(configPath string) (*rest.Config, *kubernetes.Clientset, error)

+ func NormalizeKubeConfig(configPath string) string

+ type KubeEnv struct

+ Key string

+ Value string

+ type KubePort struct

+ Name string

+ Port string

type PodInfo

+ ImageName string

+ Resource *KubeResource

+ type ResourcesOpts struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ Namespace string

+ PodInfo *PodInfo

+ Ports []KubePort

Jul 31, 2023

Changes in this version

+ const LabelKubeInstance

+ const LabelKubeManagedBy

+ const LabelKubeName

+ const LabelKubeVersion

+ const SingleReplica

+ type DeploymentDetails struct

+ Annotations map[string]string

+ Created time.Time

+ Info *DeploymentInfo

type DeploymentInfo

+ Healthy bool

+ Name string

type KubeClient

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

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

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

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

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

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

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

type PodInfo

+ ContainerName string

+ Env map[string]string

+ Namespace string

+ PodName string

type PodPortForwardOpts

+ IsWait bool

+ OnTunnelStartCallback func()

+ type ServiceInfo struct

+ Name string

+ Namespace string

+ Ports []ServicePort

+ type ServicePort struct

+ Name string

+ Port string

Jun 23, 2023

Changes in this version

+ type DeploymentCreateOpts struct

+ Namespace string

+ OnStatusEventCallback func(event string)

+ Spec *appsv1.Deployment

+ type DeploymentInfo struct

+ DeploymentName string

+ Namespace string

+ PodInfo *PodInfo

+ type KubeClient struct

+ func NewInClusterKubeClient() (*KubeClient, error)

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

+ func (client *KubeClient) Close() error

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

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

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

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

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

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

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

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

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

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

+ type KubeClientConfig struct

+ ConfigPath string

+ Namespace string

+ Resource *KubeResource

+ type KubeResource struct

+ Cpu string

+ Memory string

+ type PodExecOpts struct

+ ErrStream io.Writer

+ InStream io.ReadCloser

+ IsTty bool

+ Namespace string

+ OnExecCallback func()

+ OutStream io.Writer

+ PodId string

+ PodName string

+ Shell string

+ type PodInfo struct

+ Id string

+ Name string

+ type PodPortForwardOpts struct

+ Namespace string

+ OnTunnelErrorCallback func(error)

+ PodId string

+ Ports []string