Documentation ¶
Index ¶
Constants ¶
View Source
const (
XVanusLogOffset = segpb.XVanusLogOffset
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Eventlog ¶
type Eventlog interface { api.Eventlog Close(ctx context.Context) Writer() LogWriter Reader(cfg ReaderConfig) LogReader }
func NewEventlog ¶
type LogReader ¶
type LogReader interface { Log() Eventlog Close(ctx context.Context) // TODO: async Read(ctx context.Context, size int16) (events *cloudevents.CloudEventBatch, err error) // Seek sets the offset for the next Read to offset, // interpreted according to whence. // // `Seek(context.Background(), 0, io.SeekCurrent)` will return current offset. // // Also see `io.Seeker`. Seek(ctx context.Context, offset int64, whence int) (off int64, err error) }
type LogWriter ¶
type LogWriter interface { Log() Eventlog Close(ctx context.Context) Append(ctx context.Context, events *cloudevents.CloudEventBatch) (offs []int64, err error) }
type ReadableSegmentsWatcher ¶
type ReadableSegmentsWatcher struct { *primitive.Watcher // contains filtered or unexported fields }
func WatchReadableSegments ¶
func WatchReadableSegments(l *eventlog) *ReadableSegmentsWatcher
func (*ReadableSegmentsWatcher) Chan ¶
func (w *ReadableSegmentsWatcher) Chan() <-chan []*record.Segment
func (*ReadableSegmentsWatcher) Start ¶
func (w *ReadableSegmentsWatcher) Start()
type ReaderConfig ¶
type ReaderConfig struct {
PollingTimeout int64
}
type WritableSegmentWatcher ¶
func WatchWritableSegment ¶
func WatchWritableSegment(l *eventlog) *WritableSegmentWatcher
func (*WritableSegmentWatcher) Chan ¶
func (w *WritableSegmentWatcher) Chan() <-chan *record.Segment
func (*WritableSegmentWatcher) Start ¶
func (w *WritableSegmentWatcher) Start()
Click to show internal directories.
Click to hide internal directories.