mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
124792a871
This leverages recent additions to libkv enabling client
authentication via TLS so the discovery back-end can be locked
down with mutual TLS. Example usage:
docker daemon [other args] \
--cluster-advertise 192.168.122.168:2376 \
--cluster-store etcd://192.168.122.168:2379 \
--cluster-store-opt kv.cacertfile=/path/to/ca.pem \
--cluster-store-opt kv.certfile=/path/to/cert.pem \
--cluster-store-opt kv.keyfile=/path/to/key.pem
Signed-off-by: Daniel Hiltgen <daniel.hiltgen@docker.com>
53 lines
1.4 KiB
Go
53 lines
1.4 KiB
Go
package discovery
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
|
|
log "github.com/Sirupsen/logrus"
|
|
)
|
|
|
|
var (
|
|
// Backends is a global map of discovery backends indexed by their
|
|
// associated scheme.
|
|
backends map[string]Backend
|
|
)
|
|
|
|
func init() {
|
|
backends = make(map[string]Backend)
|
|
}
|
|
|
|
// Register makes a discovery backend available by the provided scheme.
|
|
// If Register is called twice with the same scheme an error is returned.
|
|
func Register(scheme string, d Backend) error {
|
|
if _, exists := backends[scheme]; exists {
|
|
return fmt.Errorf("scheme already registered %s", scheme)
|
|
}
|
|
log.WithField("name", scheme).Debug("Registering discovery service")
|
|
backends[scheme] = d
|
|
return nil
|
|
}
|
|
|
|
func parse(rawurl string) (string, string) {
|
|
parts := strings.SplitN(rawurl, "://", 2)
|
|
|
|
// nodes:port,node2:port => nodes://node1:port,node2:port
|
|
if len(parts) == 1 {
|
|
return "nodes", parts[0]
|
|
}
|
|
return parts[0], parts[1]
|
|
}
|
|
|
|
// New returns a new Discovery given a URL, heartbeat and ttl settings.
|
|
// Returns an error if the URL scheme is not supported.
|
|
func New(rawurl string, heartbeat time.Duration, ttl time.Duration, clusterOpts map[string]string) (Backend, error) {
|
|
scheme, uri := parse(rawurl)
|
|
if backend, exists := backends[scheme]; exists {
|
|
log.WithFields(log.Fields{"name": scheme, "uri": uri}).Debug("Initializing discovery service")
|
|
err := backend.Initialize(uri, heartbeat, ttl, clusterOpts)
|
|
return backend, err
|
|
}
|
|
|
|
return nil, ErrNotSupported
|
|
}
|