Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 Changes in this version + type AddLocalityOptions struct + Health []corepb.HealthStatus + Weight []uint32 + type CDSUpdate struct + EnableLRS bool + ServiceName string + type Client struct + func New(opts Options) (*Client, error) + func (c *Client) Close() + func (c *Client) ReportLoad(server string, clusterName string, loadStore lrs.Store) func() + func (c *Client) WatchCluster(clusterName string, cdsCb func(CDSUpdate, error)) (cancel func()) + func (c *Client) WatchEndpoints(clusterName string, edsCb func(*EDSUpdate, error)) (cancel func()) + func (c *Client) WatchService(serviceName string, callback func(ServiceUpdate, error)) (cancel func()) + type ClusterLoadAssignmentBuilder struct + func NewClusterLoadAssignmentBuilder(clusterName string, dropPercents []uint32) *ClusterLoadAssignmentBuilder + func (clab *ClusterLoadAssignmentBuilder) AddLocality(subzone string, weight uint32, priority uint32, addrsWithPort []string, ...) + func (clab *ClusterLoadAssignmentBuilder) Build() *xdspb.ClusterLoadAssignment + type EDSUpdate struct + Drops []OverloadDropConfig + Localities []Locality + func ParseEDSRespProto(m *xdspb.ClusterLoadAssignment) (*EDSUpdate, error) + func ParseEDSRespProtoForTesting(m *xdspb.ClusterLoadAssignment) *EDSUpdate + type Endpoint struct + Address string + HealthStatus EndpointHealthStatus + Weight uint32 + type EndpointHealthStatus int32 + const EndpointHealthStatusDegraded + const EndpointHealthStatusDraining + const EndpointHealthStatusHealthy + const EndpointHealthStatusTimeout + const EndpointHealthStatusUnhealthy + const EndpointHealthStatusUnknown + type Locality struct + Endpoints []Endpoint + ID internal.Locality + Priority uint32 + Weight uint32 + type Options struct + Config bootstrap.Config + DialOpts []grpc.DialOption + TargetName string + type OverloadDropConfig struct + Category string + Denominator uint32 + Numerator uint32 + type ServiceUpdate struct + Cluster string