kubernetes

package
v0.33.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 25, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package kubernetes is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source
var (
	Scheme = k8s_runtime.NewScheme()
)

Functions

func EnsureNamespace

func EnsureNamespace(ctx context.Context, client k8s.Interface, namespace string) error

EnsureNamespace checks if a namespace exists in a Kubernetes cluster and creates it if it doesn't, returning an error if it fails.

func GetContextFromConfigFileIfExists

func GetContextFromConfigFileIfExists(configFilePath, context string) (string, error)

GetContextFromConfigFileIfExists attempts to load a Kubernetes context from a config file, and returns an error if the context is not found.

func NewCLIClientConfig

func NewCLIClientConfig(context string) (*rest.Config, error)

NewCLIClientConfig creates a new Kubernetes client config from the local configuration file using the given context name, with a default QPS and Burst. It returns a rest.Config and an error if one occurs.

func NewClientset

func NewClientset(context string) (*k8s.Clientset, *rest.Config, error)

NewClientset creates a new Kubernetes client and rest client config by context name.

func NewDynamicClient

func NewDynamicClient(context string) (dynamic.Interface, error)

NewDynamicClient creates a new dynamic client by context name, otherwise returns an error.

func NewRuntimeClient

func NewRuntimeClient(context string, scheme *k8s_runtime.Scheme) (client.WithWatch, error)

NewRuntimeClient creates a kubernetes client using a given context and scheme.

Types

type Impl

type Impl struct {
}

func (*Impl) GetKubeContext

func (i *Impl) GetKubeContext() (*api.Config, error)

GetKubeContext loads the kube configuration file and returns a Config object and an error if the file cannot be loaded.

type Interface

type Interface interface {
	GetKubeContext() (*api.Config, error)
}

type MockInterface

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

MockInterface is a mock of Interface interface.

func NewMockInterface

func NewMockInterface(ctrl *gomock.Controller) *MockInterface

NewMockInterface creates a new mock instance.

func (*MockInterface) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInterface) GetKubeContext

func (m *MockInterface) GetKubeContext() (*api.Config, error)

GetKubeContext mocks base method.

type MockInterfaceMockRecorder

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

MockInterfaceMockRecorder is the mock recorder for MockInterface.

func (*MockInterfaceMockRecorder) GetKubeContext

func (mr *MockInterfaceMockRecorder) GetKubeContext() *gomock.Call

GetKubeContext indicates an expected call of GetKubeContext.

Directories

Path Synopsis
logstream contains functionality for streaming logs for an entire application from Kubernetes.
logstream contains functionality for streaming logs for an entire application from Kubernetes.
portforward contains functionality for port-forwarding an entire application from Kubernetes.
portforward contains functionality for port-forwarding an entire application from Kubernetes.

Jump to

Keyboard shortcuts

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