invocation

Documentation

Index

• func WithArguments(arguments []any) option
• func WithAttachment(k string, v any) option
• func WithAttachments(attachments map[string]any) option
• func WithCallBack(callBack any) option
• func WithInvoker(invoker base.Invoker) option
• func WithMethodName(methodName string) option
• func WithParameterRawValues(parameterRawValues []any) option
• func WithParameterTypeNames(parameterTypeNames []string) option
• func WithParameterTypes(parameterTypes []reflect.Type) option
• func WithParameterValues(parameterValues []reflect.Value) option
• func WithReply(reply any) option
• type RPCInvocation
  • func NewRPCInvocation(methodName string, arguments []any, attachments map[string]any) *RPCInvocation
  • func NewRPCInvocationWithOptions(opts ...option) *RPCInvocation
  • func (r *RPCInvocation) ActualMethodName() string
  • func (r *RPCInvocation) Arguments() []any
  • func (r *RPCInvocation) Attachments() map[string]any
  • func (r *RPCInvocation) Attributes() map[string]any
  • func (r *RPCInvocation) CallBack() any
  • func (r *RPCInvocation) GetAttachment(key string) (string, bool)
  • func (r *RPCInvocation) GetAttachmentAsContext() context.Context
  • func (r *RPCInvocation) GetAttachmentInterface(key string) any
  • func (r *RPCInvocation) GetAttachmentWithDefaultValue(key string, defaultValue string) string
  • func (r *RPCInvocation) GetAttribute(key string) (any, bool)
  • func (r *RPCInvocation) GetAttributeWithDefaultValue(key string, defaultValue any) any
  • func (r *RPCInvocation) Invoker() base.Invoker
  • func (r *RPCInvocation) IsGenericInvocation() bool
  • func (r *RPCInvocation) MergeAttachmentFromContext(ctx context.Context)
  • func (r *RPCInvocation) MethodName() string
  • func (r *RPCInvocation) ParameterRawValues() []any
  • func (r *RPCInvocation) ParameterTypeNames() []string
  • func (r *RPCInvocation) ParameterTypes() []reflect.Type
  • func (r *RPCInvocation) ParameterValues() []reflect.Value
  • func (r *RPCInvocation) Reply() any
  • func (r *RPCInvocation) ServiceKey() string
  • func (r *RPCInvocation) SetAttachment(key string, value any)
  • func (r *RPCInvocation) SetAttribute(key string, value any)
  • func (r *RPCInvocation) SetCallBack(c any)
  • func (r *RPCInvocation) SetInvoker(invoker base.Invoker)
  • func (r *RPCInvocation) SetReply(reply any)

Functions

func WithArguments

func WithArguments(arguments []any) option

WithArguments creates option with @arguments function.

func WithAttachment

func WithAttachment(k string, v any) option

WithAttachment put a key-value pair into attachments.

func WithAttachments

func WithAttachments(attachments map[string]any) option

WithAttachments creates option with @attachments.

func WithCallBack

func WithCallBack(callBack any) option

WithCallBack creates option with @callback function.

func WithInvoker

func WithInvoker(invoker base.Invoker) option

WithInvoker creates option with @invoker.

func WithMethodName

func WithMethodName(methodName string) option

WithMethodName creates option with @methodName.

func WithParameterRawValues

func WithParameterRawValues(parameterRawValues []any) option

WithParameterRawValues creates option with @parameterRawValues

func WithParameterTypeNames

func WithParameterTypeNames(parameterTypeNames []string) option

WithParameterTypeNames creates option with @parameterTypeNames.

func WithParameterTypes

func WithParameterTypes(parameterTypes []reflect.Type) option

WithParameterTypes creates option with @parameterTypes.

func WithParameterValues

func WithParameterValues(parameterValues []reflect.Value) option

WithParameterValues creates option with @parameterValues

func WithReply

func WithReply(reply any) option

WithReply creates option with @reply function.

Types

type RPCInvocation

type RPCInvocation struct {
	// contains filtered or unexported fields
}

todo: is it necessary to separate fields of consumer(provider) from RPCInvocation RPCInvocation carries method, parameters, attachments and invocation metadata.

