cmd

Documentation

Index

• type Globals
  • func (s *Globals) Flush()
  • func (s *Globals) Initialize() error
  • func (s *Globals) IsKubernetes() bool
  • func (s *Globals) NeedsBrokerConfigFileWatcher() bool
  • func (s *Globals) NeedsFileWatcher() bool
  • func (s *Globals) NeedsKubernetesBrokerSecret() bool
  • func (s *Globals) NeedsKubernetesInformer() bool
  • func (s *Globals) NeedsKubernetesObservabilityConfigMap() bool
  • func (s *Globals) NeedsObservabilityConfigFileWatcher() bool
  • func (s *Globals) UpdateLogLevel(cfg *observability.Config)
  • func (s *Globals) UpdateMetricsOptions(cfg *observability.Config)
  • func (s *Globals) Validate() error

Types

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 */

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

func (*Globals) Flush

func (s *Globals) Flush()

func (*Globals) Initialize

func (s *Globals) Initialize() error

func (*Globals) IsKubernetes

func (s *Globals) IsKubernetes() bool

func (*Globals) NeedsBrokerConfigFileWatcher

func (s *Globals) NeedsBrokerConfigFileWatcher() bool

func (*Globals) NeedsFileWatcher

func (s *Globals) NeedsFileWatcher() bool

func (*Globals) NeedsKubernetesBrokerSecret

func (s *Globals) NeedsKubernetesBrokerSecret() bool

func (*Globals) NeedsKubernetesInformer

func (s *Globals) NeedsKubernetesInformer() bool

func (*Globals) NeedsKubernetesObservabilityConfigMap

func (s *Globals) NeedsKubernetesObservabilityConfigMap() bool

func (*Globals) NeedsObservabilityConfigFileWatcher

func (s *Globals) NeedsObservabilityConfigFileWatcher() bool

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