Versions in this module Expand all Collapse all v1 v1.51.4 Oct 3, 2022 Changes in this version + func GetAPIClientBuilder(version version.TransportAPI) func(opts BuildOptions) (VersionedClient, error) + func RegisterAPIClientBuilder(v version.TransportAPI, f func(opts BuildOptions) (VersionedClient, error)) + type BuildOptions struct + Logger *grpclog.PrefixLogger + NodeProto proto.Message + type ErrResourceTypeUnsupported struct + ErrStr string + func (e ErrResourceTypeUnsupported) Error() string + type LoadReportingOptions struct + LoadStore *load.Store + type VersionedClient interface + HandleLoadStatsResponse func(s grpc.ClientStream) (clusters []string, _ time.Duration, _ error) + NewLoadStatsStream func(ctx context.Context, cc *grpc.ClientConn) (grpc.ClientStream, error) + NewStream func(ctx context.Context, cc *grpc.ClientConn) (grpc.ClientStream, error) + ParseResponse func(r proto.Message) (xdsresource.ResourceType, []*anypb.Any, string, string, error) + RecvResponse func(s grpc.ClientStream) (proto.Message, error) + SendFirstLoadStatsRequest func(s grpc.ClientStream) error + SendLoadStatsRequest func(s grpc.ClientStream, loads []*load.Data) error + SendRequest func(s grpc.ClientStream, resourceNames []string, rType xdsresource.ResourceType, ...) error
Go to main page