Method NextServer

roundrobin/roundrobin.go:47–59

NextServer returns the next server in the round-robin algorithm. If there are no servers available, it returns nil. The server selection is based on an atomic counter that increments with each call. The selected server is determined by calculating the index using the modulo operation. This method is

()

// The selected server is determined by calculating the index using the modulo operation.
// This method is thread-safe using atomic operations and read locks.
func (r *roundrobin) NextServer() *proxy.Proxy {
	index := atomic.AddUint32(&r.next, 1)

	r.RLock()
	count := uint32(len(r.servers))
	if count == 0 {
		r.RUnlock()
		return nil
	}
	server := r.servers[(index-1)%count]
	r.RUnlock()
	return server
}

// AddServers adds the given servers to the roundrobin load balancer.
// It takes a variadic parameter of type *proxy.Proxy, representing the servers to be added.