func NewRPCInvocation

func NewRPCInvocation(methodName string, arguments []any, attachments map[string]any) *RPCInvocation

NewRPCInvocation creates a RPC invocation.

func NewRPCInvocationWithOptions

func NewRPCInvocationWithOptions(opts ...option) *RPCInvocation

NewRPCInvocationWithOptions creates a RPC invocation with @opts.

func (*RPCInvocation) ActualMethodName

func (r *RPCInvocation) ActualMethodName() string

ActualMethodName gets actual invocation method name. It returns the method name been called if it's a generic call

func (*RPCInvocation) Arguments

func (r *RPCInvocation) Arguments() []any

Arguments gets RPC arguments.

func (*RPCInvocation) Attachments

func (r *RPCInvocation) Attachments() map[string]any

Attachments gets all attachments of RPC.

func (*RPCInvocation) Attributes

func (r *RPCInvocation) Attributes() map[string]any

Attributes gets all attributes of RPC.

func (*RPCInvocation) CallBack

func (r *RPCInvocation) CallBack() any

CallBack sets RPC callback method.

func (*RPCInvocation) GetAttachment

func (r *RPCInvocation) GetAttachment(key string) (string, bool)

func (*RPCInvocation) GetAttachmentAsContext

func (r *RPCInvocation) GetAttachmentAsContext() context.Context

func (*RPCInvocation) GetAttachmentInterface

func (r *RPCInvocation) GetAttachmentInterface(key string) any

GetAttachmentInterface returns the corresponding value from dubbo's attachment with the given key.

func (*RPCInvocation) GetAttachmentWithDefaultValue

func (r *RPCInvocation) GetAttachmentWithDefaultValue(key string, defaultValue string) string

func (*RPCInvocation) GetAttribute

func (r *RPCInvocation) GetAttribute(key string) (any, bool)

func (*RPCInvocation) GetAttributeWithDefaultValue

func (r *RPCInvocation) GetAttributeWithDefaultValue(key string, defaultValue any) any

func (*RPCInvocation) Invoker

func (r *RPCInvocation) Invoker() base.Invoker

Invoker gets the invoker in current context.

func (*RPCInvocation) IsGenericInvocation

func (r *RPCInvocation) IsGenericInvocation() bool

IsGenericInvocation gets if this is a generic invocation

func (*RPCInvocation) MergeAttachmentFromContext

func (r *RPCInvocation) MergeAttachmentFromContext(ctx context.Context)

func (*RPCInvocation) MethodName

func (r *RPCInvocation) MethodName() string

MethodName gets RPC invocation method name.

func (*RPCInvocation) ParameterRawValues

func (r *RPCInvocation) ParameterRawValues() []any

func (*RPCInvocation) ParameterTypeNames

func (r *RPCInvocation) ParameterTypeNames() []string

ParameterTypeNames gets RPC invocation parameter types of string expression.

func (*RPCInvocation) ParameterTypes

func (r *RPCInvocation) ParameterTypes() []reflect.Type

ParameterTypes gets RPC invocation parameter types.

func (*RPCInvocation) ParameterValues

func (r *RPCInvocation) ParameterValues() []reflect.Value

ParameterValues gets RPC invocation parameter values.

func (*RPCInvocation) Reply

func (r *RPCInvocation) Reply() any

Reply gets response of RPC request.

func (*RPCInvocation) ServiceKey

func (r *RPCInvocation) ServiceKey() string

func (*RPCInvocation) SetAttachment

func (r *RPCInvocation) SetAttachment(key string, value any)

func (*RPCInvocation) SetAttribute

func (r *RPCInvocation) SetAttribute(key string, value any)

func (*RPCInvocation) SetCallBack

func (r *RPCInvocation) SetCallBack(c any)

SetCallBack sets RPC callback method.

func (*RPCInvocation) SetInvoker

func (r *RPCInvocation) SetInvoker(invoker base.Invoker)

SetInvoker sets the invoker in current context (thread-safe).

func (*RPCInvocation) SetReply

func (r *RPCInvocation) SetReply(reply any)

SetReply sets response of RPC request.