kubernetes

Documentation

Index

• type KubernetesClient
  • func NewKubernetesClient(logger *logrus.Logger, kubeConfigFileName string) (*KubernetesClient, error)
  • func (k *KubernetesClient) AddClients(clients map[string]*kubernetes.Clientset)
  • func (k *KubernetesClient) GetSyncTime(id string) (types.SyncTime, error)
  • func (k *KubernetesClient) ListClusters(ctx context.Context) ([]types.Cluster, error)
  • func (k *KubernetesClient) ListNamespaces(ctx context.Context, clusterName string, labels map[string]string) ([]types.Namespace, error)
  • func (k *KubernetesClient) ListNodes(ctx context.Context, clusterName string, labels map[string]string) ([]types.K8sNode, error)
  • func (k *KubernetesClient) ListPods(ctx context.Context, clusterName string, labels map[string]string) (pods []types.Pod, err error)
  • func (k *KubernetesClient) ListPodsCIDRs(ctx context.Context, clusterName string) ([]string, error)
  • func (k *KubernetesClient) ListServices(ctx context.Context, clusterName string, labels map[string]string) ([]types.K8SService, error)
  • func (k *KubernetesClient) ListServicesCIDRs(ctx context.Context, clusterName string) (string, error)
  • func (k *KubernetesClient) UpdateServiceSourceRanges(ctx context.Context, clusterName, namespace, name string, cidrsToAdd []string, ...) error

Types

type KubernetesClient

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

func NewKubernetesClient

func NewKubernetesClient(logger *logrus.Logger, kubeConfigFileName string) (*KubernetesClient, error)

func (*KubernetesClient) AddClients

func (k *KubernetesClient) AddClients(clients map[string]*kubernetes.Clientset)

func (*KubernetesClient) GetSyncTime

func (k *KubernetesClient) GetSyncTime(id string) (types.SyncTime, error)

func (*KubernetesClient) ListClusters

func (k *KubernetesClient) ListClusters(ctx context.Context) ([]types.Cluster, error)

func (*KubernetesClient) ListNamespaces

func (k *KubernetesClient) ListNamespaces(ctx context.Context, clusterName string, labels map[string]string) ([]types.Namespace, error)

func (*KubernetesClient) ListNodes

func (k *KubernetesClient) ListNodes(ctx context.Context, clusterName string, labels map[string]string) ([]types.K8sNode, error)

func (*KubernetesClient) ListPods

func (k *KubernetesClient) ListPods(ctx context.Context, clusterName string, labels map[string]string) (pods []types.Pod, err error)

func (*KubernetesClient) ListPodsCIDRs

func (k *KubernetesClient) ListPodsCIDRs(ctx context.Context, clusterName string) ([]string, error)

func (*KubernetesClient) ListServices

func (k *KubernetesClient) ListServices(ctx context.Context, clusterName string, labels map[string]string) ([]types.K8SService, error)

func (*KubernetesClient) ListServicesCIDRs

func (k *KubernetesClient) ListServicesCIDRs(ctx context.Context, clusterName string) (string, error)

func (*KubernetesClient) UpdateServiceSourceRanges

func (k *KubernetesClient) UpdateServiceSourceRanges(ctx context.Context, clusterName, namespace, name string, cidrsToAdd []string, cidrsToRemove []string) error