database

Documentation

Index

• type Base
  • func New(database *mongo.Database) *Base
  • func (db *Base) Collections() collection.Map
  • func (db *Base) Drop(ctx context.Context) error
  • func (db *Base) GetCollection(ctx context.Context, coll_name string, conn *connection.Base, ...) (*collection.Base, error)
  • func (db *Base) ListCollectionNames(ctx context.Context, filter any) ([]string, error)
  • func (db *Base) Name() string
  • func (db *Base) NewCollection(name string) *mongo.Collection
  • func (db *Base) RunCommand(ctx context.Context, command any) error
• type Inter
• type InterAdmin
• type Map
  • func (m Map) Get(db_name string) *Base
  • func (m Map) Set(base *Base)

Types

type Base

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

func New

func New(database *mongo.Database) *Base

func (*Base) Collections

func (db *Base) Collections() collection.Map

func (*Base) Drop

func (db *Base) Drop(ctx context.Context) error

func (*Base) GetCollection

func (db *Base) GetCollection(ctx context.Context, coll_name string, conn *connection.Base, indexes ...rIndex.Inter) (*collection.Base, error)

func (*Base) ListCollectionNames

func (db *Base) ListCollectionNames(ctx context.Context, filter any) ([]string, error)

func (*Base) Name

func (db *Base) Name() string

func (*Base) NewCollection

func (db *Base) NewCollection(name string) *mongo.Collection

func (*Base) RunCommand

func (db *Base) RunCommand(ctx context.Context, command any) error

type Inter

type Inter interface {
	Name() string
	Collections() collection.Map
	GetCollection(ctx context.Context, coll_name string, conn *connection.Base, indexes ...rIndex.Inter) (*collection.Base, error)
}

type InterAdmin

type InterAdmin interface {
	Drop(ctx context.Context) error
	ListCollectionNames(ctx context.Context, filter interface{}) ([]string, error)
	NewCollection(name string) *mongo.Collection
}

type Map

type Map map[string]*Base

func (Map) Get

func (m Map) Get(db_name string) *Base

func (Map) Set

func (m Map) Set(base *Base)