util

Documentation

Overview

SPDX-License-Identifier: CC0-1.0 https://creativecommons.org/publicdomain/zero/1.0/

SPDX-License-Identifier: CC0-1.0 https://creativecommons.org/publicdomain/zero/1.0/

Index

• func GetClientset() (*kubernetes.Clientset, error)
• func GetNetns(ctx context.Context, pod, ns string) (string, error)
• func GetPOD(ctx context.Context, ns, pod string) (*k8s.Pod, error)
• func GetPodSandbox(ctx context.Context, conn *RuntimeConnection, pod, ns string) (*cri.PodSandbox, error)
• type RuntimeConnection
  • func NewRuntimeConnection(ctx context.Context, uri string) (*RuntimeConnection, error)
  • func (conn *RuntimeConnection) Close() error

Functions

func GetClientset

func GetClientset() (*kubernetes.Clientset, error)

func GetNetns

func GetNetns(ctx context.Context, pod, ns string) (string, error)

GetNetns Returns the Linux netns path for a K8s namespace/pod

func GetPOD

func GetPOD(ctx context.Context, ns, pod string) (*k8s.Pod, error)

func GetPodSandbox

func GetPodSandbox(
	ctx context.Context, conn *RuntimeConnection, pod, ns string) (
	*cri.PodSandbox, error)

GetPodSandbox Returns the runtime PodSandbox for a K8s namespace/pod

Types

type RuntimeConnection

type RuntimeConnection struct {
	io.Closer
	// contains filtered or unexported fields
}

func NewRuntimeConnection

func NewRuntimeConnection(
	ctx context.Context, uri string) (*RuntimeConnection, error)

NewRuntimeConnection Create a connection to the runtime The socket is searched in order from;

• The passed uri
• $CONTAINER_RUNTIME_ENDPOINT
• unix:///run/crio/crio.sock
• unix:///run/containerd/containerd.sock
• unix:///var/run/crio/crio.sock

func (*RuntimeConnection) Close

func (conn *RuntimeConnection) Close() error