k8s

Mar 22, 2023

Changes in this version

+ func CheckEphemeralContainerSupport(v VersionGetter) error

+ func CheckPodsContext(pods []v1.Pod) error

type AgentOpt

+ func WithAgentCaptureFilter(n string) AgentOpt

type AgentOpts

+ Filter string

+ type VersionGetter interface

+ ServerVersion func() (*version.Info, error)

Mar 7, 2023

Changes in this version

type KubeEphemeralHandler

+ List func(ctx context.Context, opts metav1.ListOptions) (*v1.PodList, error)

Mar 6, 2023

Changes in this version

+ func GetKubeForwarder(r *rest.Config, path string, rch, sch chan struct{}, proxyport int32) (*portforward.PortForwarder, int, error)

+ func PortForward(forwarder Forwarder, readych chan struct{}, timeout time.Duration) error

+ func SelectPods(pods []string, all bool, h PodLister) ([]v1.Pod, error)

+ func SetupEphemeralContainers(pods []v1.Pod, h KubeEphemeralHandler, opts AgentOpts) error

+ func SetupProxy(h KubeProxyHandler, opts ProxyOpts) (string, error)

+ func TearDownProxy(id string, h KubeProxyHandler) error

+ type AgentOpt func(o AgentOpts) AgentOpts

+ func WithAgentCaptureTimeOut(n time.Duration) AgentOpt

+ func WithAgentDevice(n string) AgentOpt

+ func WithAgentPromiscuous(n bool) AgentOpt

+ func WithAgentSetupTimeOut(n time.Duration) AgentOpt

+ func WithAgentSnapLen(n int32) AgentOpt

+ func WithAgentUUID(u string) AgentOpt

+ type AgentOpts struct

+ Device string

+ Promiscuous bool

+ SetupTimeout time.Duration

+ SnapshotLen int32

+ TargetIP string

+ TargetPort int

+ Timeout time.Duration

+ UUID string

+ func LoadAgentOpts(os ...AgentOpt) AgentOpts

+ func (a AgentOpts) WithTargetIP(s string) AgentOpts

+ func (a AgentOpts) WithTargetPort(p int) AgentOpts

+ type Forwarder interface

+ ForwardPorts func() error

+ type KubeClient struct

+ Clientset *kubernetes.Clientset

+ Namespace string

+ RestConf *rest.Config

+ func GetClient(namespace string) (*KubeClient, error)

+ type KubeEphemeralHandler interface

+ Get func(ctx context.Context, name string, opts metav1.GetOptions) (*v1.Pod, error)

+ UpdateEphemeralContainers func(ctx context.Context, podName string, pod *v1.Pod, opts metav1.UpdateOptions) (*v1.Pod, error)

+ type KubeProxyHandler interface

+ Create func(ctx context.Context, pod *v1.Pod, opts metav1.CreateOptions) (*v1.Pod, error)

+ Delete func(ctx context.Context, name string, opts metav1.DeleteOptions) error

+ Get func(ctx context.Context, name string, opts metav1.GetOptions) (*v1.Pod, error)

+ type PodLister interface

+ List func(ctx context.Context, opts metav1.ListOptions) (*v1.PodList, error)

+ type ProxyOpt func(o ProxyOpts) ProxyOpts

+ func WithProxyServerPort(u int32) ProxyOpt

+ func WithProxySetupTimeout(u time.Duration) ProxyOpt

+ func WithProxyUUID(u string) ProxyOpt

+ type ProxyOpts struct

+ ServerPort int32

+ SetupTimeout time.Duration

+ UUID string

+ func LoadProxyOpts(os ...ProxyOpt) ProxyOpts