discovery

var Component = compogo.Component{
	Name: "cluster.discovery",
	Dependencies: compogo.Components{
		&discoveryConfig.Component,
		&grpc.Component,
	},
	PostExecute: compogo.StepFunc(func(container compogo.Container) error {
		return container.Invoke(func(
			config *discoveryConfig.Config,
			grpcConfig *grpc.Config,
			replicaConfig *managerConfig.Replica,
			m cluster.Manager,
			logger compogo.Logger,
			closer compogo.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(), &grpcConfig.GrpcConfig, logger.GetLogger("discovery"), closer))
				if err != nil {

					return err
				}
			}

			return nil
		})
	}),
}