Versions in this module Expand all Collapse all v3 v3.1.2 Feb 5, 2024 Changes in this version + var ErrClientClosed = perrors.New("remoting client has closed") + var ErrDestroyedInvoker = perrors.New("request Destroyed invoker") + var ErrNoReply = perrors.New("request need @response") + func BeginCount(url *common.URL, methodName string) + func CleanAllStatus() + func CurrentTimeMillis() int64 + func EndCount(url *common.URL, methodName string, elapsed int64, succeeded bool) + func GetAndRefreshState() bool + func GetInvokerHealthyStatus(invoker Invoker) bool + func RemoveInvokerUnhealthyStatus(invoker Invoker) + func RemoveUrlKeyUnhealthyStatus(key string) + func SetInvokerUnhealthyStatus(invoker Invoker) + func TryRefreshBlackList() + type BaseExporter struct + func NewBaseExporter(key string, invoker Invoker, exporterMap *sync.Map) *BaseExporter + func (de *BaseExporter) GetInvoker() Invoker + func (de *BaseExporter) Unexport() + type BaseInvoker struct + func NewBaseInvoker(url *common.URL) *BaseInvoker + func (bi *BaseInvoker) Destroy() + func (bi *BaseInvoker) GetURL() *common.URL + func (bi *BaseInvoker) Invoke(context context.Context, invocation Invocation) Result + func (bi *BaseInvoker) IsAvailable() bool + func (bi *BaseInvoker) IsDestroyed() bool + func (bi *BaseInvoker) String() string + type BaseProtocol struct + func NewBaseProtocol() BaseProtocol + func (bp *BaseProtocol) Destroy() + func (bp *BaseProtocol) Export(invoker Invoker) Exporter + func (bp *BaseProtocol) ExporterMap() *sync.Map + func (bp *BaseProtocol) Invokers() []Invoker + func (bp *BaseProtocol) Refer(url *common.URL) Invoker + func (bp *BaseProtocol) SetExporterMap(key string, exporter Exporter) + func (bp *BaseProtocol) SetInvokers(invoker Invoker) + type Exporter interface + GetInvoker func() Invoker + Unexport func() + type Invocation interface + ActualMethodName func() string + Arguments func() []interface{} + Attachments func() map[string]interface{} + Attributes func() map[string]interface{} + GetAttachment func(key string) (string, bool) + GetAttachmentAsContext func() context.Context + GetAttachmentInterface func(string) interface{} + GetAttachmentWithDefaultValue func(key string, defaultValue string) string + GetAttribute func(key string) (interface{}, bool) + GetAttributeWithDefaultValue func(key string, defaultValue interface{}) interface{} + Invoker func() Invoker + IsGenericInvocation func() bool + MethodName func() string + ParameterTypeNames func() []string + ParameterTypes func() []reflect.Type + ParameterValues func() []reflect.Value + Reply func() interface{} + SetAttachment func(key string, value interface{}) + SetAttribute func(key string, value interface{}) + type Invoker interface + Invoke func(context.Context, Invocation) Result + func GetBlackListInvokers(blockSize int) []Invoker + type Protocol interface + Destroy func() + Export func(invoker Invoker) Exporter + Refer func(url *common.URL) Invoker + type RPCResult struct + Attrs map[string]interface{} + Err error + Rest interface{} + func (r *RPCResult) AddAttachment(key string, value interface{}) + func (r *RPCResult) Attachment(key string, defaultValue interface{}) interface{} + func (r *RPCResult) Attachments() map[string]interface{} + func (r *RPCResult) Error() error + func (r *RPCResult) Result() interface{} + func (r *RPCResult) SetAttachments(attr map[string]interface{}) + func (r *RPCResult) SetError(err error) + func (r *RPCResult) SetResult(rest interface{}) + func (r *RPCResult) String() string + type RPCStatus struct + func GetMethodStatus(url *common.URL, methodName string) *RPCStatus + func GetURLStatus(url *common.URL) *RPCStatus + func (rpc *RPCStatus) GetActive() int32 + func (rpc *RPCStatus) GetFailed() int32 + func (rpc *RPCStatus) GetFailedElapsed() int64 + func (rpc *RPCStatus) GetFailedMaxElapsed() int64 + func (rpc *RPCStatus) GetLastRequestFailedTimestamp() int64 + func (rpc *RPCStatus) GetMaxElapsed() int64 + func (rpc *RPCStatus) GetSucceededMaxElapsed() int64 + func (rpc *RPCStatus) GetSuccessiveRequestFailureCount() int32 + func (rpc *RPCStatus) GetTotal() int32 + func (rpc *RPCStatus) GetTotalElapsed() int64 + type Result interface + AddAttachment func(string, interface{}) + Attachment func(string, interface{}) interface{} + Attachments func() map[string]interface{} + Error func() error + Result func() interface{} + SetAttachments func(map[string]interface{}) + SetError func(error) + SetResult func(interface{})
Go to main page