observer

type Event[T comparable] struct {
	Topic   T
	Payload protoreflect.ProtoMessage
}

type Observer[T comparable] struct {
	// contains filtered or unexported fields
}

type Processor[T comparable] func(e *Event[T]) error

type SourceID int64