Versions in this module Expand all Collapse all v0 v0.1.3 Aug 2, 2022 v0.1.2 Jul 29, 2022 Changes in this version + const OpKeyDeregisterInstance + const OpKeyDiscover + const OpKeyGetConfigFile + const OpKeyInstanceHeartbeat + const OpKeyRateLimitAcquire + const OpKeyRateLimitInit + const OpKeyRateLimitMetricInit + const OpKeyRateLimitMetricReport + const OpKeyRegisterInstance + const OpKeyReportClient + const OpKeyWatchConfigFiles + func CreateHeaderContext(timeout time.Duration, headers map[string]string) (context.Context, context.CancelFunc) + func CreateHeaderContextWithReqId(timeout time.Duration, reqID string) (context.Context, context.CancelFunc) + func DeregisterRequestToProto(request *model.InstanceDeRegisterRequest) (pbInstance *namingpb.Instance) + func GetConnErrorCode(err error) int32 + func GetUpdateTaskRequestTime(updateTask *serviceUpdateTask) time.Duration + func HeartbeatRequestToProto(request *model.InstanceHeartbeatRequest) (pbInstance *namingpb.Instance) + func NetworkError(connManager network.ConnectionManager, conn *network.Connection, errCode int32, ...) model.SDKError + func NextDeRegisterInstanceReqID() string + func NextDiscoverReqID() string + func NextGetConfigFileReqID() string + func NextHeartbeatReqID() string + func NextRateLimitAcquireReqID() string + func NextRateLimitInitReqID() string + func NextRegisterInstanceReqID() string + func NextReportClientReqID() string + func NextWatchConfigFilesReqID() string + func RegisterRequestToProto(request *model.InstanceRegisterRequest) (pbInstance *namingpb.Instance) + func ReportClientRequestToProto(request *model.ReportClientRequest) (pbInstance *namingpb.Client) + type ClientFailEvent struct + type DiscoverClient interface + CloseSend func() error + Recv func() (*namingpb.DiscoverResponse, error) + Send func(*namingpb.DiscoverRequest) error + type DiscoverClientCreator func(reqId string, connection *network.Connection, timeout time.Duration) (DiscoverClient, context.CancelFunc, error) + type DiscoverConnector struct + ServiceConnector *plugin.PluginBase + func (g *DiscoverConnector) DeRegisterServiceHandler(key *model.ServiceEventKey) error + func (g *DiscoverConnector) Destroy() error + func (g *DiscoverConnector) Init(ctx *plugin.InitContext, createClient DiscoverClientCreator) + func (g *DiscoverConnector) RegisterServiceHandler(svcEventHandler *serverconnector.ServiceEventHandler) error + func (g *DiscoverConnector) StartUpdateRoutines() + func (g *DiscoverConnector) UpdateServers(key *model.ServiceEventKey) error + type StreamingClient struct + func (s *StreamingClient) CloseStream(closeSend bool) bool + func (s *StreamingClient) IsEndStream() bool
Go to main page