mongodb

package

v0.0.0-...-ca49f88 Latest Latest Go to latest Published: Jun 7, 2019 License: GPL-3.0 Imports: 9 Imported by: 0

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

This section is empty.

This section is empty.

This section is empty.

type MongoDB struct {
	Table string
	// contains filtered or unexported fields
}

MongoDB is a driver for simple operations over mongo replica

func New(ctx context.Context, connstring, dbname, collection string) (*MongoDB, error)

New create monogdb using connstring. Connstring should be a replica one

func NewDefault(ctx context.Context) (*MongoDB, error)

NewDefault creates mongodb from env variable MONGO_CONN

func (d MongoDB) Delete(ctx context.Context, s slt.Select) error

Delete removes object and makes sure it's version mathed

func (d MongoDB) Get(ctx context.Context, id slt.SID) (s slt.Select, found bool, err error)

Get a record

func (d MongoDB) QueryALL(ctx context.Context, max int) ([]slt.Select, error)

QueryWaiting gets items based on receive and send channels

func (d MongoDB) QueryWaiting(ctx context.Context, user string, send []string, recv []string, max int) ([]slt.Select, error)

QueryWaiting gets items based on receive and send channels

func (d MongoDB) Set(ctx context.Context, s slt.Select) (res slt.Select, conflict bool, err error)

Set simply updates a record, making sure that the versions match