client

Documentation

Index

• func Remove(addr string, dbname string, timeout int) error
• type RemoteDatabase
  • func Open(addr string, dbname string, createIfNeeded bool, timeout int) (*RemoteDatabase, error)
  • func (db *RemoteDatabase) BeginTX(table string) (*RemoteTransaction, error)
  • func (db *RemoteDatabase) Close() error
• type RemoteIterator
  • func (itr *RemoteIterator) Next() (key []byte, value []byte, err error)
• type RemoteTransaction
  • func (tx *RemoteTransaction) Commit() error
  • func (tx *RemoteTransaction) CommitSync() error
  • func (tx *RemoteTransaction) Get(key []byte) ([]byte, error)
  • func (tx *RemoteTransaction) Lookup(lower []byte, upper []byte) (*RemoteIterator, error)
  • func (tx *RemoteTransaction) Put(key []byte, value []byte) error
  • func (tx *RemoteTransaction) PutSync(key []byte, value []byte) error
  • func (tx *RemoteTransaction) Rollback() error

Functions

func Remove

func Remove(addr string, dbname string, timeout int) error

Types

type RemoteDatabase

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

func Open

func Open(addr string, dbname string, createIfNeeded bool, timeout int) (*RemoteDatabase, error)

func (*RemoteDatabase) BeginTX

func (db *RemoteDatabase) BeginTX(table string) (*RemoteTransaction, error)

func (*RemoteDatabase) Close

func (db *RemoteDatabase) Close() error

type RemoteIterator

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

func (*RemoteIterator) Next

func (itr *RemoteIterator) Next() (key []byte, value []byte, err error)

type RemoteTransaction

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

func (*RemoteTransaction) Commit

func (tx *RemoteTransaction) Commit() error

func (*RemoteTransaction) CommitSync

func (tx *RemoteTransaction) CommitSync() error

func (*RemoteTransaction) Get

func (tx *RemoteTransaction) Get(key []byte) ([]byte, error)

func (*RemoteTransaction) Lookup

func (tx *RemoteTransaction) Lookup(lower []byte, upper []byte) (*RemoteIterator, error)

func (*RemoteTransaction) Put

func (tx *RemoteTransaction) Put(key []byte, value []byte) error

Put stores a key/value asynchronously for performance. error will be nil, but a subsequent Commit will fail

func (*RemoteTransaction) PutSync

func (tx *RemoteTransaction) PutSync(key []byte, value []byte) error

PutSync stores a key/value pair waiting for confirmation from the remote server

func (*RemoteTransaction) Rollback

func (tx *RemoteTransaction) Rollback() error