Versions in this module Expand all Collapse all v0 v0.1.0 Feb 6, 2025 Changes in this version + const DefaultKafkaMessageBufferCap + func AnyFilterMatches(filters []Filter, event *kube.EnhancedEvent) bool + func RelevantFieldSelection(event *kube.EnhancedEvent) map[string]string + type FieldSelectionFallback func(event *kube.EnhancedEvent, err error) map[string]string + type Filter struct + Component string + Kind string + Message string + Namespace string + Reason string + Type string + func (f *Filter) MatchEvent(event *kube.EnhancedEvent) bool + func (f *Filter) Validate() error + type KafkaMessageBuffer = circular.RingBuffer[*kafka.Message] + func NewKafkaMessageBuffer(capacity int) *KafkaMessageBuffer + type Option func(*Processor) + func WithFilters(filters []Filter) Option + func WithLogger(logger *zap.Logger) Option + func WithSelectors(selectors []Selector) Option + func WriteTo(output *KafkaMessageBuffer) Option + type PayloadCustomizer struct + OnSelectionError FieldSelectionFallback + Selectors []Selector + func (pc *PayloadCustomizer) Customize(event *kube.EnhancedEvent) map[string]string + type Processor struct + func New(source *watcher.EventBuffer, opts ...Option) *Processor + func (p *Processor) GetBuffer() *KafkaMessageBuffer + func (p *Processor) Process(ctx context.Context) + type Selector struct + Key string + Value string + func (s *Selector) Validate() error
Go to main page