discovery

var Component = &component.Component{
	Name: "cluster.discovery",
	Dependencies: component.Components{
		discoveryConfig.Component,
		grpc.Component,
	},
	PostExecute: component.StepFunc(func(container container.Container) error {
		return container.Invoke(func(
			config *discoveryConfig.Config,
			grpcConfig *grpc.Config,
			replicaConfig *managerConfig.Replica,
			delayConfig *managerConfig.Delay,
			m cluster.Manager,
			logger logger.Logger,
			closer closer.Closer,
		) (err error) {
			if len(config.Hosts) == 0 || (len(config.Hosts) == 1 && config.Hosts[0] == m.Me().GetHost()) {
				m.Me().AddRole(domain.Master)
				return
			}

			for _, host := range config.Hosts {
				if host == replicaConfig.Host {
					continue
				}

				err = m.AddPeer(manager.NewPeer(host, m.Me(), delayConfig, &grpcConfig.GrpcConfig, logger, closer))
			}

			return nil
		})
	}),
}