Configure Swarm Manager hosts

Use the ryba.swarm_primary for setting which host should be the primary swarm manager. This host will be used when rendering default DOCKER_HOST ENV variable on swarm nodes.

module.exports = (service) ->
  options = service.options

Docker Daemon options

  options.docker ?= {}
  options.docker[opt] ?= service.deps.docker.options[opt] for opt in [
    'host'
    'default_port'
    'tlscacert'
    'tlscert'
    'tlskey'
    'tlsverify'
    'conf_dir'
  ]
  options.fqdn ?= service.node.fqdn

Swarm Image

  options.image ?= 'swarm'
  options.tag ?= 'latest'
  options.conf_dir ?= '/etc/docker-swarm'
  options.iptables ?= service.deps.iptables and service.deps.iptables.options.action is 'start'

Service Discovery

Configures the docker daemon engine start options for swarm. For now only zookeeper is supported for discovery backend.

Note: The listen address and advertise adress are different:

• the advertise address configures which address CLI should use to communicate with the swarm manager's docker engine

• the listen address configures the docker engine to listen to all interfaces of the machine.

  options.cluster ?= {} options.cluster.discovery ?= 'zookeeper' options ?= {} options.name ?= 'swarm_manager' options.advertise_host ?= service.node.ip options.advertise_port ?= options.docker.default_port options.listen_host ?= '0.0.0.0' options.listen_port ?= 3376 switch options.cluster.discovery #TODO add etcd when 'zookeeper' options.cluster.zk_node ?= '/swarm-nodes' options.cluster.zk_urls ?= if service.deps.zookeeper_server then service.deps.zookeeper_server.filter( (srv) -> srv.options.config['peerType'] is 'participant').map( (srv) -> "#{srv.node.fqdn}:#{srv.options.config['clientPort']}").join ',' else options.cluster.zk_urls throw Error 'Missing options.cluster.zk_urls for discovery mode as zookeeper' unless options.cluster.zk_urls options.cluster.zk_store ?= "zk://#{options.cluster.zk_urls}#{options.cluster.zk_node}" else throw Error "Ryba does not support service discovery backend #{options.cluster.discovery} for swarm"

Docker Deamon Configuration

Pass docker start option to docker daemon to use it with swarm.

TCP Socket

Swarm manager uses the advertise address to communicate. It must be specified in the start option of the local daemon engine to enable it.

  tcp_socket = "#{service.node.fqdn}:#{options.advertise_port}"
  if service.deps.docker?.options.sockets.tcp.indexOf(tcp_socket) is -1
  then service.deps.docker.options.sockets.tcp.push tcp_socket

Swarm Cluster

This starting options should be injected to serivce.use.docker variable. For now ryba/swarm/manager modify the starting options and restart docker engine.

  # @config.docker.other_args['cluster-store'] ?= options.cluster.zk_store
  # @config.docker.other_args['cluster-advertise'] ?= "#{options.advertise_host}:#{options.advertise_port}"
  options.other_args ?= { }
  options.other_args['cluster-store'] ?= options.cluster.zk_store
  options.other_args['cluster-advertise'] ?= "#{options.advertise_host}:#{options.advertise_port}"
  service.deps.docker.options.other_args = merge service.deps.docker.options.other_args, options.other_args if service.deps.docker?

SSL

Inherits properties from local docker daemon

  options.ssl ?= merge {}, service.deps.docker.options.ssl
  if options.ssl.enabled
    options.other_args['tlscacert'] ?= service.deps.docker.options.other_args['tlscacert']
    options.other_args['tlscert'] ?= service.deps.docker.options.other_args['tlscert']
    options.other_args['tlskey'] ?= service.deps.docker.options.other_args['tlskey']
  service.deps.docker.options.daemon ?= {}
  service.deps.docker.options.daemon['cluster-advertise'] ?= options.other_args['cluster-advertise']
  service.deps.docker.options.daemon['cluster-store'] ?= options.other_args['cluster-store']

Wait

  options.wait ?= {}
  options.wait.tcp ?= for srv in service.deps.swarm_manager
    host: srv.node.fqdn
    port: srv.options.advertise_port or options.advertise_port
  options.wait_zookeeper ?=  if service.deps.zookeeper_server
  then service.deps.zookeeper_server?[0].options.wait
  else tcp: options.cluster.zk_urls.split(',').map (config) ->
    [server,port] = config.split(':')
    host: server
    port : port or 2181

Dependencies

{merge} = require '@nikitajs/core/lib/misc'