manager

Documentation

Index

• type EmephemeralContainerManager
  • func NewEmephemeralContainerManager(podGetter typedcorev1.PodsGetter) *EmephemeralContainerManager
  • func (e *EmephemeralContainerManager) ContainerName() string
  • func (e *EmephemeralContainerManager) EnsurePodManaged(ctx context.Context, ns, pod, dbgimg, target string, ...) (*corev1.Pod, error)
  • func (e *EmephemeralContainerManager) ManagerPort(ctx context.Context, podclient typedcorev1.PodInterface, podObj *corev1.Pod) (uint16, error)
• type Manager
  • func NewManager(ctx context.Context, RESTConfig *rest.Config, clientset *kubernetes.Clientset, ...) (Manager, error)

Types

type EmephemeralContainerManager

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

func NewEmephemeralContainerManager

func NewEmephemeralContainerManager(podGetter typedcorev1.PodsGetter) *EmephemeralContainerManager

func (*EmephemeralContainerManager) ContainerName

func (e *EmephemeralContainerManager) ContainerName() string

func (*EmephemeralContainerManager) EnsurePodManaged

func (e *EmephemeralContainerManager) EnsurePodManaged(ctx context.Context, ns, pod, dbgimg, target string, pullPolicy corev1.PullPolicy) (*corev1.Pod, error)

Create or connect to an ephemeral manager container in a pod

func (*EmephemeralContainerManager) ManagerPort

func (e *EmephemeralContainerManager) ManagerPort(ctx context.Context, podclient typedcorev1.PodInterface, podObj *corev1.Pod) (uint16, error)

type Manager

type Manager interface {
	GetListeneningPorts(ctx context.Context) ([]uint16, error)
	RedirectIncomingTraffic(ctx context.Context, podPort, localPort uint16) error
	RedirectOutgoingTraffic(ctx context.Context, podPort, localPort uint16) error
}

func NewManager

func NewManager(
	ctx context.Context,
	RESTConfig *rest.Config,
	clientset *kubernetes.Clientset,
	Out io.Writer,
	ErrOut io.Writer, podname, podnamespace, container string) (Manager, error)