feat: add batch inserter (#2755)

core/stores/mon/bulkinserter_test.go

@@ -25,3 +25,21 @@ func TestBulkInserter(t *testing.T) {
 		bulk.Flush()
 	})
 }
+
+func TestBatchInserter(t *testing.T) {
+	mt := mtest.New(t, mtest.NewOptions().ClientType(mtest.Mock))
+	defer mt.Close()
+
+	mt.Run("test", func(mt *mtest.T) {
+		mt.AddMockResponses(mtest.CreateSuccessResponse(bson.D{{Key: "ok", Value: 1}}...))
+		bulk, err := NewBatchInserter(createModel(mt).Collection)
+		assert.Equal(t, err, nil)
+		bulk.SetResultHandler(func(result *mongo.InsertManyResult, err error) {
+			assert.Nil(t, err)
+			assert.Equal(t, 2, len(result.InsertedIDs))
+		})
+		bulk.Insert(bson.D{{Key: "foo", Value: "bar"}})
+		bulk.Insert(bson.D{{Key: "foo", Value: "baz"}})
+		bulk.Flush()
+	})
+}