controllers

Documentation

Index

• func ValidateConfig(config *GlobalConfig) error
• type EventBusConfig
• type GlobalConfig
  • func LoadConfig(onErrorReloading func(error)) (*GlobalConfig, error)
  • func (g *GlobalConfig) GetJetStreamVersion(version string) (*JetStreamVersion, error)
  • func (g *GlobalConfig) GetSTANVersion(version string) (*StanVersion, error)
• type JetStreamConfig
• type JetStreamVersion
• type StanConfig
• type StanVersion

Functions

func ValidateConfig

func ValidateConfig(config *GlobalConfig) error

Types

type EventBusConfig

type EventBusConfig struct {
	NATS      *StanConfig      `json:"nats"`
	JetStream *JetStreamConfig `json:"jetstream"`
}

type GlobalConfig

type GlobalConfig struct {
	EventBus *EventBusConfig `json:"eventBus"`
}

func LoadConfig

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

func (*GlobalConfig) GetJetStreamVersion

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

func (*GlobalConfig) GetSTANVersion

func (g *GlobalConfig) GetSTANVersion(version string) (*StanVersion, error)

type JetStreamConfig

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

type JetStreamVersion

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

type StanConfig

type StanConfig struct {
	Versions []StanVersion `json:"versions"`
}

type StanVersion

type StanVersion struct {
	Version              string `json:"version"`
	NATSStreamingImage   string `json:"natsStreamingImage"`
	MetricsExporterImage string `json:"metricsExporterImage"`
}