kubernetes

Documentation

Overview

Package kubernetes is a generated GoMock package.

Index

• Variables
• func EnsureNamespace(ctx context.Context, client k8s.Interface, namespace string) error
• func GetContextFromConfigFileIfExists(configFilePath, context string) (string, error)
• func NewCLIClientConfig(context string) (*rest.Config, error)
• func NewClientset(context string) (*k8s.Clientset, *rest.Config, error)
• func NewDynamicClient(context string) (dynamic.Interface, error)
• func NewRuntimeClient(context string, scheme *k8s_runtime.Scheme) (client.WithWatch, error)
• type Impl
  • func (i *Impl) GetKubeContext() (*api.Config, error)
• type Interface
• type MockInterface
  • func NewMockInterface(ctrl *gomock.Controller) *MockInterface
  • func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder
  • func (m *MockInterface) GetKubeContext() (*api.Config, error)
• type MockInterfaceMockRecorder
  • func (mr *MockInterfaceMockRecorder) GetKubeContext() *gomock.Call

Variables

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

func (m *MockInterface) EXPECT() *MockInterfaceMockRecorder

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.