cmd

Documentation

Index

• Constants
• type ConfigMethod
• type Globals
  • func (s *Globals) Flush()
  • func (s *Globals) Initialize() error
  • func (s *Globals) UpdateLogLevel(cfg *observability.Config)
  • func (s *Globals) UpdateMetricsOptions(cfg *observability.Config)
  • func (s *Globals) Validate() error

Constants

const (
	ConfigMethodUnknown = iota
	ConfigMethodFileWatcher
	ConfigMethodFilePoller
	ConfigMethodKubernetesSecretMapWatcher
	ConfigMethodInline
)

Types

type ConfigMethod

type ConfigMethod int

type Globals

type Globals struct {
	BrokerConfigPath        string `help:"Path to broker configuration file." env:"BROKER_CONFIG_PATH" default:"/etc/triggermesh/broker.conf"`
	ObservabilityConfigPath string `help:"Path to observability configuration file." env:"OBSERVABILITY_CONFIG_PATH"`
	Port                    int    `help:"HTTP Port to listen for CloudEvents." env:"PORT" default:"8080"`
	BrokerName              string `` /* 129-byte string literal not displayed */

	// Config Polling is an alternative to the default file watcher for config files.
	ConfigPollingPeriod string `` /* 158-byte string literal not displayed */

	// Inline Configuration
	BrokerConfig        string `help:"JSON representation of broker configuration." env:"BROKER_CONFIG"`
	ObservabilityConfig string `help:"JSON representation of observability configuration." env:"OBSERVABILITY_CONFIG"`

	// Kubernetes parameters
	KubernetesNamespace                  string `help:"Namespace where the broker is running." env:"KUBERNETES_NAMESPACE"`
	KubernetesBrokerConfigSecretName     string `help:"Secret object name that contains the broker configuration." env:"KUBERNETES_BROKER_CONFIG_SECRET_NAME"`
	KubernetesBrokerConfigSecretKey      string `help:"Secret object key that contains the broker configuration." env:"KUBERNETES_BROKER_CONFIG_SECRET_KEY"`
	KubernetesObservabilityConfigMapName string `help:"ConfigMap object name that contains the observability configuration." env:"KUBERNETES_OBSERVABILITY_CONFIGMAP_NAME"`

	ObservabilityMetricsDomain string `help:"Domain to be used for some metrics reporters." env:"OBSERVABILITY_METRICS_DOMAIN" default:"triggermesh.io/eventing"`

	Context       context.Context    `kong:"-"`
	Logger        *zap.SugaredLogger `kong:"-"`
	LogLevel      zap.AtomicLevel    `kong:"-"`
	PollingPeriod time.Duration      `kong:"-"`
	ConfigMethod  ConfigMethod       `kong:"-"`
}

func (*Globals) Flush

func (s *Globals) Flush()

func (*Globals) Initialize

func (s *Globals) Initialize() error

func (*Globals) UpdateLogLevel

func (s *Globals) UpdateLogLevel(cfg *observability.Config)

func (*Globals) UpdateMetricsOptions

func (s *Globals) UpdateMetricsOptions(cfg *observability.Config)

func (*Globals) Validate

func (s *Globals) Validate() error