mongodb

Documentation

Index

• type Client
  • func NewClient(uri string, connectTimout time.Duration) (Client, error)
• type Collection
• type Cursor
• type Database
• type MongoDB
  • func NewMongoDB(client Client, operationTimeout time.Duration) MongoDB

Types

type Client

type Client interface {
	Database(string) Database
	Disconnect(ctx context.Context) error
}

func NewClient

func NewClient(uri string, connectTimout time.Duration) (Client, error)

type Collection

type Collection interface {
	Find(ctx context.Context, filter interface{}) (Cursor, error)
	InsertOne(ctx context.Context, document interface{}) (*mongo.InsertOneResult, error)
	UpdateOrAddOne(ctx context.Context, filter, update interface{}) (*mongo.UpdateResult, error)
	DeleteOne(ctx context.Context, filter interface{}) (*mongo.DeleteResult, error)
}

type Cursor

type Cursor interface {
	Close(ctx context.Context) error
	All(ctx context.Context, results interface{}) error
}

type Database

type Database interface {
	Collection(name string) Collection
}

type MongoDB

type MongoDB interface {
	Put(ctx context.Context, database, collection string, filter, update interface{}) error
	GetAll(ctx context.Context, database, collection string, data interface{}) error
	Delete(ctx context.Context, database, collection string, filter interface{}) error
	Close(ctx context.Context) error
}

func NewMongoDB

func NewMongoDB(client Client, operationTimeout time.Duration) MongoDB

NewMongoDB creates a new MongoDB.