adapter

Jan 23, 2024

Changes in this version

+ const EnvConfigAudience

+ const EnvConfigOIDCServiceAccount

type ClientConfig

+ TokenProvider *auth.OIDCTokenProvider

+ TrustBundleConfigMapLister corev1listers.ConfigMapNamespaceLister

type EnvConfig

+ Audience *string

+ OIDCServiceAccountName *string

+ func (e *EnvConfig) GetAudience() *string

+ func (e *EnvConfig) GetOIDCServiceAccountName() *types.NamespacedName

type EnvConfigAccessor

+ GetAudience func() *string

+ GetOIDCServiceAccountName func() *types.NamespacedName

Jul 26, 2023

Changes in this version

+ const EnvConfigCACert

+ type Client interface

+ func NewClient(cfg ClientConfig) (Client, error)

+ type ClientConfig struct

+ CeOverrides *duckv1.CloudEventOverrides

+ CrStatusEventClient *crstatusevent.CRStatusEventClient

+ Env EnvConfigAccessor

+ Options []http.Option

+ Reporter source.StatsReporter

+ func GetClientConfig(ctx context.Context) ClientConfig

Apr 25, 2023

Changes in this version

type EnvConfig

+ CACerts *string

+ func (e *EnvConfig) GetCACerts() *string

type EnvConfigAccessor

+ GetCACerts func() *string

Dec 9, 2022

Changes in this version

type MetricsExporterConfiguratorFromConfigMapOption

+ func WithMetricsExporterConfiguratorMetricsPort(port int) MetricsExporterConfiguratorFromConfigMapOption

Apr 19, 2022

Changes in this version

+ func ConfigWatcherFromContext(ctx context.Context) configmap.Watcher

+ func GetConfigMapByPolling(ctx context.Context, name string) (cm *corev1.ConfigMap, err error)

+ func IsConfigWatcherEnabled(ctx context.Context) bool

+ func NamespaceFromContext(ctx context.Context) string

+ func SecretFetcher(ctx context.Context) metrics.SecretFetcher

+ func SetupConfigMapWatch(ctx context.Context, opts ...ConfigMapWatchOption) configmap.Watcher

+ func SetupLoggerFromConfig(config *logging.Config, component string) (*zap.SugaredLogger, zap.AtomicLevel)

+ func WithConfigWatcher(ctx context.Context, cmw configmap.Watcher) context.Context

+ func WithConfigWatcherEnabled(ctx context.Context) context.Context

+ func WithConfiguratorOptions(ctx context.Context, opts []ConfiguratorOption) context.Context

+ func WithNamespace(ctx context.Context, namespace string) context.Context

+ type AdapterConfigurator interface

+ type CloudEventsStatusReporterConfigurator interface

+ CreateCloudEventsStatusReporter func(ctx context.Context) *crstatusevent.CRStatusEventClient

+ func NewCloudEventsReporterConfiguratorFromConfigMap(opts ...CloudEventsStatusReporterConfiguratorFromConfigMapOption) CloudEventsStatusReporterConfigurator

+ func NewCloudEventsStatusReporterConfiguratorFromEnvironment(env EnvConfigAccessor) CloudEventsStatusReporterConfigurator

+ type CloudEventsStatusReporterConfiguratorFromConfigMapOption func(*cloudEventsStatusReporterConfiguratorFromConfigMap)

+ func WithCloudEventsStatusReporterConfiguratorConfigMapName(name string) CloudEventsStatusReporterConfiguratorFromConfigMapOption

+ type ConfigMapWatchOption func(*ConfigMapWatchOptions)

+ func ConfigMapWatchWithLabels(ls []labels.Requirement) ConfigMapWatchOption

+ type ConfigMapWatchOptions struct

+ LabelsFilter []labels.Requirement

+ type ConfiguratorOption func(*adapterConfigurator)

+ func ConfiguratorOptionsFromContext(ctx context.Context) []ConfiguratorOption

+ func WithCloudEventsStatusReporterConfigurator(c CloudEventsStatusReporterConfigurator) ConfiguratorOption

+ func WithLoggerConfigurator(c LoggerConfigurator) ConfiguratorOption

+ func WithMetricsExporterConfigurator(c MetricsExporterConfigurator) ConfiguratorOption

+ func WithProfilerConfigurator(c ProfilerConfigurator) ConfiguratorOption

+ func WithTracingConfigurator(c TracingConfigurator) ConfiguratorOption

