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 GlobalConfig
  • func LoadConfig(onErrorReloading func(error)) (*GlobalConfig, error)
  • func (g *GlobalConfig) GetJetStreamVersion(version string) (*JetStreamVersion, error)
  • func (g *GlobalConfig) GetRedisVersion(version string) (*RedisVersion, error)
• type ISBSvcConfig
• type JetStreamConfig
• type JetStreamVersion
• type RedisConfig
• type RedisSettings
• type RedisVersion

Types

type GlobalConfig

type GlobalConfig struct {
	ISBSvc *ISBSvcConfig `json:"isbsvc"`
}

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

func LoadConfig

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

func (*GlobalConfig) GetJetStreamVersion

func (g *GlobalConfig) GetJetStreamVersion(version string) (*JetStreamVersion, error)

func (*GlobalConfig) GetRedisVersion

func (g *GlobalConfig) GetRedisVersion(version string) (*RedisVersion, error)

type ISBSvcConfig

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

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"`
}