mongo

package

v0.0.0-...-3f93e99 Latest Latest Go to latest Published: Apr 8, 2023 License: GPL-3.0 Imports: 8 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dmibod/kanban

Links

Open Source Insights

Documentation ¶

Index ¶

func AddToSet(field string, value interface{}) bson.M
func Compose(elements ...bson.DocElem) bson.M
func FromID(id string) bson.M
func Insert(ctx context.Context, col *mgo.Collection, entity interface{}) error
func PipeList(ctx context.Context, col *mgo.Collection, pipeline []bson.M, ...) error
func PipeOne(ctx context.Context, col *mgo.Collection, pipeline []bson.M, ...) error
func QueryCount(ctx context.Context, col *mgo.Collection, criteria interface{}, ...) error
func QueryList(ctx context.Context, col *mgo.Collection, criteria interface{}, ...) error
func QueryOne(ctx context.Context, col *mgo.Collection, criteria interface{}, ...) error
func Remove(ctx context.Context, col *mgo.Collection, criteria interface{}) error
func RemoveFromSet(field string, value interface{}) bson.M
func Set(field string, value interface{}) bson.M
func Update(ctx context.Context, col *mgo.Collection, criteria interface{}, ...) error
type ContextFactory
- func CreateContextFactory(p SessionProvider, l logger.Logger) ContextFactory
type Operation
type OperationContext
- func CreateOperationContext(ctx context.Context, db string, col string) *OperationContext
type OperationExecutor
- func CreateExecutor(p SessionProvider, l logger.Logger) OperationExecutor
type Option
- func WithAuthDb(db string) Option
- func WithLogger(l logger.Logger) Option
- func WithPassword(p string) Option
- func WithTimeout(t time.Duration) Option
- func WithURL(u string) Option
- func WithUser(u string) Option
type Repository
- func (r *Repository) Create(ctx context.Context, entity interface{}) (string, error)
- func (r *Repository) Execute(ctx context.Context, o Operation) error
- func (r *Repository) Remove(ctx context.Context, id string) error
- func (r *Repository) Update(ctx context.Context, id string, op bson.M) error
type RepositoryFactory
- func CreateRepositoryFactory(db string, e OperationExecutor, l logger.Logger) *RepositoryFactory
- func (f *RepositoryFactory) CreateRepository(col string) *Repository
type Session
- func FromContext(ctx context.Context) Session
- func GetSession(providers ...SessionProvider) Session
type SessionFactory
- func CreateSessionFactory(opts ...Option) SessionFactory
type SessionProvider
- func CreateContextSessionProvider(c context.Context, l logger.Logger) SessionProvider
- func CreateCopySessionProvider(p SessionProvider, l logger.Logger) SessionProvider
- func CreateSessionProvider(f SessionFactory, l logger.Logger) SessionProvider

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddToSet ¶

func AddToSet(field string, value interface{}) bson.M

func Compose ¶

func Compose(elements ...bson.DocElem) bson.M

func FromID ¶

func FromID(id string) bson.M

func Insert ¶

func Insert(ctx context.Context, col *mgo.Collection, entity interface{}) error

Insert function

func PipeList ¶

func PipeList(ctx context.Context, col *mgo.Collection, pipeline []bson.M, entity interface{}, visit func(interface{}) error) error

PipeList function

func PipeOne ¶

func PipeOne(ctx context.Context, col *mgo.Collection, pipeline []bson.M, entity interface{}, visit func(interface{}) error) error

PipeOne function

func QueryCount ¶

func QueryCount(ctx context.Context, col *mgo.Collection, criteria interface{}, visit func(int) error) error

QueryCount function

func QueryList ¶

func QueryList(ctx context.Context, col *mgo.Collection, criteria interface{}, entity interface{}, visit func(interface{}) error) error

QueryList function

func QueryOne ¶

func QueryOne(ctx context.Context, col *mgo.Collection, criteria interface{}, entity interface{}, visit func(interface{}) error) error

QueryOne function

func Remove ¶

func Remove(ctx context.Context, col *mgo.Collection, criteria interface{}) error

