kubernetes

package

v1.0.700 Latest Latest Go to latest Published: Oct 7, 2024 License: Apache-2.0 Imports: 31 Imported by: 3

Details

This section is empty.

View Source

var Nil = fake.NewSimpleClientset()

func BytesToUtf8Lf(file []byte) (string, error)

func GetClusterName(config *rest.Config) string

ExecutePodf runs the specified shell command inside a container of the specified pod

func GetUnstructuredObjects(data []byte) ([]unstructured.Unstructured, error)

func NewClient(logger logger.Logger, kubeconfigPaths ...string) (kubernetes.Interface, *rest.Config, error)

func NewClientWithConfig(logger logger.Logger, kubeConfig []byte) (kubernetes.Interface, *rest.Config, error)

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

DynamicClient is an updated & stripped of kommons client

func NewKubeClient(client kubernetes.Interface, config *rest.Config) *DynamicClient

func (c *DynamicClient) ExecutePodf(ctx context.Context, namespace, pod, container string, command ...string) (string, string, error)

func (c *DynamicClient) FetchResources(ctx context.Context, resources ...unstructured.Unstructured) ([]unstructured.Unstructured, error)

func (c *DynamicClient) GetClientByGroupVersionKind(group, version, kind string) (dynamic.NamespaceableResourceInterface, error)

func (c *DynamicClient) GetClientByKind(kind string) (dynamic.NamespaceableResourceInterface, error)

func (c *DynamicClient) GetDynamicClient() (dynamic.Interface, error)

GetDynamicClient creates a new k8s client

func (c *DynamicClient) GetRestMapper() (meta.RESTMapper, error)