new feature: client-side load balancer.
Pre-release
Pre-release
Support client-side load balancer:
brokers := make(chan []string, 0)
cli, err := rsocket.Connect().Transports(brokers, WithInitTransports("tcp://127.0.0.1:7878", "tcp://127.0.0.1:7879")).Start()
......
go func() {
// simulate updating newest brokers.
brokers <- []string{"tcp://127.0.0.1:7877", "tcp://127.0.0.1:7878", "tcp://127.0.0.1:7879"}
}