testconfigobserver

Documentation

Index

• func WithPrefix(observer originalconfigobserver.ObserveConfigFunc, prefix ...string) originalconfigobserver.ObserveConfigFunc
• type ConfigObserver
  • func NewConfigObserver(operatorClient v1helpers.OperatorClient, ...) *ConfigObserver
  • func (c ConfigObserver) Sync(ctx context.Context, syncCtx factory.SyncContext) error

Functions

func WithPrefix

func WithPrefix(observer originalconfigobserver.ObserveConfigFunc, prefix ...string) originalconfigobserver.ObserveConfigFunc

WithPrefix adds a prefix to the path the input observer would otherwise observe into

Types

type ConfigObserver

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

func NewConfigObserver

func NewConfigObserver(
	operatorClient v1helpers.OperatorClient,
	listers originalconfigobserver.Listers,
	informers []factory.Informer,
	observers ...originalconfigobserver.ObserveConfigFunc,
) *ConfigObserver

NewConfigObserver creates a config observer that watches changes to a nested field (nestedConfigPath) in the config. Useful when the config is shared across multiple controllers in the same process.

Example:

Given the following configuration, you could run two separate controllers and point each to its own section. The first controller would be responsible for "oauthAPIServer" and the second for "oauthServer" section.

"observedConfig": {
  "oauthAPIServer": {
    "apiServerArguments": {"tls-min-version": "VersionTLS12"}
  },
  "oauthServer": {
    "corsAllowedOrigins": [ "//127\\.0\\.0\\.1(:|$)","//localhost(:|$)"]
  }
}

oauthAPIController := NewNestedConfigObserver(..., []string{"oauthAPIServer"} oauthServerController := NewNestedConfigObserver(..., []string{"oauthServer"}

func (ConfigObserver) Sync

func (c ConfigObserver) Sync(ctx context.Context, syncCtx factory.SyncContext) error

sync reacts to a change in prereqs by finding information that is required to match another value in the cluster. This must be information that is logically "owned" by another component.