mongodb

Documentation

Index

• func NewDB(addr string, credential *options.Credential) (*kv.DB, error)
• type MTxnStore
  • func (m MTxnStore) Close() error
  • func (m MTxnStore) GetTxnRecord(ctx context.Context, version uint64) (value types.DBValue, err error)
  • func (m MTxnStore) RemoveTxnRecord(ctx context.Context, version uint64) error
  • func (m MTxnStore) UpsertTxnRecord(ctx context.Context, version uint64, val types.DBValue) error
• type MongoVVS
  • func (m MongoVVS) Close() error
  • func (m MongoVVS) Floor(ctx context.Context, key string, upperVersion uint64) (types.DBValue, uint64, error)
  • func (m MongoVVS) Get(ctx context.Context, key string, version uint64) (types.DBValue, error)
  • func (m MongoVVS) Remove(ctx context.Context, key string, version uint64) error
  • func (m MongoVVS) RemoveIf(ctx context.Context, key string, version uint64, ...) error
  • func (m MongoVVS) UpdateFlag(ctx context.Context, key string, version uint64, newFlag uint8) error
  • func (m MongoVVS) Upsert(ctx context.Context, key string, version uint64, val types.DBValue) error

Functions

func NewDB

func NewDB(addr string, credential *options.Credential) (*kv.DB, error)

Types

type MTxnStore

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

func (MTxnStore) Close

func (m MTxnStore) Close() error

func (MTxnStore) GetTxnRecord

func (m MTxnStore) GetTxnRecord(ctx context.Context, version uint64) (value types.DBValue, err error)

func (MTxnStore) RemoveTxnRecord

func (m MTxnStore) RemoveTxnRecord(ctx context.Context, version uint64) error

func (MTxnStore) UpsertTxnRecord

func (m MTxnStore) UpsertTxnRecord(ctx context.Context, version uint64, val types.DBValue) error

type MongoVVS

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

func (MongoVVS) Close

func (m MongoVVS) Close() error

func (MongoVVS) Floor

func (m MongoVVS) Floor(ctx context.Context, key string, upperVersion uint64) (types.DBValue, uint64, error)

func (MongoVVS) Get

func (m MongoVVS) Get(ctx context.Context, key string, version uint64) (types.DBValue, error)

func (MongoVVS) Remove

func (m MongoVVS) Remove(ctx context.Context, key string, version uint64) error

func (MongoVVS) RemoveIf

func (m MongoVVS) RemoveIf(ctx context.Context, key string, version uint64, pred func(prev types.DBValue) error) error

func (MongoVVS) UpdateFlag

func (m MongoVVS) UpdateFlag(ctx context.Context, key string, version uint64, newFlag uint8) error

func (MongoVVS) Upsert

func (m MongoVVS) Upsert(ctx context.Context, key string, version uint64, val types.DBValue) error