Documentation
¶
Index ¶
- func WithArguments(arguments []interface{}) option
- func WithMethodName(methodName string) option
- func WithParameterTypes(parameterTypes []reflect.Type) option
- type RPCInvocation
- func NewRPCInvocationForConsumer(methodName string, parameterTypes []reflect.Type, arguments []interface{}, ...) *RPCInvocation
- func NewRPCInvocationForProvider(methodName string, arguments []interface{}, attachments map[string]string) *RPCInvocation
- func NewRPCInvocationWithOptions(opts ...option) *RPCInvocation
- func (r *RPCInvocation) Arguments() []interface{}
- func (r *RPCInvocation) Attachments() map[string]string
- func (r *RPCInvocation) AttachmentsByKey(key string, defaultValue string) string
- func (r *RPCInvocation) CallBack() interface{}
- func (r *RPCInvocation) Invoker() protocol.Invoker
- func (r *RPCInvocation) MethodName() string
- func (r *RPCInvocation) ParameterTypes() []reflect.Type
- func (r *RPCInvocation) Reply() interface{}
- func (r *RPCInvocation) SetAttachments(key string, value string)
- func (r *RPCInvocation) SetCallBack(c interface{})
- func (r *RPCInvocation) SetInvoker() protocol.Invoker
- func (r *RPCInvocation) SetMethod(method string)
- func (r *RPCInvocation) SetReply(reply interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithArguments ¶
func WithArguments(arguments []interface{}) option
func WithMethodName ¶
func WithMethodName(methodName string) option
func WithParameterTypes ¶
Types ¶
type RPCInvocation ¶
type RPCInvocation struct {
// contains filtered or unexported fields
}
/////////////////////////// Invocation Impletment of RPC /////////////////////////// todo: is it necessary to separate fields of consumer(provider) from RPCInvocation
func NewRPCInvocationForProvider ¶
func NewRPCInvocationForProvider(methodName string, arguments []interface{}, attachments map[string]string) *RPCInvocation
func NewRPCInvocationWithOptions ¶
func NewRPCInvocationWithOptions(opts ...option) *RPCInvocation
func (*RPCInvocation) Arguments ¶
func (r *RPCInvocation) Arguments() []interface{}
func (*RPCInvocation) Attachments ¶
func (r *RPCInvocation) Attachments() map[string]string
func (*RPCInvocation) AttachmentsByKey ¶
func (r *RPCInvocation) AttachmentsByKey(key string, defaultValue string) string
func (*RPCInvocation) CallBack ¶
func (r *RPCInvocation) CallBack() interface{}
func (*RPCInvocation) Invoker ¶
func (r *RPCInvocation) Invoker() protocol.Invoker
func (*RPCInvocation) MethodName ¶
func (r *RPCInvocation) MethodName() string
func (*RPCInvocation) ParameterTypes ¶
func (r *RPCInvocation) ParameterTypes() []reflect.Type
func (*RPCInvocation) Reply ¶
func (r *RPCInvocation) Reply() interface{}
func (*RPCInvocation) SetAttachments ¶
func (r *RPCInvocation) SetAttachments(key string, value string)
func (*RPCInvocation) SetCallBack ¶
func (r *RPCInvocation) SetCallBack(c interface{})
func (*RPCInvocation) SetInvoker ¶
func (r *RPCInvocation) SetInvoker() protocol.Invoker
func (*RPCInvocation) SetMethod ¶
func (r *RPCInvocation) SetMethod(method string)
func (*RPCInvocation) SetReply ¶
func (r *RPCInvocation) SetReply(reply interface{})
Click to show internal directories.
Click to hide internal directories.