+ type LoggerConfigurator interface

+ CreateLogger func(ctx context.Context) *zap.SugaredLogger

+ func NewLoggerConfiguratorFromConfigMap(component string, opts ...LoggerConfiguratorFromConfigMapOption) LoggerConfigurator

+ func NewLoggerConfiguratorFromEnvironment(env EnvConfigAccessor) LoggerConfigurator

+ type LoggerConfiguratorFromConfigMapOption func(*loggerConfiguratorFromConfigMap)

+ func WithLoggerConfiguratorConfigMapName(name string) LoggerConfiguratorFromConfigMapOption

+ type MetricsExporterConfigurator interface

+ SetupMetricsExporter func(ctx context.Context)

+ func NewMetricsExporterConfiguratorFromConfigMap(component string, opts ...MetricsExporterConfiguratorFromConfigMapOption) MetricsExporterConfigurator

+ func NewMetricsExporterConfiguratorFromEnvironment(env EnvConfigAccessor) MetricsExporterConfigurator

+ type MetricsExporterConfiguratorFromConfigMapOption func(*metricsExporterConfiguratorFromConfigMap)

+ func WithMetricsExporterConfiguratorConfigMapName(name string) MetricsExporterConfiguratorFromConfigMapOption

+ func WithMetricsExporterConfiguratorMetricsDomain(domain string) MetricsExporterConfiguratorFromConfigMapOption

+ type ObservabilityConfigurator interface

+ type ProfilerConfigurator interface

+ CreateProfilingServer func(ctx context.Context) *http.Server

+ func NewProfilerConfiguratorFromConfigMap(opts ...ProfilerConfiguratorFromConfigMapOption) ProfilerConfigurator

+ func NewProfilerConfiguratorFromEnvironment(env EnvConfigAccessor) ProfilerConfigurator

+ type ProfilerConfiguratorFromConfigMapOption func(*profilerConfiguratorFromConfigMap)

+ func WithProfilerConfiguratorConfigMapName(name string) ProfilerConfiguratorFromConfigMapOption

+ type TracingConfiguration struct

+ InstanceName string

+ type TracingConfigurator interface

+ SetupTracing func(ctx context.Context, cfg *TracingConfiguration)

+ func NewTracingConfiguratorFromConfigMap(opts ...TracingConfiguratorFromConfigMapOption) TracingConfigurator

+ func NewTracingConfiguratorFromEnvironment(env EnvConfigAccessor) TracingConfigurator

+ type TracingConfiguratorFromConfigMapOption func(*tracingConfiguratorFromConfigMap)

+ func WithTracingConfiguratorConfigMapName(name string) TracingConfiguratorFromConfigMapOption

Jan 25, 2022

Changes in this version

+ func NewClientHTTPObserved(topt []http.Option, copt []ceclient.Option) (ceclient.Client, error)

Jun 29, 2021

Changes in this version

+ func NewCloudEventsClientWithOptions(ceOverrides *duckv1.CloudEventOverrides, reporter source.StatsReporter, ...) (cloudevents.Client, error)

Nov 10, 2020

Changes in this version

+ func LeaderElectionComponentConfigToJSON(cfg *kle.ComponentConfig) (string, error)

Oct 6, 2020

Changes in this version

+ const EnvSinkTimeout

+ func GetSinkTimeout(logger *zap.SugaredLogger) int

type EnvConfig

+ EnvSinkTimeout int

+ func (e *EnvConfig) GetSinktimeout() int

type EnvConfigAccessor

+ GetSinktimeout func() int

Sep 29, 2020

Changes in this version

+ func LeaderElectionComponentConfigToJson(cfg *kle.ComponentConfig) (string, error)

+ func WithController(ctx context.Context, ctor ControllerConstructor) context.Context

+ type ControllerConstructor func(ctx context.Context, adapter Adapter) *controller.Impl

+ func ControllerFromContext(ctx context.Context) ControllerConstructor

Aug 18, 2020

Changes in this version

+ func ConfigMapWatcherFromContext(ctx context.Context) configmap.Watcher

+ func FilterConfigByLabelEquals(labelKey string, labelValue string) (*labels.Requirement, error)

+ func IsConfigMapWatcherEnabled(ctx context.Context) bool

+ func IsHAEnabled(ctx context.Context) bool

+ func IsInjectorEnabled(ctx context.Context) bool

