adapter

type Adapter interface {
	Start(ctx context.Context) error
}

type AdapterConfigurator interface {
	LoggerConfigurator
	ObservabilityConfigurator
	CloudEventsStatusReporterConfigurator
}

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

type Client interface {
	cloudevents.Client
	// contains filtered or unexported methods
}

type ClientConfig struct {
	Env                 EnvConfigAccessor
	CeOverrides         *duckv1.CloudEventOverrides
	Reporter            source.StatsReporter
	CrStatusEventClient *crstatusevent.CRStatusEventClient
	Options             []http.Option
	TokenProvider       *auth.OIDCTokenProvider
	MeterProvider       metric.MeterProvider
	TraceProvider       trace.TracerProvider

	TrustBundleConfigMapLister corev1listers.ConfigMapNamespaceLister
}

type CloudEventsStatusReporterConfigurator interface {
	CreateCloudEventsStatusReporter(ctx context.Context) *crstatusevent.CRStatusEventClient
}

type CloudEventsStatusReporterConfiguratorFromConfigMapOption func(*cloudEventsStatusReporterConfiguratorFromConfigMap)

type ConfigMapWatchOption func(*ConfigMapWatchOptions)

type ConfigMapWatchOptions struct {
	LabelsFilter []labels.Requirement
}

type ConfiguratorOption func(*adapterConfigurator)

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

type EnvConfig struct {
	// Component is the kind of this adapter.
	Component string `envconfig:"K_COMPONENT"`

	// Environment variable containing the namespace of the adapter.
	Namespace string `envconfig:"NAMESPACE"`

	// Environment variable containing the name of the adapter.
	Name string `envconfig:"NAME" default:"adapter"`

	// Environment variable containing the resource group of the adapter for metrics.
	ResourceGroup string `envconfig:"K_RESOURCE_GROUP" default:"adapter.sources.knative.dev"`

	// Sink is the URI messages will be sent.
	Sink string `envconfig:"K_SINK"`

	// Audience is the audience of the target sink.
	Audience *string `envconfig:"K_AUDIENCE"`

	// OIDCServiceAccount Name is the name of the service account to use for the adapter.
	OIDCServiceAccountName *string `envconfig:"K_OIDC_SERVICE_ACCOUNT"`

	// CACerts are the Certification Authority (CA) certificates in PEM format
	// according to https://www.rfc-editor.org/rfc/rfc7468.
	// +optional
	CACerts *string `envconfig:"K_CA_CERTS"`

	// CEOverrides are the CloudEvents overrides to be applied to the outbound event.
	CEOverrides string `envconfig:"K_CE_OVERRIDES"`

	// LoggingConfigJson is a json string of logging.Config.
	// This is used to configure the logging config, the config is stored in
	// a config map inside the controllers namespace and copied here.
	LoggingConfigJson string `envconfig:"K_LOGGING_CONFIG" default:"{}"`

	// ObservabilityConfigJson is a json string of observability.Config.
	// This is used to configure the observability config, the config is stored in
	// a config map inside the controllers namespace and copied here.
	ObservabilityConfigJson string `envconfig:"K_OBSERVABILITY_CONFIG" default:"{}"`

	// LeaderElectionConfigJson is the leader election component configuration.
	LeaderElectionConfigJson string `envconfig:"K_LEADER_ELECTION_CONFIG"`

	// Time in seconds to wait for sink to respond
	EnvSinkTimeout string `envconfig:"K_SINK_TIMEOUT"`
	// contains filtered or unexported fields
}

type EnvConfigAccessor interface {
	// Set the component name.
	SetComponent(string)

	// Get the URI where messages will be forwarded to.
	GetSink() string

	// GetCACerts gets the CACerts of the Sink.
	GetCACerts() *string

	// GetAudience gets the audience of the target sink.
	GetAudience() *string

	// GetOIDCServiceAccountName gets the service account name to use for the adapter.
	GetOIDCServiceAccountName() *types.NamespacedName

	// Get the namespace of the adapter.
	GetNamespace() string

	// Get the name of the adapter.
	GetName() string

	// Get the parsed logger.
	GetLogger() *zap.SugaredLogger

	GetCloudEventOverrides() (*duckv1.CloudEventOverrides, error)

	GetObservabilityConfig() (*observability.Config, error)

	// GetLeaderElectionConfig returns leader election configuration.
	GetLeaderElectionConfig() (*kle.ComponentConfig, error)

	// Get the timeout to apply on a request to a sink
	GetSinktimeout() int
}

type EnvConfigConstructor func() EnvConfigAccessor

type LoggerConfigurator interface {
	CreateLogger(ctx context.Context) *zap.SugaredLogger
}

type LoggerConfiguratorFromConfigMapOption func(*loggerConfiguratorFromConfigMap)

type MessageAdapter interface {
	Start(ctx context.Context) error
}

type MessageAdapterConstructor func(ctx context.Context, env EnvConfigAccessor, sink duckv1.Addressable, reporter source.StatsReporter) MessageAdapter

type MetricTag struct {
	Name          string
	Namespace     string
	ResourceGroup string
}

type ObservabilityConfigurator interface {
	SetupObservabilityOrDie(ctx context.Context, component string, logger *zap.SugaredLogger, pprof *k8sruntime.ProfilingServer) (metric.MeterProvider, trace.TracerProvider)
}

type ObservabilityConfiguratorFromConfigMapOption func(*observabilityConfiguratorFromConfigMap)

type ProfilerConfigurator interface {
	CreateProfilingServer(ctx context.Context) *http.Server
}