Versions in this module Expand all Collapse all v3 v3.1.2 Feb 5, 2024 Changes in this version + func GetAPIClientBuilder(version version.TransportAPI) func(opts BuildOptions) (MetadataWrappedVersionClient, error) + func RegisterAPIClientBuilder(v version.TransportAPI, ...) + type BuildOptions struct + Logger dubboLogger.Logger + NodeProto proto.Message + type ErrResourceTypeUnsupported struct + ErrStr string + func (e ErrResourceTypeUnsupported) Error() string + type LoadReportingOptions struct + LoadStore *load.Store + type MetadataWrappedVersionClient interface + SetMetadata func(p *_struct.Struct) + 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) (resource.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 resource.ResourceType, ...) error
Go to main page