Function runOplog

oplog/change_stream_event_test.go:370–392

(data *PartialLog)

}

func runOplog(data *PartialLog) error {
	ns := strings.Split(data.Namespace, ".")
	switch data.Operation {
	case "i":
		_, err := client.Database(ns[0]).Collection(ns[1]).InsertOne(context.Background(), data.Object)
		return err
	case "d":
		_, err := client.Database(ns[0]).Collection(ns[1]).DeleteOne(context.Background(), data.Object)
		return err
	case "u":
		_, err := client.Database(ns[0]).Collection(ns[1]).UpdateOne(context.Background(), data.Query, data.Object)
		return err
	case "c":
		operation, found := ExtraCommandName(data.Object)
		if !found {
			return fmt.Errorf("extract command failed")
		}

		return RunCommand(ns[0], operation, data, client)
	default:
		return fmt.Errorf("unknown op[%v]", data.Operation)
	}
}

func runByte(input []byte) error {
	data, err := ConvertEvent2Oplog(input, false)