mirror of
https://github.com/drone/drone-cli.git
synced 2024-05-26 08:46:03 +02:00
45 lines
985 B
Go
45 lines
985 B
Go
package docker
|
|
|
|
// import (
|
|
// "context"
|
|
//
|
|
// "github.com/cncd/pipeline/pipeline/backend"
|
|
// )
|
|
//
|
|
// // Pool manages a pool of Docker clients.
|
|
// type Pool struct {
|
|
// queue chan (backend.Engine)
|
|
// }
|
|
//
|
|
// // NewPool returns a Pool.
|
|
// func NewPool(engines ...backend.Engine) *Pool {
|
|
// return &Pool{
|
|
// queue: make(chan backend.Engine, len(engines)),
|
|
// }
|
|
// }
|
|
//
|
|
// // Reserve requests the next available Docker client in the pool.
|
|
// func (p *Pool) Reserve(c context.Context) backend.Engine {
|
|
// select {
|
|
// case <-c.Done():
|
|
// case engine := <-p.queue:
|
|
// return engine
|
|
// }
|
|
// return nil
|
|
// }
|
|
//
|
|
// // Release releases the Docker client back to the pool.
|
|
// func (p *Pool) Release(engine backend.Engine) {
|
|
// p.queue <- engine
|
|
// }
|
|
|
|
// pool := docker.Pool(
|
|
// docker.FromEnvironmentMust(),
|
|
// docker.FromEnvironmentMust(),
|
|
// docker.FromEnvironmentMust(),
|
|
// docker.FromEnvironmentMust(),
|
|
// )
|
|
//
|
|
// client := pool.Reserve()
|
|
// defer pool.Release(client)
|