mongowrapper

package module
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 1, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

README

gomongowrapper

MongoDB Go wrapper source code

Table of contents

End to end example

With a MongoDB server running at "localhost:27017" and running this example with Go

package main

import (
	"context"
	"github.com/while-loop/gomongowrapper"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo/options"
	"go.opentelemetry.io/otel/api/global"
	"go.opentelemetry.io/otel/exporter/trace/stackdriver"
	sdktrace "go.opentelemetry.io/otel/sdk/trace"
	"log"
	"time"
)

func main() {
	// Enabling the OpenTelemetry exporter.
	// Just using Stackdriver since it has both Tracing and Metrics
	// and is easy to whip up. Add your desired one here.
    sde, err := stackdriver.NewExporter(
        stackdriver.WithProjectID("census-demos"),
    )
    if err != nil {
        log.Fatalf("Failed to create Stackdriver exporter: %v", err)
    }
    tp, err := sdktrace.NewProvider(
        sdktrace.WithConfig(sdktrace.Config{DefaultSampler: sdktrace.AlwaysSample()}),
        sdktrace.WithSyncer(sde),
    )
    global.SetTraceProvider(tp)

	defer func() {
		<-time.After(2 * time.Minute)
	}()

	tracer := global.TraceProvider().Tracer("example-tracer")

	// Start a span like your application would start one.
	ctx, span := tracer.Start(context.Background(), "Fetch")
	defer span.End()

	// Now for the mongo connections, using the context
	// with the span in it for continuity.
	client, err := mongowrapper.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"))
	if err != nil {
		log.Fatalf("Failed to create the new client: %v", err)
	}
	if err := client.Connect(ctx); err != nil {
		log.Fatalf("Failed to open client connection: %v", err)
	}
	defer client.Disconnect(ctx)
	coll := client.Database("the_db").Collection("music")

	q := bson.M{"name": "Examples"}
	cur, err := coll.Find(ctx, q)
	if err != nil {
		log.Fatalf("Find error: %v", err)
	}

	for cur.Next(ctx) {
		elem := make(map[string]int)
		if err := cur.Decode(elem); err != nil {
			log.Printf("Decode error: %v", err)
			continue
		}
		log.Printf("Got result: %v\n", elem)
	}
	log.Print("Done iterating")

	_, err = coll.DeleteMany(ctx, q)
	if err != nil {
		log.Fatalf("Failed to delete: %v", err)
	}
}

Traces

Documentation

Index

Constants

View Source 
const (
	TracerName = "go.mongodb.org/mongo-driver"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type WrappedClient 

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

func Connect 

func Connect(ctx context.Context, opts ...*options.ClientOptions) (*WrappedClient, error)

func NewClient 

func NewClient(opts ...*options.ClientOptions) (*WrappedClient, error)

func (*WrappedClient) Client 

func (wc *WrappedClient) Client() *mongo.Client

func (*WrappedClient) Connect 

func (wc *WrappedClient) Connect(ctx context.Context) error

func (*WrappedClient) Database 

func (wc *WrappedClient) Database(name string, opts ...*options.DatabaseOptions) *WrappedDatabase

func (*WrappedClient) Disconnect 

func (wc *WrappedClient) Disconnect(ctx context.Context) error

func (*WrappedClient) ListDatabaseNames 

func (wc *WrappedClient) ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)

func (*WrappedClient) ListDatabases 

func (wc *WrappedClient) ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)

func (*WrappedClient) NumberSessionsInProgress 

func (wc *WrappedClient) NumberSessionsInProgress() int

func (*WrappedClient) Ping 

func (wc *WrappedClient) Ping(ctx context.Context, rp *readpref.ReadPref) error

func (*WrappedClient) StartSession 

func (wc *WrappedClient) StartSession(opts ...*options.SessionOptions) (mongo.Session, error)

func (*WrappedClient) UseSession 

func (wc *WrappedClient) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error

func (*WrappedClient) UseSessionWithOptions 

func (wc *WrappedClient) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, fn func(mongo.SessionContext) error) error

func (*WrappedClient) Watch 

func (wc *WrappedClient) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

type WrappedCollection 

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

func (*WrappedCollection) Aggregate 

func (wc *WrappedCollection) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)

func (*WrappedCollection) BulkWrite 

func (wc *WrappedCollection) BulkWrite(ctx context.Context, models []mongo.WriteModel, opts ...*options.BulkWriteOptions) (*mongo.BulkWriteResult, error)

func (*WrappedCollection) Clone 

func (wc *WrappedCollection) Clone(opts ...*options.CollectionOptions) (*mongo.Collection, error)

func (*WrappedCollection) Collection 

func (wc *WrappedCollection) Collection() *mongo.Collection

func (*WrappedCollection) Count 

