pod

Documentation

Index

• Constants
• Variables
• type CRI
  • func NewCRI(containerName, podName, namespace string) CRI
• type CurrentPodHandler
  • func NewCurrentPodHandler(clientSet *kubernetes.Clientset) (CurrentPodHandler, error)
• type PRI
  • func NewPRI(podName, namespace string) PRI
• type SshHandler
  • func NewSshHandler(config *rest.Config) (SshHandler, error)
• type User

Constants

const AuthorizedKeyAnnotation = "ssh.barpilot.io/publickey"

const CommandAnnotation = "ssh.barpilot.io/command"

const PrefixCommandAnnotation = "ssh.barpilot.io/prefix-command"

Variables

var ErrDestination = errors.New("can't find destination")

Types

type CRI

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

CRI is "container resource identifier"

func NewCRI

func NewCRI(containerName, podName, namespace string) CRI

type CurrentPodHandler

type CurrentPodHandler interface {
	GetCurrentPodName() string
	GetCurrentNamespace() string
	GetCurrentPod(ctx context.Context) (*corev1.Pod, error)
}

func NewCurrentPodHandler

func NewCurrentPodHandler(clientSet *kubernetes.Clientset) (CurrentPodHandler, error)

type PRI

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

PRI is "pod resource identifier"

func NewPRI

func NewPRI(podName, namespace string) PRI

type SshHandler

type SshHandler interface {
	Ssh4ContainerShellHandler(cri CRI, cmd string) func(ssh.Session)
}

func NewSshHandler

func NewSshHandler(
	config *rest.Config,
) (SshHandler, error)

type User

type User struct {
	PublicKey ssh.PublicKey
	User      string
	Pod       string
	Namespace string
}