internal

Documentation

Index

• type DatabaseDriver
  • func NewCollectionDriver(database *mongo.Database) (*DatabaseDriver, error)
  • func (dd *DatabaseDriver) Delete(key key.Key) error
  • func (dd *DatabaseDriver) Get(key key.Key, opts ...noptions.Option) (noptions.Version, error)
  • func (dd *DatabaseDriver) GetName() string
  • func (dd *DatabaseDriver) Incr(key key.Key, field string, amount int32) (int64, error)
  • func (dd *DatabaseDriver) Set(key key.Key, opts ...noptions.Option) (noptions.Version, error)
• type DriverProvider
  • func NewDriverProvider(mClient *mongo.Client, logger *zap.Logger) *DriverProvider
  • func (dp *DriverProvider) OpenDbDriver(name string) (diface.ICollection, error)
  • func (dp *DriverProvider) Shutdown() error

Types

type DatabaseDriver

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

func NewCollectionDriver

func NewCollectionDriver(database *mongo.Database) (*DatabaseDriver, error)

func (*DatabaseDriver) Delete

func (dd *DatabaseDriver) Delete(key key.Key) error

Delete delete a document by a key

func (*DatabaseDriver) Get

func (dd *DatabaseDriver) Get(key key.Key, opts ...noptions.Option) (noptions.Version, error)

func (*DatabaseDriver) GetName

func (dd *DatabaseDriver) GetName() string

func (*DatabaseDriver) Incr

func (dd *DatabaseDriver) Incr(key key.Key, field string, amount int32) (int64, error)

Incr increments a document from the nosql store. (tips: can not be used for document,because the version)

func (*DatabaseDriver) Set

func (dd *DatabaseDriver) Set(key key.Key, opts ...noptions.Option) (noptions.Version, error)

type DriverProvider

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

func NewDriverProvider

func NewDriverProvider(
	mClient *mongo.Client,
	logger *zap.Logger,
) *DriverProvider

func (*DriverProvider) OpenDbDriver

func (dp *DriverProvider) OpenDbDriver(name string) (diface.ICollection, error)

func (*DriverProvider) Shutdown

func (dp *DriverProvider) Shutdown() error