func (wc *WrappedCollection) Count(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

func (*WrappedCollection) CountDocuments 

func (wc *WrappedCollection) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

func (*WrappedCollection) Database 

func (wc *WrappedCollection) Database() *mongo.Database

func (*WrappedCollection) DeleteMany 

func (wc *WrappedCollection) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

func (*WrappedCollection) DeleteOne 

func (wc *WrappedCollection) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

func (*WrappedCollection) Distinct 

func (wc *WrappedCollection) Distinct(ctx context.Context, fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error)

func (*WrappedCollection) Drop 

func (wc *WrappedCollection) Drop(ctx context.Context) error

func (*WrappedCollection) EstimatedDocumentCount 

func (wc *WrappedCollection) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

func (*WrappedCollection) Find 

func (wc *WrappedCollection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error)

func (*WrappedCollection) FindOne 

func (wc *WrappedCollection) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult

func (*WrappedCollection) FindOneAndDelete 

func (wc *WrappedCollection) FindOneAndDelete(ctx context.Context, filter interface{}, opts ...*options.FindOneAndDeleteOptions) *mongo.SingleResult

func (*WrappedCollection) FindOneAndReplace 

func (wc *WrappedCollection) FindOneAndReplace(ctx context.Context, filter, replacement interface{}, opts ...*options.FindOneAndReplaceOptions) *mongo.SingleResult

func (*WrappedCollection) FindOneAndUpdate 

func (wc *WrappedCollection) FindOneAndUpdate(ctx context.Context, filter, update interface{}, opts ...*options.FindOneAndUpdateOptions) *mongo.SingleResult

func (*WrappedCollection) Indexes 

func (wc *WrappedCollection) Indexes() mongo.IndexView

func (*WrappedCollection) InsertMany 

func (wc *WrappedCollection) InsertMany(ctx context.Context, documents []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)

func (*WrappedCollection) InsertOne 

func (wc *WrappedCollection) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

func (*WrappedCollection) Name 

func (wc *WrappedCollection) Name() string

func (*WrappedCollection) ReplaceOne 

func (wc *WrappedCollection) ReplaceOne(ctx context.Context, filter, replacement interface{}, opts ...*options.ReplaceOptions) (*mongo.UpdateResult, error)

func (*WrappedCollection) UpdateMany 

func (wc *WrappedCollection) UpdateMany(ctx context.Context, filter, replacement interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

func (*WrappedCollection) UpdateOne 

func (wc *WrappedCollection) UpdateOne(ctx context.Context, filter, replacement interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

func (*WrappedCollection) Watch 

func (wc *WrappedCollection) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

type WrappedDatabase 

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

func (*WrappedDatabase) Aggregate 

func (wd *WrappedDatabase) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)

func (*WrappedDatabase) Client 

func (wd *WrappedDatabase) Client() *WrappedClient

func (*WrappedDatabase) Collection 

func (wd *WrappedDatabase) Collection(name string, opts ...*options.CollectionOptions) *WrappedCollection

func (*WrappedDatabase) Database 

func (wd *WrappedDatabase) Database() *mongo.Database

func (*WrappedDatabase) Drop 

func (wd *WrappedDatabase) Drop(ctx context.Context) error

func (*WrappedDatabase) ListCollectionNames 

func (wd *WrappedDatabase) ListCollectionNames(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) ([]string, error)

func (*WrappedDatabase) ListCollections 

func (wd *WrappedDatabase) ListCollections(ctx context.Context, filter interface{}, opts ...*options.ListCollectionsOptions) (*mongo.Cursor, error)

func (*WrappedDatabase) Name 

func (wd *WrappedDatabase) Name() string

func (*WrappedDatabase) ReadConcern 

func (wd *WrappedDatabase) ReadConcern() *readconcern.ReadConcern

func (*WrappedDatabase) ReadPreference 

func (wd *WrappedDatabase) ReadPreference() *readpref.ReadPref

func (*WrappedDatabase) RunCommand 

func (wd *WrappedDatabase) RunCommand(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) *mongo.SingleResult

func (*WrappedDatabase) RunCommandCursor 

func (wd *WrappedDatabase) RunCommandCursor(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) (*mongo.Cursor, error)

func (*WrappedDatabase) Watch 

func (wd *WrappedDatabase) Watch(ctx context.Context, pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

func (*WrappedDatabase) WriteConcern 

func (wd *WrappedDatabase) WriteConcern() *writeconcern.WriteConcern

type WrappedSession 

type WrappedSession struct {
	mongo.Session
}

func (*WrappedSession) AbortTransaction 

func (ws *WrappedSession) AbortTransaction(ctx context.Context) error

func (*WrappedSession) AdvanceClusterTime 

func (ws *WrappedSession) AdvanceClusterTime(br bson.Raw) error

func (*WrappedSession) AdvanceOperationTime 

func (ws *WrappedSession) AdvanceOperationTime(pt *primitive.Timestamp) error

func (*WrappedSession) Client 

func (ws *WrappedSession) Client() *mongo.Client

func (*WrappedSession) ClusterTime 

func (ws *WrappedSession) ClusterTime() bson.Raw

func (*WrappedSession) CommitTransaction 

func (ws *WrappedSession) CommitTransaction(ctx context.Context) error

func (*WrappedSession) EndSession 

func (ws *WrappedSession) EndSession(ctx context.Context)

func (*WrappedSession) OperationTime 

func (ws *WrappedSession) OperationTime() *primitive.Timestamp

func (*WrappedSession) StartTransaction 

func (ws *WrappedSession) StartTransaction(topts ...*options.TransactionOptions) error

func (*WrappedSession) WithTransaction 

func (ws *WrappedSession) WithTransaction(ctx context.Context, fn func(sessCtx mongo.SessionContext) (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.