creator

Documentation

Index

• Constants
• func CreatePodDisruptionBudget(cr api.ICustomResource) *policy.PodDisruptionBudget
• func NewContainerManager(probe interfaces.IProbeManager) interfaces.IContainerManager
• func NewOwnerReferencer() interfaces.IOwnerReferencesManager
• type ConfigMapManager
  • func NewConfigMapManager() *ConfigMapManager
  • func (m *ConfigMapManager) CreateConfigMap(what interfaces.ConfigMapType, params ...any) *core.ConfigMap
  • func (m *ConfigMapManager) SetCR(cr api.ICustomResource)
  • func (m *ConfigMapManager) SetConfigFilesGenerator(configFilesGenerator interfaces.IConfigFilesGenerator)
  • func (m *ConfigMapManager) SetTagger(tagger interfaces.ITagger)
• type ContainerManager
  • func (cm *ContainerManager) EnsureAppContainer(statefulSet *apps.StatefulSet, host *chi.Host)
  • func (cm *ContainerManager) EnsureLogContainer(statefulSet *apps.StatefulSet)
  • func (cm *ContainerManager) GetAppContainer(statefulSet *apps.StatefulSet) (*core.Container, bool)
  • func (cm *ContainerManager) NewDefaultAppContainer(host *chi.Host) core.Container
• type ProbeManager
  • func NewProbeManager() *ProbeManager
  • func (m *ProbeManager) CreateProbe(what interfaces.ProbeType, host *api.Host) *core.Probe
• type ServiceManager
  • func NewServiceManager() *ServiceManager
  • func (m *ServiceManager) CreateService(what interfaces.ServiceType, params ...any) *core.Service
  • func (m *ServiceManager) SetCR(cr chi.ICustomResource)
  • func (m *ServiceManager) SetTagger(tagger interfaces.ITagger)

Constants

const (
	// Default value for ClusterIP service
	TemplateDefaultsServiceClusterIP = "None"
)

Functions

func CreatePodDisruptionBudget

func CreatePodDisruptionBudget(cr api.ICustomResource) *policy.PodDisruptionBudget

CreatePodDisruptionBudget returns a pdb for the clickhouse keeper cluster

func NewContainerManager

func NewContainerManager(probe interfaces.IProbeManager) interfaces.IContainerManager

func NewOwnerReferencer

func NewOwnerReferencer() interfaces.IOwnerReferencesManager

Types

type ConfigMapManager

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

func NewConfigMapManager

func NewConfigMapManager() *ConfigMapManager

func (*ConfigMapManager) CreateConfigMap

func (m *ConfigMapManager) CreateConfigMap(what interfaces.ConfigMapType, params ...any) *core.ConfigMap

func (*ConfigMapManager) SetCR

func (m *ConfigMapManager) SetCR(cr api.ICustomResource)

func (*ConfigMapManager) SetConfigFilesGenerator

func (m *ConfigMapManager) SetConfigFilesGenerator(configFilesGenerator interfaces.IConfigFilesGenerator)

func (*ConfigMapManager) SetTagger

func (m *ConfigMapManager) SetTagger(tagger interfaces.ITagger)

type ContainerManager

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

func (*ContainerManager) EnsureAppContainer

func (cm *ContainerManager) EnsureAppContainer(statefulSet *apps.StatefulSet, host *chi.Host)

func (*ContainerManager) EnsureLogContainer

func (cm *ContainerManager) EnsureLogContainer(statefulSet *apps.StatefulSet)

func (*ContainerManager) GetAppContainer

func (cm *ContainerManager) GetAppContainer(statefulSet *apps.StatefulSet) (*core.Container, bool)

func (*ContainerManager) NewDefaultAppContainer

func (cm *ContainerManager) NewDefaultAppContainer(host *chi.Host) core.Container

type ProbeManager

type ProbeManager struct {
}

func NewProbeManager

func NewProbeManager() *ProbeManager

func (*ProbeManager) CreateProbe

func (m *ProbeManager) CreateProbe(what interfaces.ProbeType, host *api.Host) *core.Probe

type ServiceManager

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

func NewServiceManager

func NewServiceManager() *ServiceManager

func (*ServiceManager) CreateService

func (m *ServiceManager) CreateService(what interfaces.ServiceType, params ...any) *core.Service

func (*ServiceManager) SetCR

func (m *ServiceManager) SetCR(cr chi.ICustomResource)

func (*ServiceManager) SetTagger

func (m *ServiceManager) SetTagger(tagger interfaces.ITagger)