mongodb

Documentation

Index

• Constants
• type KeyVal
• type MongoDB
  • func New(opts db.Options) (*MongoDB, error)
  • func (d *MongoDB) Close() error
  • func (d *MongoDB) Compact() error
  • func (d *MongoDB) Get(key []byte) ([]byte, error)
  • func (d *MongoDB) Iterate(prefix []byte, callback func(key, value []byte) bool) error
  • func (d *MongoDB) WriteTx() db.WriteTx
• type WriteTx
  • func (tx *WriteTx) Apply(other db.WriteTx) error
  • func (tx *WriteTx) Commit() error
  • func (tx *WriteTx) Delete(k []byte) error
  • func (tx *WriteTx) Discard()
  • func (tx *WriteTx) Get(k []byte) ([]byte, error)
  • func (tx *WriteTx) Iterate(prefix []byte, callback func(key, value []byte) bool) error
  • func (tx *WriteTx) Set(k, v []byte) error

Constants

const (
	// MongodbTimeoutConnect is the timeout for connecting to the database
	MongodbTimeoutConnect = 10 * time.Second
	// MongodbTimeoutCommit is the timeout for committing a batch transaction
	MongodbTimeoutCommit = 12 * time.Second
	// MongodbTimeoutQuery is the timeout for querying the database
	MongodbTimeoutQuery = 4 * time.Second
)

Types

type KeyVal

type KeyVal struct {
	Key   string `bson:"_id" json:"key"` // needs to be an ugly string because of regex
	Value []byte `bson:"value" json:"value"`
}

type MongoDB

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

MongoDB is a MongoDB implementation of the db.DB interface

func New

func New(opts db.Options) (*MongoDB, error)

func (*MongoDB) Close

func (d *MongoDB) Close() error

func (*MongoDB) Compact

func (d *MongoDB) Compact() error

func (*MongoDB) Get

func (d *MongoDB) Get(key []byte) ([]byte, error)

func (*MongoDB) Iterate

func (d *MongoDB) Iterate(prefix []byte, callback func(key, value []byte) bool) error

func (*MongoDB) WriteTx

func (d *MongoDB) WriteTx() db.WriteTx

type WriteTx

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

func (*WriteTx) Apply

func (tx *WriteTx) Apply(other db.WriteTx) error

func (*WriteTx) Commit

func (tx *WriteTx) Commit() error

func (*WriteTx) Delete

func (tx *WriteTx) Delete(k []byte) error

func (*WriteTx) Discard

func (tx *WriteTx) Discard()

func (*WriteTx) Get

func (tx *WriteTx) Get(k []byte) ([]byte, error)

func (*WriteTx) Iterate

func (tx *WriteTx) Iterate(prefix []byte, callback func(key, value []byte) bool) error

func (*WriteTx) Set

func (tx *WriteTx) Set(k, v []byte) error