mgo

package

v0.12.0 Latest Latest Go to latest Published: Sep 29, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/spaceuptech/space-cloud

Links

Open Source Insights

Documentation ¶

Index ¶

type Mongo
- func Init(enabled bool, connection string) (mongoStub *Mongo, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Mongo ¶

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

Mongo holds the mongo session

func Init ¶

func Init(enabled bool, connection string) (mongoStub *Mongo, err error)

Init initialises a new mongo instance

func (*Mongo) Aggregate ¶

func (m *Mongo) Aggregate(ctx context.Context, project, col string, req *model.AggregateRequest) (interface{}, error)

Aggregate performs a mongo db pipeline aggregation

func (*Mongo) Batch ¶

func (m *Mongo) Batch(ctx context.Context, project string, txRequest *model.BatchRequest) error

Batch performs the provided operations in a single Batch

func (*Mongo) Close ¶

func (m *Mongo) Close() error

Close gracefully the Mongo client

func (*Mongo) Create ¶

func (m *Mongo) Create(ctx context.Context, project, col string, req *model.CreateRequest) error

Create inserts a document (or multiple when op is "all") into the database

func (*Mongo) Delete ¶

func (m *Mongo) Delete(ctx context.Context, project, col string, req *model.DeleteRequest) error

Delete removes the document(s) from the database which match the condition

func (*Mongo) DescribeTable ¶ added in v0.12.0

func (m *Mongo) DescribeTable(ctx context.Context, project, dbType, col string) ([]utils.FieldType, []utils.ForeignKeysType, error)

DescribeTable return a structure of sql table

func (*Mongo) GetCollections ¶ added in v0.12.0

func (m *Mongo) GetCollections(ctx context.Context, project string) ([]utils.DatabaseCollections, error)

GetCollections returns collection / tables name of specified database

func (*Mongo) GetDBType ¶

func (m *Mongo) GetDBType() utils.DBType

GetDBType returns the dbType of the crud block

func (*Mongo) IsClientSafe ¶ added in v0.12.0

func (m *Mongo) IsClientSafe() error

IsClientSafe checks whether database is enabled and connected

func (*Mongo) RawBatch ¶ added in v0.12.0

func (m *Mongo) RawBatch(ctx context.Context, queries []string) error

RawBatch performs a batch operation for schema creation NOTE: not to be exposed externally

func (*Mongo) RawExec ¶ added in v0.12.0

func (m *Mongo) RawExec(ctx context.Context, query string) error

RawExec performs an operation for schema creation NOTE: not to be exposed externally

func (*Mongo) Read ¶

func (m *Mongo) Read(ctx context.Context, project, col string, req *model.ReadRequest) (interface{}, error)

Read querys document(s) from the database

func (*Mongo) Update ¶

func (m *Mongo) Update(ctx context.Context, project, col string, req *model.UpdateRequest) error

Update updates the document(s) which match the condition provided.

Source Files ¶

View all Source files

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