+ func MainWithEnv(ctx context.Context, component string, env EnvConfigAccessor, ...)

+ func MainWithInformers(ctx context.Context, component string, env EnvConfigAccessor, ...)

+ func NewCloudEventsClientCRStatus(target string, ceOverrides *duckv1.CloudEventOverrides, ...) (cloudevents.Client, error)

+ func SetupConfigMapWatchOrDie(ctx context.Context, component string, namespace string) configmap.Watcher

+ func SetupInformers(ctx context.Context, logger *zap.SugaredLogger) (context.Context, []controller.Informer)

+ func StartInformers(ctx context.Context, informers []controller.Informer)

+ func WithConfigMapWatcher(ctx context.Context, watcher configmap.Watcher) context.Context

+ func WithConfigMapWatcherEnabled(ctx context.Context) context.Context

+ func WithHAEnabled(ctx context.Context) context.Context

+ func WithInjectorEnabled(ctx context.Context) context.Context

type EnvConfigAccessor

+ func ConstructEnvOrDie(ector EnvConfigConstructor) EnvConfigAccessor

Jul 7, 2020

Changes in this version

+ const EnvConfigCEOverrides

+ const EnvConfigComponent

+ const EnvConfigLeaderElectionConfig

+ const EnvConfigLoggingConfig

+ const EnvConfigMetricsConfig

+ const EnvConfigName

+ const EnvConfigNamespace

+ const EnvConfigResourceGroup

+ const EnvConfigSink

+ const EnvConfigTracingConfig

type EnvConfig

+ LeaderElectionConfigJson string

+ func (e *EnvConfig) GetLeaderElectionConfig() (*kle.ComponentConfig, error)

type EnvConfigAccessor

+ GetLeaderElectionConfig func() (*kle.ComponentConfig, error)

May 26, 2020

Changes in this version

+ func MainMessageAdapter(component string, ector EnvConfigConstructor, ctor MessageAdapterConstructor)

+ func MainMessageAdapterWithContext(ctx context.Context, component string, ector EnvConfigConstructor, ...)

type EnvConfig

+ TracingConfigJson string

+ func (e *EnvConfig) SetupTracing(logger *zap.SugaredLogger) error

type EnvConfigAccessor

+ SetupTracing func(*zap.SugaredLogger) error

+ type MessageAdapter interface

+ Start func(stopCh <-chan struct{}) error

+ type MessageAdapterConstructor func(ctx context.Context, env EnvConfigAccessor, ...) MessageAdapter

Apr 14, 2020

Changes in this version

+ func ContextWithMetricTag(ctx context.Context, metric *MetricTag) context.Context

+ func Main(component string, ector EnvConfigConstructor, ctor AdapterConstructor)

+ func MainWithContext(ctx context.Context, component string, ector EnvConfigConstructor, ...)

+ func NewCloudEventsClient(target string, ceOverrides *duckv1.CloudEventOverrides, ...) (cloudevents.Client, error)

+ type Adapter interface

+ Start func(stopCh <-chan struct{}) error

+ type AdapterConstructor func(ctx context.Context, env EnvConfigAccessor, client cloudevents.Client) Adapter

+ type EnvConfig struct

+ CEOverrides string

+ Component string

+ LoggingConfigJson string

+ MetricsConfigJson string

+ Name string

+ Namespace string

+ ResourceGroup string

+ Sink string

+ func (e *EnvConfig) GetCloudEventOverrides() (*duckv1.CloudEventOverrides, error)

+ func (e *EnvConfig) GetLogger() *zap.SugaredLogger

+ func (e *EnvConfig) GetMetricsConfig() (*metrics.ExporterOptions, error)

+ func (e *EnvConfig) GetName() string

+ func (e *EnvConfig) GetNamespace() string

+ func (e *EnvConfig) GetSink() string

+ func (e *EnvConfig) SetComponent(component string)

+ type EnvConfigAccessor interface

+ GetCloudEventOverrides func() (*duckv1.CloudEventOverrides, error)

+ GetLogger func() *zap.SugaredLogger

+ GetMetricsConfig func() (*metrics.ExporterOptions, error)

+ GetName func() string

+ GetNamespace func() string

+ GetSink func() string

+ SetComponent func(string)

+ type EnvConfigConstructor func() EnvConfigAccessor

+ type MetricTag struct

+ Name string

+ Namespace string

+ ResourceGroup string

+ func MetricTagFromContext(ctx context.Context) *MetricTag