Remove function

func RemoveFromSet ¶

func RemoveFromSet(field string, value interface{}) bson.M

func Set ¶

func Set(field string, value interface{}) bson.M

func Update ¶

func Update(ctx context.Context, col *mgo.Collection, criteria interface{}, entity interface{}) error

Update function

Types ¶

type ContextFactory ¶

type ContextFactory interface {
	Context(context.Context) (context.Context, error)
}

ContextFactory interface

func CreateContextFactory ¶

func CreateContextFactory(p SessionProvider, l logger.Logger) ContextFactory

CreateContextFactory instance

type Operation ¶

type Operation func(*mgo.Collection) error

Operation to be performed on mongo collection

type OperationContext ¶

type OperationContext struct {
	context.Context
	// contains filtered or unexported fields
}

OperationContext declares operation context

func CreateOperationContext ¶

func CreateOperationContext(ctx context.Context, db string, col string) *OperationContext

CreateOperationContext creates OperationContext

type OperationExecutor ¶

type OperationExecutor interface {
	Execute(*OperationContext, Operation) error
}

OperationExecutor executes operation

func CreateExecutor ¶

func CreateExecutor(p SessionProvider, l logger.Logger) OperationExecutor

CreateExecutor instance

type Option ¶

type Option func(*options)

Option initializes options properties

func WithAuthDb ¶

func WithAuthDb(db string) Option

WithAuthDb initializes authdb option

func WithLogger ¶

func WithLogger(l logger.Logger) Option

WithLogger initializes logger option

func WithPassword ¶

func WithPassword(p string) Option

WithPassword initializes password option

func WithTimeout ¶

func WithTimeout(t time.Duration) Option

WithTimeout initializes timeout

func WithURL ¶

func WithURL(u string) Option

WithURL initializes url option

func WithUser ¶

func WithUser(u string) Option

WithUser initializes user option

type Repository ¶

type Repository struct {
	logger.Logger
	// contains filtered or unexported fields
}

Repository type

func (*Repository) Create ¶

func (r *Repository) Create(ctx context.Context, entity interface{}) (string, error)

Create new document

func (*Repository) Execute ¶

func (r *Repository) Execute(ctx context.Context, o Operation) error

func (*Repository) Remove ¶

func (r *Repository) Remove(ctx context.Context, id string) error

Remove document by id

func (*Repository) Update ¶

func (r *Repository) Update(ctx context.Context, id string, op bson.M) error

Update document

type RepositoryFactory ¶

type RepositoryFactory struct {
	logger.Logger
	OperationExecutor
	// contains filtered or unexported fields
}

RepositoryFactory type

func CreateRepositoryFactory ¶

func CreateRepositoryFactory(db string, e OperationExecutor, l logger.Logger) *RepositoryFactory

CreateRepositoryFactory creates repository factory

func (*RepositoryFactory) CreateRepository ¶

func (f *RepositoryFactory) CreateRepository(col string) *Repository

CreateRepository creates new repository

type Session ¶

type Session interface {
	Session() *mgo.Session
	Close(bool)
}

func FromContext ¶

func FromContext(ctx context.Context) Session

FromContext gets mongo session from context

func GetSession ¶

func GetSession(providers ...SessionProvider) Session

type SessionFactory ¶

type SessionFactory interface {
	Session() (*mgo.Session, error)
}

SessionFactory interface

func CreateSessionFactory ¶

func CreateSessionFactory(opts ...Option) SessionFactory

CreateSessionFactory instance

type SessionProvider ¶

type SessionProvider interface {
	Provide() Session
}

SessionProvider interface

func CreateContextSessionProvider ¶

func CreateContextSessionProvider(c context.Context, l logger.Logger) SessionProvider

CreateContextSessionProvider instance

func CreateCopySessionProvider ¶

func CreateCopySessionProvider(p SessionProvider, l logger.Logger) SessionProvider

CreateCopySessionProvider instance

func CreateSessionProvider ¶

func CreateSessionProvider(f SessionFactory, l logger.Logger) SessionProvider

CreateSessionProvider instance

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL