mongo

Documentation

Index

• func New(conf map[string]string) (drivers.DataStore, error)
• type Mongo
  • func (m *Mongo) Close() error
  • func (m *Mongo) Connect() error
  • func (m *Mongo) CreateUser(ctx context.Context, user *entity.User) (int, error)
  • func (m *Mongo) GetUserByEmail(ctx context.Context, email string) (*entity.User, error)
  • func (m *Mongo) GetUserByID(ctx context.Context, id int) (user *entity.User, err error)
  • func (m *Mongo) GetUsers(ctx context.Context) ([]*entity.User, error)
  • func (m *Mongo) Name() string
  • func (m *Mongo) Ping() error

Functions

func New

func New(conf map[string]string) (drivers.DataStore, error)

Types

type Mongo

type Mongo struct {
	MongoURL string

	DB      *mongo.Database
	Context context.Context
	// contains filtered or unexported fields
}

func (*Mongo) Close

func (m *Mongo) Close() error

func (*Mongo) Connect

func (m *Mongo) Connect() error

func (*Mongo) CreateUser

func (m *Mongo) CreateUser(ctx context.Context, user *entity.User) (int, error)

func (*Mongo) GetUserByEmail

func (m *Mongo) GetUserByEmail(ctx context.Context, email string) (*entity.User, error)

func (*Mongo) GetUserByID

func (m *Mongo) GetUserByID(ctx context.Context, id int) (user *entity.User, err error)

func (*Mongo) GetUsers

func (m *Mongo) GetUsers(ctx context.Context) ([]*entity.User, error)

func (*Mongo) Name

func (m *Mongo) Name() string

func (*Mongo) Ping

func (m *Mongo) Ping() error