kubernetes

func Clients ¶

func Clients() (kubernetes.Interface, scheme.Interface, error)

Clients returns a new Kubernetes and Dapr clients

func ComponentsIndexInformer ¶

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

func CreateService ¶

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

CreateService creates a new service

func DeploymentsIndexInformer ¶

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

func GetDeployment ¶

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

GetDeployment gets a deployment

func GetDeploymentsBySelector ¶

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

GetDeploymentsBySelector returns a deployment by a selector

func GetEndpoints ¶

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

GetEndpoints returns a list of service endpoints

func ServiceExists ¶

func ServiceExists(name, namespace string) bool

ServiceExists checks if a service already exists

func UpdateDeployment ¶

func UpdateDeployment(deployment *appsv1.Deployment) error

UpdateDeployment updates an existing deployment