eventlog

type Eventlog interface {
	api.Eventlog

	Close(ctx context.Context)
	Writer() LogWriter
	Reader(cfg ReaderConfig) 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 interface {
	Log() Eventlog

	Close(ctx context.Context)

	Append(ctx context.Context, events *cloudevents.CloudEventBatch) (offs []int64, err error)
}

type ReadableSegmentsWatcher struct {
	*primitive.Watcher
	// contains filtered or unexported fields
}

type ReaderConfig struct {
	PollingTimeout int64
}

type WritableSegmentWatcher struct {
	*primitive.Watcher
	// contains filtered or unexported fields
}