kube

package

v0.0.0-...-64e8fac Latest Latest Go to latest Published: Apr 2, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/horizoncd/horizon

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BuildClient(kubeconfig string) (*rest.Config, kubernetes.Interface, error)
func DeletePods(ctx context.Context, kubeClientset kubernetes.Interface, namespace string, ...) (err error)
func Exec(ctx context.Context, c ContainerRef, command []string, ...) (stdout string, stderr string, err error)
func GetDeploymentList(ctx context.Context, kubeClientset kubernetes.Interface, ...) (_ []appsv1.Deployment, err error)
func GetEvents(ctx context.Context, kubeClientset kubernetes.Interface, namespace string) (_ map[string][]*v1.Event, err error)
func GetPod(ctx context.Context, kubeClientset kubernetes.Interface, ...) (_ *v1.Pod, err error)
func GetPodEvents(ctx context.Context, kubeClientset kubernetes.Interface, namespace, pod string) (_ []v1.Event, err error)
func GetPods(ctx context.Context, kubeClientset kubernetes.Interface, ...) (_ []v1.Pod, err error)
func GetReplicaSets(ctx context.Context, kubeClientset kubernetes.Interface, ...) (_ []appsv1.ReplicaSet, err error)
type Client
- func BuildClientFromContent(kubeconfigContent string) (*rest.Config, *Client, error)
type ContainerRef

Constants ¶

View Source

const (
	EnvK8sClientQPS   = "HORIZON_K8S_CLIENT_QPS"
	EnvK8sClientBurst = "HORIZON_K8S_CLIENT_BURST"
)

View Source

const DefaultEventsLimit = 100

Variables ¶

View Source

var (
	K8sClientConfigQPS   float32 = 50
	K8sClientConfigBurst         = 100
)

Functions ¶

func BuildClient ¶

func BuildClient(kubeconfig string) (*rest.Config, kubernetes.Interface, error)

func DeletePods ¶

func DeletePods(ctx context.Context, kubeClientset kubernetes.Interface, namespace string, pod string) (err error)

func Exec ¶

func Exec(ctx context.Context, c ContainerRef,
	command []string, executor exec.RemoteExecutor) (stdout string, stderr string, err error)

func GetDeploymentList ¶

func GetDeploymentList(ctx context.Context, kubeClientset kubernetes.Interface,
	namespace, labelSelector string) (_ []appsv1.Deployment, err error)

func GetEvents ¶

func GetEvents(ctx context.Context, kubeClientset kubernetes.Interface,
	namespace string) (_ map[string][]*v1.Event, err error)

GetEvents Returns a map. key is the basic information of Pod, name-uid-namespace

func GetPod ¶

func GetPod(ctx context.Context, kubeClientset kubernetes.Interface, namespace, podName string) (_ *v1.Pod, err error)

func GetPodEvents ¶

func GetPodEvents(ctx context.Context, kubeClientset kubernetes.Interface, namespace, pod string) (_ []v1.Event,
	err error)

GetPodEvents returns event list of a pod, notice that it will return events from oldest to latest by DefaultEventsLimit

func GetPods ¶

func GetPods(ctx context.Context, kubeClientset kubernetes.Interface,
	namespace, labelSelector string) (_ []v1.Pod, err error)

func GetReplicaSets ¶

func GetReplicaSets(ctx context.Context, kubeClientset kubernetes.Interface,
	namespace, labelSelector string) (_ []appsv1.ReplicaSet, err error)

Types ¶

type Client ¶

type Client struct {
	Basic   kubernetes.Interface
	Dynamic dynamic.Interface
}

func BuildClientFromContent ¶

func BuildClientFromContent(kubeconfigContent string) (*rest.Config, *Client, error)

BuildClientFromContent build client from k8s kubeconfig content, not file path

type ContainerRef ¶

type ContainerRef struct {
	Config        *rest.Config
	KubeClientset kubernetes.Interface
	Namespace     string
	Pod           string
	Container     string
}

Source Files ¶

View all Source files

kube.go

Directories ¶

Path	Synopsis
fake

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL