Versions in this module Expand all Collapse all v0 v0.5.2 Nov 8, 2020 Changes in this version + type Log interface + After func(ctx context.Context, prefix string, revision, limit int64) (int64, []*server.Event, error) + Append func(ctx context.Context, event *server.Event) (int64, error) + Count func(ctx context.Context, prefix string) (int64, int64, error) + CurrentRevision func(ctx context.Context) (int64, error) + List func(ctx context.Context, prefix, startKey string, limit, revision int64, ...) (int64, []*server.Event, error) + Start func(ctx context.Context) error + Watch func(ctx context.Context, prefix string) <-chan []*server.Event + type LogStructured struct + func New(log Log) *LogStructured + func (l *LogStructured) Count(ctx context.Context, prefix string) (revRet int64, count int64, err error) + func (l *LogStructured) Create(ctx context.Context, key string, value []byte, lease int64) (revRet int64, errRet error) + func (l *LogStructured) Delete(ctx context.Context, key string, revision int64) (revRet int64, kvRet *server.KeyValue, deletedRet bool, errRet error) + func (l *LogStructured) Get(ctx context.Context, key string, revision int64) (revRet int64, kvRet *server.KeyValue, errRet error) + func (l *LogStructured) List(ctx context.Context, prefix, startKey string, limit, revision int64) (revRet int64, kvRet []*server.KeyValue, errRet error) + func (l *LogStructured) Start(ctx context.Context) error + func (l *LogStructured) Update(ctx context.Context, key string, value []byte, revision, lease int64) (revRet int64, kvRet *server.KeyValue, updateRet bool, errRet error) + func (l *LogStructured) Watch(ctx context.Context, prefix string, revision int64) <-chan []*server.Event
Go to main page