kubernetes

package

v1.0.1126 Latest Latest Go to latest Published: Dec 13, 2025 License: Apache-2.0 Imports: 44 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flanksource/duty

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func BytesToUtf8Lf(file []byte) (string, error)
func GetAPIServer(kubeconfigRaw []byte) (string, error)
func GetClusterName(config *rest.Config) string
func GetClusterNameFromKubeconfig(config *clientcmdapi.Config) (clusterName string, server string)
func GetUnstructuredObjects(data []byte) ([]unstructured.Unstructured, error)
func NewClient(log logger.Logger, kubeconfigPaths ...string) (kubernetes.Interface, *rest.Config, error)
func NewClientFromPathOrConfig(logger logger.Logger, kubeconfigOrPath string) (kubernetes.Interface, *rest.Config, error)
func NewClientWithConfig(log logger.Logger, kubeConfig []byte) (kubernetes.Interface, *rest.Config, error)
func RestConfigFingerprint(rc *rest.Config) string
type Client
- func NewKubeClient(logger logger.Logger, client kubernetes.Interface, config *rest.Config) *Client

Constants ¶

This section is empty.

Variables ¶

View Source

var Nil = fake.NewSimpleClientset()

Functions ¶

func BytesToUtf8Lf ¶ added in v1.0.660

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

func GetAPIServer ¶ added in v1.0.878

func GetAPIServer(kubeconfigRaw []byte) (string, error)

func GetClusterName ¶ added in v1.0.596

func GetClusterName(config *rest.Config) string

GetClusterName returns the name of the cluster

func GetClusterNameFromKubeconfig ¶ added in v1.0.900

func GetClusterNameFromKubeconfig(config *clientcmdapi.Config) (clusterName string, server string)

func GetUnstructuredObjects ¶ added in v1.0.660

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

func NewClient ¶

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

func NewClientFromPathOrConfig ¶ added in v1.0.763

func NewClientFromPathOrConfig(
	logger logger.Logger,
	kubeconfigOrPath string,
) (kubernetes.Interface, *rest.Config, error)

func NewClientWithConfig ¶

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

func RestConfigFingerprint ¶ added in v1.0.854

func RestConfigFingerprint(rc *rest.Config) string

RestConfigFingerprint generates a unique SHA-256 hash to identify the Kubernetes API server and client authentication details from the REST configuration.

Types ¶

type Client ¶ added in v1.0.770

type Client struct {
	kubernetes.Interface

	Config *rest.Config // Prefer updaating token in place
	// contains filtered or unexported fields
}

func NewKubeClient ¶ added in v1.0.596

func NewKubeClient(logger logger.Logger, client kubernetes.Interface, config *rest.Config) *Client

func (*Client) DeleteByGVK ¶ added in v1.0.770

func (c *Client) DeleteByGVK(ctx context.Context, namespace, name string, gvk schema.GroupVersionKind) (bool, error)

func (*Client) ExecutePodf ¶ added in v1.0.770

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

func (*Client) ExpandNamespaces ¶ added in v1.0.901

func (c *Client) ExpandNamespaces(ctx context.Context, namespace string) ([]string, error)

func (*Client) FetchResources ¶ added in v1.0.770

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

func (*Client) GetClientByGroupVersionKind ¶ added in v1.0.770

func (c *Client) GetClientByGroupVersionKind(
	ctx context.Context, group, version, kind string,
) (dynamic.NamespaceableResourceInterface, error)

func (*Client) GetClientByKind ¶ added in v1.0.770

func (c *Client) GetClientByKind(kind string) (dynamic.NamespaceableResourceInterface, *meta.RESTMapping, error)

WARN: "Kind" is not specific enough. A cluster can have various resources with the same Kind. example: helmchrats.helm.cattle.io & helmcharts.source.toolkit.fluxcd.io both have HelmChart as the kind.

Use GetClientByGroupVersionKind instead.

func (*Client) GetDynamicClient ¶ added in v1.0.770

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

GetDynamicClient creates a new k8s client

func (*Client) GetPodLogs ¶ added in v1.0.770

func (c *Client) GetPodLogs(ctx context.Context, namespace, podName, container string) (io.ReadCloser, error)

func (*Client) GetRestMapper ¶ added in v1.0.770

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

func (*Client) QueryResources ¶ added in v1.0.898

func (c *Client) QueryResources(ctx context.Context, selector types.ResourceSelector) ([]unstructured.Unstructured, error)

func (*Client) Reset ¶ added in v1.0.872

func (c *Client) Reset()

func (*Client) ResetRestMapper ¶ added in v1.0.916

func (c *Client) ResetRestMapper()

func (*Client) RestConfig ¶ added in v1.0.854

func (c *Client) RestConfig() *rest.Config

func (*Client) SetLogger ¶ added in v1.0.900

func (c *Client) SetLogger(logger logger.Logger)

func (*Client) StreamLogsV2 ¶ added in v1.0.770

func (c *Client) StreamLogsV2(
	ctx context.Context,
	namespace, name string,
	timeout time.Duration,
	containerNames ...string,
) error

func (*Client) WaitForContainerStart ¶ added in v1.0.770

func (c *Client) WaitForContainerStart(
	ctx context.Context,
	namespace, name string,
	timeout time.Duration,
	containerNames ...string,
) error

WaitForContainerStart waits for the specified containers to be started (or any container if no names are specified) - returns an error if the timeout is exceeded

func (*Client) WaitForPod ¶ added in v1.0.770

func (c *Client) WaitForPod(
	ctx context.Context,
	namespace, name string,
	timeout time.Duration,
	phases ...v1.PodPhase,
) error

WaitForPod waits for a pod to be in the specified phase, or returns an error if the timeout is exceeded

Source Files ¶

View all Source files

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