balancer

type Balancer struct {
	// contains filtered or unexported fields
}

type Builder interface {
	balancer.Builder      // Interface for building balancers.
	balancer.ConfigParser // Interface for parsing balancer configurations.
}

type ClientConnWrapper interface {
	// NewSubConn creates a new SubConn with the specified addresses and options.
	NewSubConn([]resolver.Address, balancer.NewSubConnOptions) (balancer.SubConn, error)
	// RemoveSubConn removes the specified SubConn.
	RemoveSubConn(balancer.SubConn)
	// UpdateAddresses updates the addresses for the specified SubConn.
	UpdateAddresses(balancer.SubConn, []resolver.Address)
	// UpdateState updates the overall connectivity state of the balancer.
	UpdateState(balancer.State)
	// ResolveNow triggers an immediate resolution of the target.
	ResolveNow(resolver.ResolveNowOptions)
	// Target returns the target URI of the connection.
	Target() string
	// MetricsRecorder returns the metrics recorder for the connection.
	MetricsRecorder() estats.MetricsRecorder
}

type Config struct {
	serviceconfig.LoadBalancingConfig `json:"-"` // Embedding the base load balancing config.
	PartitionCount                    int        `json:"partitionCount,omitempty"`    // Number of partitions in the consistent hash ring.
	ReplicationFactor                 int        `json:"replicationFactor,omitempty"` // Number of replicas for each member.
	Load                              float64    `json:"load,omitempty"`              // Load factor for balancing traffic.
	PickerWidth                       int        `json:"pickerWidth,omitempty"`       // Number of closest members to consider in the picker.
}

type ConsistentMember struct {
	balancer.SubConn // Embedded SubConn for the gRPC connection.
	// contains filtered or unexported fields
}