Jialin Wu linnv

## rabbitmq-demo.go
package main

import (
	"flag"
	"fmt"
	"log"
	"strconv"
	"time"

	"github.com/streadway/amqp"

## go.mod
module rtpdemo

go 1.18

require (
	github.com/go-audio/audio v1.0.0
	github.com/go-audio/wav v1.1.0
	github.com/jart/gosip v0.0.0-20220818224804-29801cedf805
	github.com/linnv/logx v1.3.5
	github.com/zaf/g711 v0.0.0-20220109202201-cf0017bf0359

## es-mapping-date-detect-issue.sh
#!/usr/bin/env bash

getAddr()
{
cat <<EOF
http://elastic:Qnzs2020@172.26.50.105:9230
EOF
}

# curl -XDELETE "$(getAddr)/mappingdetectdemo?pretty"

## leaderByEtcd.go
package demo

import (
	"context"
	"log"
	"math/rand"
	"path"
	"time"

	clientv3 "github.com/coreos/etcd/clientv3"

## mergesort.go
package main

import (
	"sync"
)

const parallelBySliceLength = 1 << 10 * 3

func MergeSortLoop(src []int64) {
	srcReadOnly := make([]int64, len(src))//update only in merge stage

## qps-rate-limiting.go
package main

import (
        "flag"
        "fmt"
        "log"
        "net/http"
        "os"
        "os/signal"
        "time"

## adding-version.go
package main

import (
	"flag"
	"os"
	"strings"
)

var (
	Version   = "1.0.0"

## mongodb-multi-collection-query-by-go.go
// import (
// 	"fmt"
// 	"time"
//
// 	mgo "gopkg.in/mgo.v2"
// 	"gopkg.in/mgo.v2/bson"
// )

// ``` cmd in mongo shell
// 	db.Slot.aggregate([

## redis-sub-pub-golang-demo.go
package main

import (
	"encoding/json"
	"fmt"
	"log"
	"time"

	"gopkg.in/redis.v2"
)

## dockerctl.sh
#!/usr/bin/env bash

cids=`docker ps -a | awk 'FNR>1 {print $1}'`

function stop() {
for v in $cids
do
	echo "stop "$v
	docker stop $v
done
	package main

	import (
	"flag"
	"fmt"
	"log"
	"strconv"
	"time"

	"github.com/streadway/amqp"
	module rtpdemo

	go 1.18

	require (
	github.com/go-audio/audio v1.0.0
	github.com/go-audio/wav v1.1.0
	github.com/jart/gosip v0.0.0-20220818224804-29801cedf805
	github.com/linnv/logx v1.3.5
	github.com/zaf/g711 v0.0.0-20220109202201-cf0017bf0359
	#!/usr/bin/env bash

	getAddr()
	{
	cat <<EOF
	http://elastic:Qnzs2020@172.26.50.105:9230
	EOF
	}

	# curl -XDELETE "$(getAddr)/mappingdetectdemo?pretty"
	package demo

	import (
	"context"
	"log"
	"math/rand"
	"path"
	"time"

	clientv3 "github.com/coreos/etcd/clientv3"
	package main

	import (
	"sync"
	)

	const parallelBySliceLength = 1 << 10 * 3

	func MergeSortLoop(src []int64) {
	srcReadOnly := make([]int64, len(src))//update only in merge stage
	// import (
	// "fmt"
	// "time"
	//
	// mgo "gopkg.in/mgo.v2"
	// "gopkg.in/mgo.v2/bson"
	// )

	// ``` cmd in mongo shell
	// db.Slot.aggregate([
	package main

	import (
	"encoding/json"
	"fmt"
	"log"
	"time"

	"gopkg.in/redis.v2"
	)
	#!/usr/bin/env bash

	cids=`docker ps -a \| awk 'FNR>1 {print $1}'`

	function stop() {
	for v in $cids
	do
	echo "stop "$v
	docker stop $v
	done