kubernetes

Documentation

Index

• func ConfigPath() string
• func IsAlreadyExists(err error) bool
• func IsConflict(err error) bool
• func IsNotFound(err error) bool
• type Client
  • func New() (Client, error)
  • func NewFromBytes(kubeconfig []byte) (Client, error)
  • func NewFromConfig(config *rest.Config, namespace string) (Client, error)
  • func NewFromFile(kubeconfig string) (Client, error)
• type Credentials

Functions

func ConfigPath

func ConfigPath() string

func IsAlreadyExists

func IsAlreadyExists(err error) bool

func IsConflict

func IsConflict(err error) bool

func IsNotFound

func IsNotFound(err error) bool

Types

type Client

type Client interface {
	kubernetes.Interface

	Config() *rest.Config

	Namespace() string
	Credentials() (*Credentials, error)

	PodCIDR(ctx context.Context) (string, error)
	ServiceCIDR(ctx context.Context) (string, error)

	ServicePods(ctx context.Context, namespace, name string) ([]corev1.Pod, error)
	ServicePod(ctx context.Context, namespace, name string) (*corev1.Pod, error)
	ServiceAddress(ctx context.Context, namespace, name string) (string, error)
	ServicePortForward(ctx context.Context, namespace, name, address string, ports map[int]int, readyChan chan struct{}) error

	PodExec(ctx context.Context, namespace, name, container string, command []string, tty bool, stdin io.Reader, stdout, stderr io.Writer) error
	PodAttach(ctx context.Context, namespace, name, container string, tty bool, stdin io.Reader, stdout, stderr io.Writer) error
	PodLogs(ctx context.Context, namespace, name, container string, out io.Writer, follow bool) error
	PodPortForward(ctx context.Context, namespace, name, address string, ports map[int]int, readyChan chan struct{}) error

	WaitForPod(ctx context.Context, namespace, name string) (*corev1.Pod, error)
	WaitForService(ctx context.Context, namespace, name string) (*corev1.Service, error)

	ReadFileInPod(ctx context.Context, namespace, name, container, path string, data io.Writer) error
	CreateFileInPod(ctx context.Context, namespace, name, container, path string, data io.Reader) error
}

func New

func New() (Client, error)

func NewFromBytes

func NewFromBytes(kubeconfig []byte) (Client, error)

func NewFromConfig

func NewFromConfig(config *rest.Config, namespace string) (Client, error)

func NewFromFile

func NewFromFile(kubeconfig string) (Client, error)

type Credentials

type Credentials struct {
	Host string
	Port string

	CAData  []byte
	APIPath string

	Token string
}