k8s

Documentation

Index

• type Client
  • func NewClient(kubeconfig, kubecontext string) *Client
  • func (c *Client) CertManagerClientset() *certmanagerversioned.Clientset
  • func (c *Client) Config() *rest.Config
  • func (c *Client) DiscoveryClient() *discovery.DiscoveryClient
  • func (c *Client) DynamicClient() *dynamic.DynamicClient
  • func (c *Client) Exec(ctx context.Context, namespace, podName, containerName string, ...) (string, string, error)
  • func (c *Client) IstioClientset() *istioversioned.Clientset
  • func (c *Client) KubernetesClientset() *kubernetes.Clientset
• type Cluster
  • func NewCluster(client *Client, db *gorm.DB) *Cluster
  • func (c *Cluster) ApplyClusterRole(ctx context.Context, cr *rbacv1.ClusterRole) (err error)
  • func (c *Cluster) ApplyClusterRoleBiding(ctx context.Context, crb *rbacv1.ClusterRoleBinding) (err error)
  • func (c *Cluster) ApplyConfigMap(ctx context.Context, namespace string, configmap *corev1.ConfigMap) (err error)
  • func (c *Cluster) ApplyDeployment(ctx context.Context, namespace string, deployment *appsv1.Deployment) (err error)
  • func (c *Cluster) ApplyNamespace(ctx context.Context, name string) (err error)
  • func (c *Cluster) ApplyService(ctx context.Context, service *corev1.Service, namespace string) (err error)
  • func (c *Cluster) ApplyServiceAccount(ctx context.Context, sa *corev1.ServiceAccount, namespace string) (err error)
  • func (c *Cluster) ApplyStatefulSet(ctx context.Context, statefulSet *appsv1.StatefulSet, namespace string) (err error)
  • func (c *Cluster) ApplyUnstructured(ctx context.Context, obj *unstructured.Unstructured, namespace string) (err error)
  • func (c *Cluster) CertManager() *certmanager.Client
  • func (c *Cluster) CreateSecret(ctx context.Context, namespace string, secret *corev1.Secret) (*corev1.Secret, error)
  • func (c *Cluster) Exec(ctx context.Context, namespace, podName, containerName string, ...) (string, string, error)
  • func (c *Cluster) GetSecret(ctx context.Context, name, namespace string) (*corev1.Secret, error)
  • func (c *Cluster) Informer(queue workqueue.RateLimitingInterface) ext.Informer
  • func (c *Cluster) Istio() *istio.Client
• type Informer
  • func (i *Informer) Shutdown()
  • func (i *Informer) Start(stopCh <-chan struct{})

Types

type Client

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

func NewClient

func NewClient(kubeconfig, kubecontext string) *Client

func (*Client) CertManagerClientset

func (c *Client) CertManagerClientset() *certmanagerversioned.Clientset

func (*Client) Config

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

func (*Client) DiscoveryClient

func (c *Client) DiscoveryClient() *discovery.DiscoveryClient

func (*Client) DynamicClient

func (c *Client) DynamicClient() *dynamic.DynamicClient

func (*Client) Exec

func (c *Client) Exec(ctx context.Context, namespace, podName, containerName string, command []string) (string, string, error)

func (*Client) IstioClientset

func (c *Client) IstioClientset() *istioversioned.Clientset

func (*Client) KubernetesClientset

func (c *Client) KubernetesClientset() *kubernetes.Clientset

type Cluster

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

func NewCluster

func NewCluster(client *Client, db *gorm.DB) *Cluster

func (*Cluster) ApplyClusterRole

func (c *Cluster) ApplyClusterRole(ctx context.Context, cr *rbacv1.ClusterRole) (err error)

func (*Cluster) ApplyClusterRoleBiding

func (c *Cluster) ApplyClusterRoleBiding(ctx context.Context, crb *rbacv1.ClusterRoleBinding) (err error)

func (*Cluster) ApplyConfigMap

func (c *Cluster) ApplyConfigMap(ctx context.Context, namespace string, configmap *corev1.ConfigMap) (err error)

func (*Cluster) ApplyDeployment

func (c *Cluster) ApplyDeployment(ctx context.Context, namespace string, deployment *appsv1.Deployment) (err error)

func (*Cluster) ApplyNamespace

func (c *Cluster) ApplyNamespace(ctx context.Context, name string) (err error)

func (*Cluster) ApplyService

func (c *Cluster) ApplyService(ctx context.Context, service *corev1.Service, namespace string) (err error)

func (*Cluster) ApplyServiceAccount

func (c *Cluster) ApplyServiceAccount(ctx context.Context, sa *corev1.ServiceAccount, namespace string) (err error)

func (*Cluster) ApplyStatefulSet

func (c *Cluster) ApplyStatefulSet(ctx context.Context, statefulSet *appsv1.StatefulSet, namespace string) (err error)

func (*Cluster) ApplyUnstructured

func (c *Cluster) ApplyUnstructured(ctx context.Context, obj *unstructured.Unstructured, namespace string) (err error)

func (*Cluster) CertManager

func (c *Cluster) CertManager() *certmanager.Client

func (*Cluster) CreateSecret

func (c *Cluster) CreateSecret(ctx context.Context, namespace string, secret *corev1.Secret) (*corev1.Secret, error)

func (*Cluster) Exec

func (c *Cluster) Exec(ctx context.Context, namespace, podName, containerName string, command []string) (string, string, error)

func (*Cluster) GetSecret

func (c *Cluster) GetSecret(ctx context.Context, name, namespace string) (*corev1.Secret, error)

func (*Cluster) Informer

func (c *Cluster) Informer(queue workqueue.RateLimitingInterface) ext.Informer

func (*Cluster) Istio

func (c *Cluster) Istio() *istio.Client

type Informer

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

func (*Informer) Shutdown

func (i *Informer) Shutdown()

func (*Informer) Start

func (i *Informer) Start(stopCh <-chan struct{})