client

Documentation

Index

• type DiscoveryClient
  • func NewDiscoveryClient(ctx context.Context, config *rest.Config) (*DiscoveryClient, error)
  • func (dc *DiscoveryClient) ResourcesForCluster(toObj ParseResult, exclude ExcludeFilter, errLog io.Writer) (map[string]interface{}, error)
  • func (dc *DiscoveryClient) ResourcesForNamespace(toObj ParseResult, namespace string, exclude ExcludeFilter, errLog io.Writer) (map[string]interface{}, error)
  • func (dc *DiscoveryClient) SpecificResourcesForNamespace(toObj ParseResult, moduleName, namespace string, targetResource []string, ...) (map[string]interface{}, error)
• type ExcludeFilter
• type KubernetesClient
  • func NewKubernetesClient(ctx context.Context, config *rest.Config) (*KubernetesClient, error)
  • func (k *KubernetesClient) CreateDaemonSets(namespace string, daemonSet *appsv1.DaemonSet) (*appsv1.DaemonSet, error)
  • func (k *KubernetesClient) DeleteDaemonSets(namespace, name string) error
  • func (k *KubernetesClient) GetAllConfigMaps(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllCronJobsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllDaemonSetsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllDeploymentsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllEventsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllJobsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllNodesList() (runtime.Object, error)
  • func (k *KubernetesClient) GetAllPodsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllServicesList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllStatefulSetsList(namespace string) (runtime.Object, error)
  • func (k *KubernetesClient) GetAllVolumeAttachments() (runtime.Object, error)
  • func (k *KubernetesClient) GetDeploymentsListByLabels(namespace, labels string) (*appsv1.DeploymentList, error)
  • func (k *KubernetesClient) GetKubernetesVersion() (*version.Info, error)
  • func (k *KubernetesClient) GetNamespace(namespace string) (*corev1.Namespace, error)
  • func (k *KubernetesClient) GetNodesListByLabels(labels string) (*corev1.NodeList, error)
  • func (k *KubernetesClient) GetPodContainerLogRequest(namespace, podName, containerName string) *rest.Request
  • func (k *KubernetesClient) GetPodsListByLabels(namespace string, labels string) (*corev1.PodList, error)
• type MetricsClient
  • func NewMetricsClient(ctx context.Context, config *rest.Config) (*MetricsClient, error)
  • func (c *MetricsClient) GetAllNodeMetrics() (runtime.Object, error)
  • func (c *MetricsClient) GetAllPodMetrics(namespace string) (runtime.Object, error)
• type ParseResult

Types

type DiscoveryClient

type DiscoveryClient struct {
	Context context.Context
	// contains filtered or unexported fields
}

func NewDiscoveryClient

func NewDiscoveryClient(ctx context.Context, config *rest.Config) (*DiscoveryClient, error)

func (*DiscoveryClient) ResourcesForCluster

func (dc *DiscoveryClient) ResourcesForCluster(toObj ParseResult, exclude ExcludeFilter, errLog io.Writer) (map[string]interface{}, error)

Get the cluster level resources

func (*DiscoveryClient) ResourcesForNamespace

func (dc *DiscoveryClient) ResourcesForNamespace(toObj ParseResult, namespace string, exclude ExcludeFilter, errLog io.Writer) (map[string]interface{}, error)

func (*DiscoveryClient) SpecificResourcesForNamespace

func (dc *DiscoveryClient) SpecificResourcesForNamespace(toObj ParseResult, moduleName, namespace string, targetResource []string, errLog io.Writer) (map[string]interface{}, error)

Get extra resource/namespace and try to do specific filter with module name

type ExcludeFilter

type ExcludeFilter func(schema.GroupVersion, metav1.APIResource) bool

type KubernetesClient

type KubernetesClient struct {
	Context context.Context
	// contains filtered or unexported fields
}

func NewKubernetesClient

func NewKubernetesClient(ctx context.Context, config *rest.Config) (*KubernetesClient, error)

func (*KubernetesClient) CreateDaemonSets

func (k *KubernetesClient) CreateDaemonSets(namespace string, daemonSet *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

func (*KubernetesClient) DeleteDaemonSets

func (k *KubernetesClient) DeleteDaemonSets(namespace, name string) error

func (*KubernetesClient) GetAllConfigMaps

func (k *KubernetesClient) GetAllConfigMaps(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllCronJobsList

func (k *KubernetesClient) GetAllCronJobsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllDaemonSetsList

func (k *KubernetesClient) GetAllDaemonSetsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllDeploymentsList

func (k *KubernetesClient) GetAllDeploymentsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllEventsList

func (k *KubernetesClient) GetAllEventsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllJobsList

func (k *KubernetesClient) GetAllJobsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllNodesList

func (k *KubernetesClient) GetAllNodesList() (runtime.Object, error)

func (*KubernetesClient) GetAllPodsList

func (k *KubernetesClient) GetAllPodsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllServicesList

func (k *KubernetesClient) GetAllServicesList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllStatefulSetsList

func (k *KubernetesClient) GetAllStatefulSetsList(namespace string) (runtime.Object, error)

func (*KubernetesClient) GetAllVolumeAttachments

func (k *KubernetesClient) GetAllVolumeAttachments() (runtime.Object, error)

func (*KubernetesClient) GetDeploymentsListByLabels

func (k *KubernetesClient) GetDeploymentsListByLabels(namespace, labels string) (*appsv1.DeploymentList, error)

func (*KubernetesClient) GetKubernetesVersion

func (k *KubernetesClient) GetKubernetesVersion() (*version.Info, error)

func (*KubernetesClient) GetNamespace

func (k *KubernetesClient) GetNamespace(namespace string) (*corev1.Namespace, error)

func (*KubernetesClient) GetNodesListByLabels

func (k *KubernetesClient) GetNodesListByLabels(labels string) (*corev1.NodeList, error)

func (*KubernetesClient) GetPodContainerLogRequest

func (k *KubernetesClient) GetPodContainerLogRequest(namespace, podName, containerName string) *rest.Request

func (*KubernetesClient) GetPodsListByLabels

func (k *KubernetesClient) GetPodsListByLabels(namespace string, labels string) (*corev1.PodList, error)

type MetricsClient

type MetricsClient struct {
	Context context.Context
	// contains filtered or unexported fields
}

func NewMetricsClient

func NewMetricsClient(ctx context.Context, config *rest.Config) (*MetricsClient, error)

func (*MetricsClient) GetAllNodeMetrics

func (c *MetricsClient) GetAllNodeMetrics() (runtime.Object, error)

func (*MetricsClient) GetAllPodMetrics

func (c *MetricsClient) GetAllPodMetrics(namespace string) (runtime.Object, error)

type ParseResult

type ParseResult func(b []byte, groupVersion, kind string, resources ...string) (interface{}, error)