client

Documentation

Index

• type Base
  • func New(conn connection.Base, client *mongo.Client) *Base
  • func (c *Base) Databases() database.Map
  • func (c *Base) Env() string
  • func (c *Base) GetColl(ctx context.Context, env, db_name, coll_name string, indexes ...rIndex.Inter) (*collection.Base, error)
  • func (c *Base) GetDatabase(db_name string) (*database.Base, error)
  • func (c *Base) ListDatabaseNames(ctx context.Context, filter interface{}) ([]string, error)
  • func (c *Base) NumberSessionsInProgress() int
  • func (c *Base) Timeout() *time.Duration
• type Inter
• type InterAdmin
• type Map
  • func (cs Map) Get(conn_name string) *Base
  • func (m Map) Set(conn_name string, base *Base)

Types

type Base

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

func New

func New(conn connection.Base, client *mongo.Client) *Base

func (*Base) Databases

func (c *Base) Databases() database.Map

func (*Base) Env

func (c *Base) Env() string

func (*Base) GetColl

func (c *Base) GetColl(ctx context.Context, env, db_name, coll_name string, indexes ...rIndex.Inter) (*collection.Base, error)

func (*Base) GetDatabase

func (c *Base) GetDatabase(db_name string) (*database.Base, error)

func (*Base) ListDatabaseNames

func (c *Base) ListDatabaseNames(ctx context.Context, filter interface{}) ([]string, error)

func (*Base) NumberSessionsInProgress

func (c *Base) NumberSessionsInProgress() int

func (*Base) Timeout

func (c *Base) Timeout() *time.Duration

type Inter

type Inter interface {
	Databases() database.Map
	Env() string
	GetColl(ctx context.Context, env, db_name, coll_name string, indexes ...rIndex.Inter) (*collection.Base, error)
}

type InterAdmin

type InterAdmin interface {
	GetDatabase(db_name string) (*database.Base, error)

	Timeout() *time.Duration
	NumberSessionsInProgress() int
	ListDatabaseNames(ctx context.Context, filter interface{}) ([]string, error)
}

type Map

type Map map[string]*Base

func (Map) Get

func (cs Map) Get(conn_name string) *Base

func (Map) Set

func (m Map) Set(conn_name string, base *Base)