k8s

Nov 24, 2022

Changes in this version

+ const DaemonSetKind

+ const DeploymentKind

+ const PortForwardMethod

+ const StatefulSetKind

+ type KubernetesClient struct

+ func NewKubernetesClient(kubeConfigPath string) (*KubernetesClient, error)

+ func (k *KubernetesClient) GetDaemonSet(namespace, name string) (*appsV1.DaemonSet, error)

+ func (k *KubernetesClient) GetDeployment(namespace, deploymentName string) (*appsV1.Deployment, error)

+ func (k *KubernetesClient) GetPod(namespace, name string) (*coreV1.Pod, error)

+ func (k *KubernetesClient) GetPortForwardSubresourceURL(pod *coreV1.Pod) *url.URL

+ func (k *KubernetesClient) GetStatefulSet(namespace, name string) (*appsV1.StatefulSet, error)

+ func (k *KubernetesClient) ListPods(namespace string, listOptions apiMetaV1.ListOptions) (*coreV1.PodList, error)

+ func (k *KubernetesClient) PortForward(pod *coreV1.Pod, portForward *PortForward, out, errOut io.Writer) (*portforward.PortForwarder, error)

+ func (k *KubernetesClient) WorkflowPodsList(namespace, kind, name string) (*coreV1.PodList, error)

+ type PortForward struct

+ Interface string

+ LocalPort int

+ ReadyChannel chan struct{}

+ RemotePort int

+ StopChannel chan struct{}

+ func NewPortForward(iface string, localPort int, remotePort int) *PortForward

+ func (p *PortForward) Close()