gopool

KO | EN

gitlite — search

#javascript #python #hacktoberfest #typescript #llm #go #deep-learning #linux #docker #java #cli #security #openai #open-source

(★ 83)

go连接池、Golang连接池、By Golang realize distributed common connection pool.

파일 탐색기

최종 버전 다운로드 (.zip)

- copool.go
- copool_test.go
- example.go
- rediscli.go
- rediscli_test.go
.gitignore
chanconnpool.go
interfaces.go
LICENSE
README.md
types.go

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# gopool
* By Golang realize distributed common connection pool.
* Golang分布式的连接池，协程池，内含redis client连接池实现

* go get github.com/aosen/gopool

## example
```
var addrs []string = []string{"127.0.0.1:8000", "127.0.0.1:8001", "127.0.0.1:8002", "127.0.0.1:8003"}

var epool Pooler

func InitExpPool() (err error) {
	if epool == nil {
		epool, err = NewChanConnPool(&ConnPoolReq{
			Addrs: addrs,
			Create: func(addr string, timeout time.Duration) (interface{}, error) {
				cli, err := net.DialTimeout("tcp", addr, timeout)
				return cli, err
			},
			IsOpen: func(cli interface{}) bool {
				if cli != nil {
					return true
				}
				return false
			},
			Down: func(cli interface{}) {
				c := cli.(net.Conn)
				c.Close()
			},
		})
		return
	}
	return
}

func Get() (cli net.Conn, err error) {
	if epool == nil {
		err = errors.New("no init epool.")
		return
	}
	cli, err = epool.Get()
	return
}

func Put(cli net.Conn, safe bool) {
	if epool == nil {
		err := errors.New("no init epool.")
		return
	}
	epool.Put(cli, safe)
}

func GetHealthy() map[string]bool {
	if epool == nil {
		return nil
	}
	return epool.GetHealthy()
}

func GetConnCount() map[string]int {
	if epool == nil {
		return nil
	}
	return epool.GetConnCount()
}
```

gopool

파일 탐색기

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

gopool

파일 탐색기

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README