nats

May 9, 2024

Changes in this version

type Backend

+ func (b *Backend) Compact(ctx context.Context, revision int64) (int64, error)

type BackendLogger

+ func (b *BackendLogger) Compact(ctx context.Context, revision int64) (int64, error)

Dec 7, 2023

Changes in this version

type Backend

+ func (b *Backend) CurrentRevision(ctx context.Context) (int64, error)

type BackendLogger

+ func (b *BackendLogger) CurrentRevision(ctx context.Context) (int64, error)

Nov 10, 2023

Changes in this version

+ type Backend struct

+ func (b *Backend) Close() error

+ func (b *Backend) Count(ctx context.Context, prefix string) (int64, int64, error)

+ func (b *Backend) Create(ctx context.Context, key string, value []byte, lease int64) (int64, error)

+ func (b *Backend) DbSize(ctx context.Context) (int64, error)

+ func (b *Backend) Delete(ctx context.Context, key string, revision int64) (int64, *server.KeyValue, bool, error)

+ func (b *Backend) Get(ctx context.Context, key, rangeEnd string, limit, revision int64) (int64, *server.KeyValue, error)

+ func (b *Backend) List(ctx context.Context, prefix, startKey string, limit, maxRevision int64) (int64, []*server.KeyValue, error)

+ func (b *Backend) Start(ctx context.Context) error

+ func (b *Backend) Update(ctx context.Context, key string, value []byte, revision, lease int64) (int64, *server.KeyValue, bool, error)

+ func (b *Backend) Watch(ctx context.Context, prefix string, startRevision int64) server.WatchResult

+ type BackendLogger struct

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

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

+ func (b *BackendLogger) DbSize(ctx context.Context) (int64, error)

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

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

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

+ func (b *BackendLogger) Start(ctx context.Context) error

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

+ func (b *BackendLogger) Watch(ctx context.Context, prefix string, revision int64) server.WatchResult

+ type KeyValue struct

+ func NewKeyValue(ctx context.Context, bucket jetstream.KeyValue, js jetstream.JetStream) *KeyValue

+ func (e *KeyValue) BucketRevision() int64

+ func (e *KeyValue) BucketSize(ctx context.Context) (int64, error)

+ func (e *KeyValue) Count(ctx context.Context, prefix string) (int64, error)

+ func (e *KeyValue) Create(ctx context.Context, key string, value []byte) (uint64, error)

+ func (e *KeyValue) Delete(ctx context.Context, key string, opts ...jetstream.KVDeleteOpt) error

+ func (e *KeyValue) Get(ctx context.Context, key string) (jetstream.KeyValueEntry, error)

+ func (e *KeyValue) GetRevision(ctx context.Context, key string, revision uint64) (jetstream.KeyValueEntry, error)

+ func (e *KeyValue) List(ctx context.Context, prefix, startKey string, limit, revision int64) ([]jetstream.KeyValueEntry, error)

+ func (e *KeyValue) Update(ctx context.Context, key string, value []byte, last uint64) (uint64, error)

+ func (e *KeyValue) Watch(ctx context.Context, keys string, startRev int64) (jetstream.KeyWatcher, error)

May 5, 2023

Changes in this version

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

Apr 26, 2023

Changes in this version

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

+ type Config struct

+ type Driver struct

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

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

+ func (d *Driver) DbSize(context.Context) (int64, error)

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

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

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

+ func (d *Driver) Start(ctx context.Context) error

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

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

+ type JSValue struct

+ Create bool

+ Delete bool

+ KV *server.KeyValue

+ PrevRevision int64