config

Documentation

Index

• Constants
• func ToContext(ctx context.Context, features *KafkaFeatureFlags) context.Context
• type KafkaFeatureFlags
  • func DefaultFeaturesConfig() *KafkaFeatureFlags
  • func FromContext(ctx context.Context) *KafkaFeatureFlags
  • func NewFeaturesConfigFromMap(cm *corev1.ConfigMap) (*KafkaFeatureFlags, error)
  • func (f *KafkaFeatureFlags) ExecuteBrokersTopicTemplate(brokerMetadata v1.ObjectMeta) (string, error)
  • func (f *KafkaFeatureFlags) ExecuteChannelsTopicTemplate(channelMetadata v1.ObjectMeta) (string, error)
  • func (f *KafkaFeatureFlags) ExecuteTriggersConsumerGroupTemplate(triggerMetadata v1.ObjectMeta) (string, error)
  • func (f *KafkaFeatureFlags) IsControllerAutoscalerEnabled() bool
  • func (f *KafkaFeatureFlags) IsDispatcherOrderedExecutorMetricsEnabled() bool
  • func (f *KafkaFeatureFlags) IsDispatcherRateLimiterEnabled() bool
  • func (f *KafkaFeatureFlags) Reset(ff *KafkaFeatureFlags)
• type Store
  • func NewStore(ctx context.Context, ...) *Store
  • func (s *Store) Load() *KafkaFeatureFlags
  • func (s *Store) ToContext(ctx context.Context) context.Context
• type Stores
  • func (css Stores) ToContext(ctx context.Context) context.Context

Constants

const (
	FlagsConfigName = "config-kafka-features"
)

Functions

func ToContext

func ToContext(ctx context.Context, features *KafkaFeatureFlags) context.Context

Types

type KafkaFeatureFlags

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

func DefaultFeaturesConfig

func DefaultFeaturesConfig() *KafkaFeatureFlags

func FromContext

func FromContext(ctx context.Context) *KafkaFeatureFlags

func NewFeaturesConfigFromMap

func NewFeaturesConfigFromMap(cm *corev1.ConfigMap) (*KafkaFeatureFlags, error)

NewFeaturesConfigFromMap creates a Features from the supplied Map

func (*KafkaFeatureFlags) ExecuteBrokersTopicTemplate

func (f *KafkaFeatureFlags) ExecuteBrokersTopicTemplate(brokerMetadata v1.ObjectMeta) (string, error)

func (*KafkaFeatureFlags) ExecuteChannelsTopicTemplate

func (f *KafkaFeatureFlags) ExecuteChannelsTopicTemplate(channelMetadata v1.ObjectMeta) (string, error)

func (*KafkaFeatureFlags) ExecuteTriggersConsumerGroupTemplate

func (f *KafkaFeatureFlags) ExecuteTriggersConsumerGroupTemplate(triggerMetadata v1.ObjectMeta) (string, error)

func (*KafkaFeatureFlags) IsControllerAutoscalerEnabled

func (f *KafkaFeatureFlags) IsControllerAutoscalerEnabled() bool

func (*KafkaFeatureFlags) IsDispatcherOrderedExecutorMetricsEnabled

func (f *KafkaFeatureFlags) IsDispatcherOrderedExecutorMetricsEnabled() bool

func (*KafkaFeatureFlags) IsDispatcherRateLimiterEnabled

func (f *KafkaFeatureFlags) IsDispatcherRateLimiterEnabled() bool

func (*KafkaFeatureFlags) Reset

func (f *KafkaFeatureFlags) Reset(ff *KafkaFeatureFlags)

type Store

type Store struct {
	*configmap.UntypedStore
}

Store is a typed wrapper around configmap.Untyped store to handle our configmaps. +k8s:deepcopy-gen=false

func NewStore

func NewStore(ctx context.Context, onAfterStore ...func(name string, value *KafkaFeatureFlags)) *Store

NewStore creates a new store of Configs and optionally calls functions when ConfigMaps are updated.

func (*Store) Load

func (s *Store) Load() *KafkaFeatureFlags

Load creates a Config from the current config state of the Store.

func (*Store) ToContext

func (s *Store) ToContext(ctx context.Context) context.Context

ToContext attaches the current Config state to the provided context.

type Stores

type Stores []reconciler.ConfigStore

func (Stores) ToContext

func (css Stores) ToContext(ctx context.Context) context.Context