processor

Documentation

Index

• func NewPolicyProcessor(ctx context.Context, offsetManager OffsetManager) *policyProcessor
• type EventOffset
• type EventProcessor
• type OffsetManager

Functions

func NewPolicyProcessor

func NewPolicyProcessor(ctx context.Context, offsetManager OffsetManager) *policyProcessor

Types

type EventOffset

type EventOffset struct {
	Topic     string
	Partition int32
	Offset    int64
}

type EventProcessor

type EventProcessor interface {
	Process(event *kube.EnhancedEvent, offset *EventOffset)
}

type OffsetManager

type OffsetManager interface {
	MarkOffset(topic string, partition int32, offset int64)
}