Skip to content

new feature: client-side load balancer.

Pre-release
Pre-release
Compare
Choose a tag to compare
@jjeffcaii jjeffcaii released this 27 Apr 13:14
· 154 commits to master since this release
7bf912c

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"}
}