streamkit

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

type Envelope struct {
	Identity    EventIdentity
	Timestamp   *time.Time
	Headers     []Header
	Key         []byte
	KeyNull     bool
	Payload     []byte
	PayloadNull bool
}

type EventIdentity = rowmodel.EventIdentity

type Header struct {
	Key   string
	Value []byte
	Null  bool
}

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

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

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

type OpaqueCodec struct{}

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

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

type RetryPolicy struct {
	MaxAttempts int
	Delay       time.Duration
	Retryable   func(error) bool
}

type Uint64Codec struct{}