Documentation ¶
Index ¶
- func BeginCount(url common.URL, methodName string)
- func CleanAllStatus()
- func CurrentTimeMillis() int64
- func EndCount(url common.URL, methodName string, elapsed int64, succeeded bool)
- type BaseExporter
- type BaseInvoker
- type 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
- type Invocation
- type Invoker
- type Protocol
- type RPCResult
- func (r *RPCResult) AddAttachment(key, value string)
- func (r *RPCResult) Attachment(key, defaultValue string) string
- func (r *RPCResult) Attachments() map[string]string
- func (r *RPCResult) Error() error
- func (r *RPCResult) Result() interface{}
- func (r *RPCResult) SetAttachments(attr map[string]string)
- func (r *RPCResult) SetError(err error)
- func (r *RPCResult) SetResult(rest interface{})
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BaseExporter ¶
type BaseExporter struct {
// contains filtered or unexported fields
}
BaseExporter ...
func NewBaseExporter ¶
func NewBaseExporter(key string, invoker Invoker, exporterMap *sync.Map) *BaseExporter
NewBaseExporter ...
type BaseInvoker ¶
type BaseInvoker struct {
// contains filtered or unexported fields
}
BaseInvoker ...
func (*BaseInvoker) Invoke ¶
func (bi *BaseInvoker) Invoke(context context.Context, invocation Invocation) Result
Invoke ...
type BaseProtocol ¶
type BaseProtocol struct {
// contains filtered or unexported fields
}
BaseProtocol ...
func (*BaseProtocol) Destroy ¶
func (bp *BaseProtocol) Destroy()
Destroy will destroy all invoker and exporter, so it only is called once.
func (*BaseProtocol) SetExporterMap ¶
func (bp *BaseProtocol) SetExporterMap(key string, exporter Exporter)
SetExporterMap ...
func (*BaseProtocol) SetInvokers ¶
func (bp *BaseProtocol) SetInvokers(invoker Invoker)
SetInvokers ...
type Exporter ¶
type Exporter interface { GetInvoker() Invoker Unexport() }
Exporter wrapping invoker
type Invocation ¶
type Invocation interface { MethodName() string ParameterTypes() []reflect.Type ParameterValues() []reflect.Value Arguments() []interface{} Reply() interface{} Attachments() map[string]string AttachmentsByKey(string, string) string Invoker() Invoker }
Invocation ...
type Protocol ¶
type Protocol interface { Export(invoker Invoker) Exporter Refer(url common.URL) Invoker Destroy() }
Protocol Extension - protocol
type RPCResult ¶
RPCResult ...
func (*RPCResult) AddAttachment ¶
AddAttachment ...
func (*RPCResult) Attachment ¶
Attachment ...
func (*RPCResult) SetAttachments ¶
SetAttachments ...
type RPCStatus ¶ added in v1.4.0
type RPCStatus struct {
// contains filtered or unexported fields
}
RPCStatus ...
func GetMethodStatus ¶ added in v1.4.0
GetMethodStatus ...
func (*RPCStatus) GetFailedElapsed ¶ added in v1.4.0
GetFailedElapsed ...
func (*RPCStatus) GetFailedMaxElapsed ¶ added in v1.4.0
GetFailedMaxElapsed ...
func (*RPCStatus) GetLastRequestFailedTimestamp ¶ added in v1.4.0
GetLastRequestFailedTimestamp ...
func (*RPCStatus) GetMaxElapsed ¶ added in v1.4.0
GetMaxElapsed ...
func (*RPCStatus) GetSucceededMaxElapsed ¶ added in v1.4.0
GetSucceededMaxElapsed ...
func (*RPCStatus) GetSuccessiveRequestFailureCount ¶ added in v1.4.0
GetSuccessiveRequestFailureCount ...
func (*RPCStatus) GetTotalElapsed ¶ added in v1.4.0
GetTotalElapsed ...
Directories ¶
Path | Synopsis |
---|---|
dubbo3
|
|
protoc-gen-dubbo3
Module
|
|
internal
just for test, never use internal for production.
|
just for test, never use internal for production. |
protoc-gen-dubbo/plugin/dubbo
Package dubbo plugin for protobuf.
|
Package dubbo plugin for protobuf. |
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.