Versions in this module Expand all Collapse all v0 v0.9.0 Sep 7, 2023 v0.8.0 Apr 17, 2023 Changes in this version + type Config struct + BatchSize int + Client eb.Client + EventbusID vanus.ID + Offset EventlogOffset + SubscriptionID vanus.ID + SubscriptionIDStr string + type EventlogOffset map[vanus.ID]uint64 + type MockReader struct + func NewMockReader(ctrl *gomock.Controller) *MockReader + func (m *MockReader) Close() + func (m *MockReader) EXPECT() *MockReaderMockRecorder + func (m *MockReader) Start() error + type MockReaderMockRecorder struct + func (mr *MockReaderMockRecorder) Close() *gomock.Call + func (mr *MockReaderMockRecorder) Start() *gomock.Call + type Reader interface + Close func() + Start func() error + func NewReader(config Config, events chan<- info.EventRecord) Reader
Go to main page