couchdbstore

package

v0.1.3 Latest Latest Go to latest Published: May 6, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Rendered for

This section is empty.

This section is empty.

This section is empty.

type CouchDBStore struct {
	// contains filtered or unexported fields
}

CouchDBStore represents a CouchDB-backed database.

func (c *CouchDBStore) Delete(k string) error

Delete will delete record with k key

func (c *CouchDBStore) Get(k string) ([]byte, error)

Get retrieves the value in the store associated with the given key.

func (c *CouchDBStore) Iterator(startKey, endKey string) storage.StoreIterator

Iterator returns iterator for the latest snapshot of the underlying db.

func (c *CouchDBStore) Put(k string, v []byte) error

Put stores the given key-value pair in the store.

type Option func(opts *Provider)

Option configures the couchdb provider

func WithDBPrefix(dbPrefix string) Option

WithDBPrefix option is for adding prefix to db name

type Provider struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Provider represents an CouchDB implementation of the storage.Provider interface

func NewProvider(hostURL string, opts ...Option) (*Provider, error)

NewProvider instantiates Provider

func (p *Provider) Close() error

Close closes the provider.

func (p *Provider) CloseStore(name string) error

CloseStore closes a previously opened store.

func (p *Provider) OpenStore(name string) (storage.Store, error)

OpenStore opens an existing store with the given name and returns it.