kubernetes

Documentation

Index

• func ComponentsIndexInformer(client scheme.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func DeploymentsIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• type API
  • func NewAPI(kubeClient kubernetes.Interface, daprClient scheme.Interface) *API
  • func (a *API) CreateService(service *corev1.Service, namespace string) error
  • func (a *API) DeleteService(serviceName string, namespace string) error
  • func (a *API) GetDaprClient() scheme.Interface
  • func (a *API) GetDeployment(name, namespace string) (*appsv1.Deployment, error)
  • func (a *API) GetDeploymentsBySelector(selector meta_v1.LabelSelector) ([]appsv1.Deployment, error)
  • func (a *API) GetEndpoints(name, namespace string) (*corev1.Endpoints, error)
  • func (a *API) GetKubeClient() kubernetes.Interface
  • func (a *API) ServiceExists(name, namespace string) bool
  • func (a *API) UpdateDeployment(deployment *appsv1.Deployment) error

Functions

func ComponentsIndexInformer

func ComponentsIndexInformer(
	client scheme.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
) cache.SharedIndexInformer

func DeploymentsIndexInformer

func DeploymentsIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
) cache.SharedIndexInformer

Types

type API

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

func NewAPI

func NewAPI(kubeClient kubernetes.Interface, daprClient scheme.Interface) *API

NewAPI returns api to interact with kubernetes

func (*API) CreateService

func (a *API) CreateService(service *corev1.Service, namespace string) error

CreateService creates a new service

func (*API) DeleteService

func (a *API) DeleteService(serviceName string, namespace string) error

Delete a service

func (*API) GetDaprClient

func (a *API) GetDaprClient() scheme.Interface

GetDaprClient returns Dapr Client

func (*API) GetDeployment

func (a *API) GetDeployment(name, namespace string) (*appsv1.Deployment, error)

GetDeployment gets a deployment

func (*API) GetDeploymentsBySelector

func (a *API) GetDeploymentsBySelector(selector meta_v1.LabelSelector) ([]appsv1.Deployment, error)

GetDeploymentsBySelector returns a deployment by a selector

func (*API) GetEndpoints

func (a *API) GetEndpoints(name, namespace string) (*corev1.Endpoints, error)

GetEndpoints returns a list of service endpoints

func (*API) GetKubeClient

func (a *API) GetKubeClient() kubernetes.Interface

GetKubeClient returns Kube Client

func (*API) ServiceExists

func (a *API) ServiceExists(name, namespace string) bool

ServiceExists checks if a service already exists

func (*API) UpdateDeployment

func (a *API) UpdateDeployment(deployment *appsv1.Deployment) error

UpdateDeployment updates an existing deployment