All uris must be reachable in case of environment creation

[Egyptmaster]

Describe the bug

Not sure if that is an expected behavior but it makes the usage of the client very hard. In case you are using multiple uris by SetUris(uris ...string) method all the hosts must be available at the point in time you create the environment with NewEnvironment.

Reproduction steps

env, err = stream.NewEnvironment(
		stream.NewEnvironmentOptions().
			SetUris([]string{"rabbitmq-streams://localhost:5552", "rabbitmq-streams://localhost:5553"}))

will return an error in case one of the uris is not accessable at point in time

Expected behavior

From the documentation I would expect to silently accept one of the hosts/uris to be not available at any point in time and automatically use randomly another one. Otherwise it is really hard in context of kubernetes/docker when I can never guarantee that all nodes are available when my service tries to start.

Additional context

No response

[Gsantomaggio]

Thank you @Egyptmaster

yes, his part can be improved:

rabbitmq-stream-go-client/pkg/stream/environment.go

Lines 51 to 76 in 202c881

	for _, parameter := range options.ConnectionParameters {
	if parameter.Uri != "" {
	u, err := url.Parse(parameter.Uri)
	if err != nil {
	return nil, err
	}
	parameter.Scheme = u.Scheme
	parameter.User = u.User.Username()
	parameter.Password, _ = u.User.Password()
	parameter.Host = u.Host
	parameter.Port = u.Port()
	if vhost := strings.TrimPrefix(u.Path, "/"); len(vhost) > 0 {
	if vhost != "/" && strings.Contains(vhost, "/") {
	return nil, errors.New("multiple segments in URI path: " + u.Path)
	}
	parameter.Vhost = vhost
	}
	}
	parameter.mergeWithDefault()
	client.broker = parameter
	}
	return &Environment{

The client should try to connect with each URI

[Gsantomaggio]

@Egyptmaster can you please try #310 ? thank you

[Egyptmaster]

Sure, but can do on Monday earliest

[Gsantomaggio]

@Egyptmaster, please let me know if you have a chance to test it so I can release the new version. Thank you

[Egyptmaster]

@Gsantomaggio sorry for late response. I recently tried the feature brach and the issue seems to be fixed 👍
thanks for the quick fix

[Gsantomaggio]

FYI: https://github.com/rabbitmq/rabbitmq-stream-go-client/releases/tag/v1.4.5