mongo

README

local run

Start docker for server:

docker run -d --name some-mongo -p 27117:27017 \
	-e MONGO_INITDB_ROOT_USERNAME=user \
	-e MONGO_INITDB_ROOT_PASSWORD=password \
	-e MONGO_INITDB_DATABASE=canondb \
	mongo

end then:

CGO_ENABLED=0;
DB0_MONGO_LOCAL_PASSWORD=password;
DB0_MONGO_LOCAL_PORT=27117;
DB0_MONGO_LOCAL_USER=user;

Documentation

Index

• Variables
• func DropCollection(ctx context.Context, Source *mongocommon.MongoSource, databaseName string, ...) error
• func InsertDocs(ctx context.Context, Source *mongocommon.MongoSource, databaseName string, ...) error
• func UpdateDocs(ctx context.Context, Source *mongocommon.MongoSource, databaseName string, ...) error
• type IncrementUpdate

Variables

var (
	SnapshotDocuments = []interface{}{
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12b7")}, {Key: "x", Value: 4}, {Key: "y", Value: 7}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12b8")}, {Key: "id", Value: bson.D{{Key: "z", Value: 2}, {Key: "incept", Value: bson.D{{Key: "y", Value: "asdf"}}}}}},
		bson.D{{Key: "_id", Value: bson.D{{Key: "x", Value: 0}, {Key: "y", Value: 1}}}},
		bson.D{{Key: "_id", Value: "omg"}},
		bson.D{{Key: "_id", Value: 8147}},
		bson.D{{Key: "_id", Value: int32(2499)}},
		bson.D{{Key: "_id", Value: int64(100502)}},
		bson.D{{Key: "_id", Value: true}},
		bson.D{{Key: "_id", Value: primitive.NewDecimal128(10101, 0)}},
		bson.D{{Key: "_id", Value: primitive.Timestamp{T: 1234526243, I: 1}}},
		bson.D{{Key: "_id", Value: primitive.NewDateTimeFromTime(time.Unix(848920, 4940200))}},
		bson.D{{Key: "_id", Value: primitive.Binary{Data: []byte("hello, world!")}}},
		bson.D{{Key: "_id", Value: primitive.Symbol("sex symbol")}},
		bson.D{{Key: "_id", Value: primitive.JavaScript("function(){ return \"omfg\" }")}, {Key: "what", Value: "is this?"}},
		bson.D{{Key: "_id", Value: primitive.Null{}}},
		bson.D{{Key: "_id", Value: primitive.DBPointer{DB: "dbdb", Pointer: oid("62e98ebcb28dbd2fffdf12b7")}}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12b9")}, {Key: "string", Value: "2354"}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c0")}, {Key: "int", Value: 402}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c1")}, {Key: "double", Value: 1.27}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c3")}, {Key: "timestamp", Value: primitive.Timestamp{
			T: 222,
			I: 1188888811,
		}}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c4")}, {Key: "nil", Value: nil}},
	}
	// this piece is valid only for repackable hetero transfer
	ExtraSnapshotDocuments = []interface{}{
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12b4")}, {Key: "nan", Value: math.NaN()}, {Key: "inf+", Value: math.Inf(1)}, {Key: "inf-", Value: math.Inf(-1)}},
	}
	IncrementDocuments = []interface{}{
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c5")}, {Key: "s", Value: 1}, {Key: "t", Value: 2}},
		bson.D{{Key: "_id", Value: bson.D{{Key: "u", Value: 8}, {Key: "v", Value: 9}}}},
		bson.D{{Key: "_id", Value: "woof"}},
		bson.D{{Key: "_id", Value: 123}},
		bson.D{{Key: "_id", Value: int32(8440)}},
		bson.D{{Key: "_id", Value: int64(100503)}},
		bson.D{{Key: "_id", Value: false}},
		bson.D{{Key: "_id", Value: primitive.NewDecimal128(10101, 1)}},
		bson.D{{Key: "_id", Value: primitive.Timestamp{T: 1234526243, I: 2}}},
		bson.D{{Key: "_id", Value: primitive.NewDateTimeFromTime(time.Unix(74271040, 412))}},
		bson.D{{Key: "_id", Value: primitive.Binary{Data: []byte("Привет, мир!")}}},
		bson.D{{Key: "_id", Value: primitive.Symbol("no homo 🍆")}},
		bson.D{{Key: "_id", Value: primitive.DBPointer{DB: "ddbb", Pointer: oid("62e98ebcb28dbd2fffdf12c4")}}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c6")}, {Key: "id", Value: "x"}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c7")}, {Key: "id", Value: oid("62e98ebcb28dbd2fffdf12ba")}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c8")}, {Key: "id", Value: primitive.JavaScript("function(){}")}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12c9")}, {Key: "decimal", Value: primitive.NewDecimal128(243994, 912994009199)}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12ca")}, {Key: "string", Value: "3"}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12cb")}, {Key: "int", Value: 5}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12cc")}, {Key: "double", Value: 2.56}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12ce")}, {Key: "timestamp", Value: primitive.Timestamp{
			T: 5555555,
			I: 333,
		}}},
		bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12cf")}, {Key: "nil", Value: primitive.Null{}}},
	}
	// Update existing
	IncrementUpdates = []IncrementUpdate{
		{
			Filter: bson.D{{Key: "_id", Value: "omg"}},
			Update: bson.D{{Key: "$set", Value: bson.D{{Key: "_id", Value: "omg"}, {Key: "omgval", Value: 44}}}},
		},
		{
			Filter: bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12b7")}},
			Update: bson.D{{Key: "$set", Value: bson.D{{Key: "_id", Value: oid("62e98ebcb28dbd2fffdf12b7")}, {Key: "x", Value: 29}}}},
		},
	}
)

Functions

func DropCollection

func DropCollection(ctx context.Context, Source *mongocommon.MongoSource, databaseName string, collectionName string) error

func InsertDocs

func InsertDocs(ctx context.Context, Source *mongocommon.MongoSource, databaseName string, collectionName string, docs ...any) error

func UpdateDocs

func UpdateDocs(ctx context.Context, Source *mongocommon.MongoSource, databaseName string, collectionName string, docs ...IncrementUpdate) error

Types

type IncrementUpdate

type IncrementUpdate struct{ Filter, Update interface{} }