jetstream

Mar 22, 2023

Changes in this version

+ func New(ctx context.Context, connection string, tlsInfo tls.Config) (server.Backend, error)

+ type Config struct

+ type JSValue struct

+ Create bool

+ Delete bool

+ KV *server.KeyValue

+ PrevRevision int64

+ type JetStream struct

+ func (j *JetStream) Count(ctx context.Context, prefix string) (revRet int64, count int64, err error)

+ func (j *JetStream) Create(ctx context.Context, key string, value []byte, lease int64) (revRet int64, errRet error)

+ func (j *JetStream) DbSize(context.Context) (int64, error)

+ func (j *JetStream) Delete(ctx context.Context, key string, revision int64) (revRet int64, kvRet *server.KeyValue, deletedRet bool, errRet error)

+ func (j *JetStream) Get(ctx context.Context, key, rangeEnd string, limit, revision int64) (revRet int64, kvRet *server.KeyValue, errRet error)

+ func (j *JetStream) List(ctx context.Context, prefix, startKey string, limit, revision int64) (revRet int64, kvRet []*server.KeyValue, errRet error)

+ func (j *JetStream) Start(ctx context.Context) error

+ func (j *JetStream) Update(ctx context.Context, key string, value []byte, revision, lease int64) (revRet int64, kvRet *server.KeyValue, updateRet bool, errRet error)

+ func (j *JetStream) Watch(ctx context.Context, prefix string, revision int64) <-chan []*server.Event