reconciler

Documentation

Overview

Package reconciler defines implementations of the Reconciler interface defined at sigs.k8s.io/controller-runtime/pkg/reconcile.Reconciler. They implement the basic workhorse functionality of controllers, which include an InterStepBufferService controller, a Pipeline controller, and a Vertex controller.

Despite the implementation of the controllers, this package also implements a Start() function to watch corresponding Kubernetes resources for those controllers, it is supposed to be called at the time the controller manager service starts.

Index

• type DefaultConfig
  • func (dc DefaultConfig) GetDefaultContainerResources() corev1.ResourceRequirements
• type GlobalConfig
  • func FakeGlobalConfig(t *testing.T, isbSvcConfig *ISBSvcConfig) *GlobalConfig
  • func LoadConfig(onErrorReloading func(error)) (*GlobalConfig, error)
  • func (g *GlobalConfig) GetDefaults() DefaultConfig
  • func (g *GlobalConfig) GetISBSvcConfig() ISBSvcConfig
• type ISBSvcConfig
  • func (isc ISBSvcConfig) GetJetStreamVersion(version string) (*JetStreamVersion, error)
  • func (isc ISBSvcConfig) GetRedisVersion(version string) (*RedisVersion, error)
• type JetStreamConfig
• type JetStreamVersion
• type RedisConfig
• type RedisSettings
• type RedisVersion

Types

type DefaultConfig

type DefaultConfig struct {
	ContainerResources string `json:"containerResources"`
}

func (DefaultConfig) GetDefaultContainerResources

func (dc DefaultConfig) GetDefaultContainerResources() corev1.ResourceRequirements

type GlobalConfig

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

GlobalConfig is the configuration for the controllers, it is supposed to be populated from the configmap attached to the controller manager.

func FakeGlobalConfig

func FakeGlobalConfig(t *testing.T, isbSvcConfig *ISBSvcConfig) *GlobalConfig

func LoadConfig

func LoadConfig(onErrorReloading func(error)) (*GlobalConfig, error)

func (*GlobalConfig) GetDefaults

func (g *GlobalConfig) GetDefaults() DefaultConfig

Get controller scope default config

func (*GlobalConfig) GetISBSvcConfig

func (g *GlobalConfig) GetISBSvcConfig() ISBSvcConfig

Get controller scope ISB Service config

type ISBSvcConfig

type ISBSvcConfig struct {
	Redis     *RedisConfig     `json:"redis"`
	JetStream *JetStreamConfig `json:"jetstream"`
}

func (ISBSvcConfig) GetJetStreamVersion

func (isc ISBSvcConfig) GetJetStreamVersion(version string) (*JetStreamVersion, error)

func (ISBSvcConfig) GetRedisVersion

func (isc ISBSvcConfig) GetRedisVersion(version string) (*RedisVersion, error)

type JetStreamConfig

type JetStreamConfig struct {
	Settings     string             `json:"settings"`
	BufferConfig string             `json:"bufferConfig"`
	Versions     []JetStreamVersion `json:"versions"`
}

type JetStreamVersion

type JetStreamVersion struct {
	Version              string `json:"version"`
	NatsImage            string `json:"natsImage"`
	MetricsExporterImage string `json:"metricsExporterImage"`
	ConfigReloaderImage  string `json:"configReloaderImage"`
	StartCommand         string `json:"startCommand"`
}

type RedisConfig

type RedisConfig struct {
	Settings *RedisSettings `json:"settings"`
	Versions []RedisVersion `json:"versions"`
}

type RedisSettings

type RedisSettings struct {
	Redis    string `json:"redis"`
	Master   string `json:"master"`
	Replica  string `json:"replica"`
	Sentinel string `json:"sentinel"`
}

type RedisVersion

type RedisVersion struct {
	Version            string `json:"version"`
	RedisImage         string `json:"redisImage"`
	SentinelImage      string `json:"sentinelImage"`
	InitContainerImage string `json:"initContainerImage"`
	RedisExporterImage string `json:"redisExporterImage"`
}