config

Documentation

Index

• type Config
  • func (cfg *Config) BindFlags()
  • func (cfg *Config) GetReconcileResourceMaxConcurrency(resourceName string) int
  • func (c *Config) GetWatchNamespaces() ([]string, error)
  • func (cfg *Config) ParseReconcileResourceResyncSeconds() (map[string]time.Duration, error)
  • func (cfg *Config) SetAWSAccountID() error
  • func (cfg *Config) SetupLogger()
  • func (cfg *Config) Validate(options ...Option) error
• type Option
  • func WithGVKs(gvks []schema.GroupVersionKind) Option

Types

type Config

type Config struct {
	MetricsAddr                     string
	HealthzAddr                     string
	EnableLeaderElection            bool
	LeaderElectionNamespace         string
	EnableDevelopmentLogging        bool
	AccountID                       string
	Region                          string
	IdentityEndpointURL             string
	EndpointURL                     string
	AllowUnsafeEndpointURL          bool
	LogLevel                        string
	ResourceTags                    []string
	WatchNamespace                  string
	EnableWebhookServer             bool
	WebhookServerAddr               string
	DeletionPolicy                  ackv1alpha1.DeletionPolicy
	ReconcileDefaultResyncSeconds   int
	ReconcileResourceResyncSeconds  []string
	ReconcileDefaultMaxConcurrency  int
	ReconcileResourceMaxConcurrency []string
}

Config contains configuration options for ACK service controllers

func (*Config) BindFlags

func (cfg *Config) BindFlags()

BindFlags defines CLI/runtime configuration options

func (*Config) GetReconcileResourceMaxConcurrency

func (cfg *Config) GetReconcileResourceMaxConcurrency(resourceName string) int

GetReconcileResourceMaxConcurrency returns the maximum number of concurrent reconciles for a given resource name. If the resource name is not found in the --reconcile-resource-max-concurrent-syncs flag, the function returns the default maximum concurrency value.

func (*Config) GetWatchNamespaces

func (c *Config) GetWatchNamespaces() ([]string, error)

GetWatchNamespaces returns a slice of namespaces to watch for custom resource events. If the watchNamespace flag is empty, the function returns nil, which means that the controller will watch for events in all namespaces.

func (*Config) ParseReconcileResourceResyncSeconds

func (cfg *Config) ParseReconcileResourceResyncSeconds() (map[string]time.Duration, error)

ParseReconcileResourceResyncSeconds parses the values of the --reconcile-resource-resync-seconds flag and returns a map that maps resource names to resync periods. The flag arguments are expected to have the format "resource=seconds", where "resource" is the name of the resource and "seconds" is the number of seconds that the reconciler should wait before reconciling the resource again.

func (*Config) SetAWSAccountID

func (cfg *Config) SetAWSAccountID() error

SetAWSAccountID uses sts GetCallerIdentity API to find AWS AccountId and set in Config

func (*Config) SetupLogger

func (cfg *Config) SetupLogger()

SetupLogger initializes the logger used in the service controller

func (*Config) Validate

func (cfg *Config) Validate(options ...Option) error

Validate ensures the options are valid

type Option

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

Option is a struct used to help validating the controller configuration

func WithGVKs

func WithGVKs(gvks []schema.GroupVersionKind) Option

WithGVKs instructs the configuration to validate against a set of supplied resource kinds and their respective groups.