cfcomponent

var DefaultYagnatsClientProvider = func(logger *gosteno.Logger, c *Config) (natsClient yagnats.NATSClient, err error) {
	members := []yagnats.ConnectionProvider{}
	for _, natsHost := range c.NatsHosts {
		members = append(members, &yagnats.ConnectionInfo{
			Addr:     fmt.Sprintf("%s:%d", natsHost, c.NatsPort),
			Username: c.NatsUser,
			Password: c.NatsPass,
		})
	}

	connectionInfo := &yagnats.ConnectionCluster{
		Members: members,
	}
	natsClient = yagnats.NewClient()
	err = natsClient.Connect(connectionInfo)
	if err != nil {
		return nil, errors.New(fmt.Sprintf("Could not connect to NATS: %v", err.Error()))
	}
	return natsClient, nil
}

var Logger *gosteno.Logger