mongo

Documentation

Index

• Constants
• Variables
• func New(ctx context.Context, opt SetupOptions) (instance.Mongo, error)
• type IndexModel
• type InsertOneModel
• type MongoInst
  • func (i *MongoInst) Collection(name instance.CollectionName) *mongo.Collection
  • func (i *MongoInst) Ping(ctx context.Context) error
  • func (i *MongoInst) RawClient() *mongo.Client
  • func (i *MongoInst) RawDatabase() *mongo.Database
• type Pipeline
• type SetupOptions
• type UpdateOneModel
• type WriteModel

Constants

const (
	CollectionNameUsers          instance.CollectionName = "users"
	CollectionNameMessages       instance.CollectionName = "messages"
	CollectionNameTwitchRoles    instance.CollectionName = "twitch_roles"
	CollectionNameStreams        instance.CollectionName = "streams"
	CollectionNameCountDocuments instance.CollectionName = "count_documents"
)

Variables

var ErrNoDocuments = mongo.ErrNoDocuments

Functions

func New

func New(ctx context.Context, opt SetupOptions) (instance.Mongo, error)

Types

type IndexModel

type IndexModel = mongo.IndexModel

type InsertOneModel

type InsertOneModel = mongo.InsertOneModel

type MongoInst

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

func (*MongoInst) Collection

func (i *MongoInst) Collection(name instance.CollectionName) *mongo.Collection

func (*MongoInst) Ping

func (i *MongoInst) Ping(ctx context.Context) error

func (*MongoInst) RawClient

func (i *MongoInst) RawClient() *mongo.Client

func (*MongoInst) RawDatabase

func (i *MongoInst) RawDatabase() *mongo.Database

type Pipeline

type Pipeline = mongo.Pipeline

type SetupOptions

type SetupOptions struct {
	URI      string
	Database string
	Direct   bool
}

type UpdateOneModel

type UpdateOneModel = mongo.UpdateOneModel

type WriteModel

type WriteModel = mongo.WriteModel