reader

type Config struct {
	EventbusID        vanus.ID
	Client            eb.Client
	SubscriptionID    vanus.ID
	SubscriptionIDStr string
	Offset            EventlogOffset
	BatchSize         int
}

type EventlogOffset map[vanus.ID]uint64

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

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

type Reader interface {
	Start() error
	Close()
}