api

package

Go to main page

Versions in this module

v0

v0.9.0

Sep 7, 2023

Changes in this version

type Eventbus

+ CheckHealth func(ctx context.Context) error

type Eventlog

+ CheckHealth func(ctx context.Context) error

type MockEventbus

+ func (m *MockEventbus) CheckHealth(ctx context.Context) error

type MockEventbusMockRecorder

+ func (mr *MockEventbusMockRecorder) CheckHealth(ctx interface{}) *gomock.Call

type MockEventlog

+ func (m *MockEventlog) CheckHealth(ctx context.Context) error

type MockEventlogMockRecorder

+ func (mr *MockEventlogMockRecorder) CheckHealth(ctx interface{}) *gomock.Call

v0.8.0

Apr 17, 2023

Changes in this version

+ const DefaultPollingTimeout

+ const Manually

+ const ReadOnly

+ const ReadWrite

+ const RoundRobin

+ const Weight

+ var ConsumeFromWhereEarliest = ConsumeFromWhere("earliest")

+ var ConsumeFromWhereLatest = ConsumeFromWhere("latest")

+ func Append(ctx context.Context, w BusWriter, events []*ce.Event, opts ...WriteOption) (eids []string, err error)

+ func AppendOne(ctx context.Context, w BusWriter, event *ce.Event, opts ...WriteOption) (eid string, err error)

+ func Read(ctx context.Context, r BusReader, opts ...ReadOption) (events []*ce.Event, off int64, logid uint64, err error)

+ type BusReader interface

+ Read func(ctx context.Context, opts ...ReadOption) (events *cloudevents.CloudEventBatch, off int64, logid uint64, err error)

+ type BusWriter interface

+ Append func(ctx context.Context, events *cloudevents.CloudEventBatch, opts ...WriteOption) (eids []string, err error)

+ type ConsumeFromWhere string

+ type Eventbus interface

+ Close func(ctx context.Context)

+ GetLog func(ctx context.Context, logID uint64, opts ...LogOption) (Eventlog, error)

+ ListLog func(ctx context.Context, opts ...LogOption) ([]Eventlog, error)

+ Reader func(opts ...ReadOption) BusReader

+ Writer func(opts ...WriteOption) BusWriter

+ type EventbusOption func(opt *EventbusOptions)

+ func WithID(id uint64) EventbusOption

+ func WithName(name string) EventbusOption

+ type EventbusOptions struct

+ ID uint64

+ Name string

+ func DefaultEventbusOptions() *EventbusOptions

+ type Eventlog interface

+ EarliestOffset func(ctx context.Context) (int64, error)

+ ID func() uint64

+ LatestOffset func(ctx context.Context) (int64, error)

+ Length func(ctx context.Context) (int64, error)

+ QueryOffsetByTime func(ctx context.Context, timestamp int64) (int64, error)

+ type LogOption func(*LogOptions)

+ type LogOptions struct

+ Policy LogPolicy

+ type LogPolicy interface

+ AccessMode func() PolicyType

+ type MockBusReader struct

+ func NewMockBusReader(ctrl *gomock.Controller) *MockBusReader

+ func (m *MockBusReader) EXPECT() *MockBusReaderMockRecorder

+ func (m *MockBusReader) Read(ctx context.Context, opts ...ReadOption) (*cloudevents.CloudEventBatch, int64, uint64, error)

+ type MockBusReaderMockRecorder struct

+ func (mr *MockBusReaderMockRecorder) Read(ctx interface{}, opts ...interface{}) *gomock.Call

+ type MockBusWriter struct

+ func NewMockBusWriter(ctrl *gomock.Controller) *MockBusWriter

+ func (m *MockBusWriter) Append(ctx context.Context, events *cloudevents.CloudEventBatch, opts ...WriteOption) ([]string, error)

+ func (m *MockBusWriter) EXPECT() *MockBusWriterMockRecorder

+ type MockBusWriterMockRecorder struct

+ func (mr *MockBusWriterMockRecorder) Append(ctx, events interface{}, opts ...interface{}) *gomock.Call

+ type MockEventbus struct

+ func NewMockEventbus(ctrl *gomock.Controller) *MockEventbus

+ func (m *MockEventbus) Close(ctx context.Context)

+ func (m *MockEventbus) EXPECT() *MockEventbusMockRecorder

+ func (m *MockEventbus) GetLog(ctx context.Context, logID uint64, opts ...LogOption) (Eventlog, error)

+ func (m *MockEventbus) ListLog(ctx context.Context, opts ...LogOption) ([]Eventlog, error)

+ func (m *MockEventbus) Reader(opts ...ReadOption) BusReader

+ func (m *MockEventbus) Writer(opts ...WriteOption) BusWriter

+ type MockEventbusMockRecorder struct

+ func (mr *MockEventbusMockRecorder) Close(ctx interface{}) *gomock.Call

+ func (mr *MockEventbusMockRecorder) GetLog(ctx, logID interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusMockRecorder) ListLog(ctx interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusMockRecorder) Reader(opts ...interface{}) *gomock.Call

+ func (mr *MockEventbusMockRecorder) Writer(opts ...interface{}) *gomock.Call

+ type MockEventlog struct

+ func NewMockEventlog(ctrl *gomock.Controller) *MockEventlog

+ func (m *MockEventlog) EXPECT() *MockEventlogMockRecorder

+ func (m *MockEventlog) EarliestOffset(ctx context.Context) (int64, error)

+ func (m *MockEventlog) ID() uint64

+ func (m *MockEventlog) LatestOffset(ctx context.Context) (int64, error)

+ func (m *MockEventlog) Length(ctx context.Context) (int64, error)

+ func (m *MockEventlog) QueryOffsetByTime(ctx context.Context, timestamp int64) (int64, error)

+ type MockEventlogMockRecorder struct

+ func (mr *MockEventlogMockRecorder) EarliestOffset(ctx interface{}) *gomock.Call

+ func (mr *MockEventlogMockRecorder) ID() *gomock.Call

+ func (mr *MockEventlogMockRecorder) LatestOffset(ctx interface{}) *gomock.Call

+ func (mr *MockEventlogMockRecorder) Length(ctx interface{}) *gomock.Call

+ func (mr *MockEventlogMockRecorder) QueryOffsetByTime(ctx, timestamp interface{}) *gomock.Call

+ type PolicyType string

+ type ReadOption func(*ReadOptions)

+ type ReadOptions struct

+ BatchSize int

+ Policy ReadPolicy

+ PollingTimeout int64

+ func (ro *ReadOptions) Apply(opts ...ReadOption)

+ func (ro *ReadOptions) Copy() *ReadOptions

+ type ReadPolicy interface

+ Forward func(diff int)

+ Offset func() int64

+ type WriteOption func(*WriteOptions)

+ type WriteOptions struct

+ Oneway bool

+ Policy WritePolicy

+ func (wo *WriteOptions) Apply(opts ...WriteOption)

+ func (wo *WriteOptions) Copy() *WriteOptions

+ type WritePolicy interface

+ NextLog func(ctx context.Context) (Eventlog, error)

+ Type func() PolicyType

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL