factory

Documentation

Index

• Constants
• type KubeFactory
  • func NewKubeFactory(ctx context.LoopContext) *KubeFactory
  • func (this *KubeFactory) CreateDeployment() *apps.Deployment
  • func (this *KubeFactory) CreateIngress(serviceName string) *networking.Ingress
  • func (this *KubeFactory) CreateNetworkPolicy(serviceName string) *networking.NetworkPolicy
  • func (this *KubeFactory) CreatePodDisruptionBudgetV1() *policy_v1.PodDisruptionBudget
  • func (this *KubeFactory) CreatePodDisruptionBudgetV1beta1() *policy_v1beta1.PodDisruptionBudget
  • func (this *KubeFactory) CreateService() *core.Service
  • func (this *KubeFactory) GetLabels() map[string]string
  • func (this *KubeFactory) GetSelectorLabels() map[string]string
• type MonitoringFactory
  • func NewMonitoringFactory(ctx context.LoopContext, kubeFactory *KubeFactory) *MonitoringFactory
  • func (this *MonitoringFactory) GetLabels() map[string]string
  • func (this *MonitoringFactory) GetSelectorLabels() map[string]string
  • func (this *MonitoringFactory) NewServiceMonitor(service *core.Service) *monitoring.ServiceMonitor

Constants

const ENV_OPERATOR_NAME = "OPERATOR_NAME"

const ENV_REGISTRY_VERSION = "REGISTRY_VERSION"

const REGISTRY_CONTAINER_NAME = "registry"

Types

type KubeFactory

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

func NewKubeFactory

func NewKubeFactory(ctx context.LoopContext) *KubeFactory

func (*KubeFactory) CreateDeployment

func (this *KubeFactory) CreateDeployment() *apps.Deployment

func (*KubeFactory) CreateIngress

func (this *KubeFactory) CreateIngress(serviceName string) *networking.Ingress

func (*KubeFactory) CreateNetworkPolicy

func (this *KubeFactory) CreateNetworkPolicy(serviceName string) *networking.NetworkPolicy

func (*KubeFactory) CreatePodDisruptionBudgetV1

func (this *KubeFactory) CreatePodDisruptionBudgetV1() *policy_v1.PodDisruptionBudget

func (*KubeFactory) CreatePodDisruptionBudgetV1beta1

func (this *KubeFactory) CreatePodDisruptionBudgetV1beta1() *policy_v1beta1.PodDisruptionBudget

func (*KubeFactory) CreateService

func (this *KubeFactory) CreateService() *core.Service

func (*KubeFactory) GetLabels

func (this *KubeFactory) GetLabels() map[string]string

MUST NOT be used directly as selector labels, because some of them may change.

func (*KubeFactory) GetSelectorLabels

func (this *KubeFactory) GetSelectorLabels() map[string]string

Selector labels MUST be static/constant in the life of the application. Labels that can change during operator/SCV upgrade, such as "apicur.io/version" MUST NOT be used.

type MonitoringFactory

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

func NewMonitoringFactory

func NewMonitoringFactory(ctx context.LoopContext, kubeFactory *KubeFactory) *MonitoringFactory

func (*MonitoringFactory) GetLabels

func (this *MonitoringFactory) GetLabels() map[string]string

func (*MonitoringFactory) GetSelectorLabels

func (this *MonitoringFactory) GetSelectorLabels() map[string]string

func (*MonitoringFactory) NewServiceMonitor

func (this *MonitoringFactory) NewServiceMonitor(service *core.Service) *monitoring.ServiceMonitor