fix(generic): support variadic method invocation via generic call

common/constant/key.go

@@ -28,40 +28,41 @@ const (
 )
 
 const (
-	GroupKey               = "group"
-	VersionKey             = "version"
-	InterfaceKey           = "interface"
-	MessageSizeKey         = "message_size"
-	PathKey                = "path"
-	ServiceKey             = "service"
-	MethodsKey             = "methods"
-	TimeoutKey             = "timeout"
-	CategoryKey            = "category"
-	CheckKey               = "check"
-	EnabledKey             = "enabled"
-	SideKey                = "side"
-	OverrideProvidersKey   = "providerAddresses"
-	BeanNameKey            = "bean.name"
-	GenericKey             = "generic"
-	ClassifierKey          = "classifier"
-	TokenKey               = "token"
-	LocalAddr              = "local-addr"
-	RemoteAddr             = "remote-addr"
-	DefaultRemotingTimeout = 1000
-	ReleaseKey             = "release"
-	AnyhostKey             = "anyhost"
-	PortKey                = "port"
-	ProtocolKey            = "protocol"
-	PathSeparator          = "/"
-	DotSeparator           = "."
-	CommaSeparator         = ","
-	SslEnabledKey          = "ssl-enabled"
-	ParamsTypeKey          = "parameter-type-names" // key used in pass through invoker factory, to define param type
-	MetadataTypeKey        = "metadata-type"
-	MaxCallSendMsgSize     = "max-call-send-msg-size"
-	MaxServerSendMsgSize   = "max-server-send-msg-size"
-	MaxCallRecvMsgSize     = "max-call-recv-msg-size"
-	MaxServerRecvMsgSize   = "max-server-recv-msg-size"
+	GroupKey                    = "group"
+	VersionKey                  = "version"
+	InterfaceKey                = "interface"
+	MessageSizeKey              = "message_size"
+	PathKey                     = "path"
+	ServiceKey                  = "service"
+	MethodsKey                  = "methods"
+	TimeoutKey                  = "timeout"
+	CategoryKey                 = "category"
+	CheckKey                    = "check"
+	EnabledKey                  = "enabled"
+	SideKey                     = "side"
+	OverrideProvidersKey        = "providerAddresses"
+	BeanNameKey                 = "bean.name"
+	GenericKey                  = "generic"
+	GenericVariadicCallSliceKey = "generic-variadic-call-slice" // internal marker from generic filter to variadic reflection dispatchers
+	ClassifierKey               = "classifier"
+	TokenKey                    = "token"
+	LocalAddr                   = "local-addr"
+	RemoteAddr                  = "remote-addr"
+	DefaultRemotingTimeout      = 1000
+	ReleaseKey                  = "release"
+	AnyhostKey                  = "anyhost"
+	PortKey                     = "port"
+	ProtocolKey                 = "protocol"
+	PathSeparator               = "/"
+	DotSeparator                = "."
+	CommaSeparator              = ","
+	SslEnabledKey               = "ssl-enabled"
+	ParamsTypeKey               = "parameter-type-names" // key used in pass through invoker factory, to define param type
+	MetadataTypeKey             = "metadata-type"
+	MaxCallSendMsgSize          = "max-call-send-msg-size"
+	MaxServerSendMsgSize        = "max-server-send-msg-size"
+	MaxCallRecvMsgSize          = "max-call-recv-msg-size"
+	MaxServerRecvMsgSize        = "max-server-recv-msg-size"
 
 	// TODO: remove KeepAliveInterval and KeepAliveInterval in version 4.0.0
 	KeepAliveInterval = "keep-alive-interval"

common/rpc_service.go

@@ -132,6 +132,11 @@ func (m *MethodType) ReplyType() reflect.Type {
 	return m.replyType
 }
 
+// IsVariadic returns true if the method has a variadic (...T) final parameter.
+func (m *MethodType) IsVariadic() bool {
+	return m.method.Type.IsVariadic()
+}
+
 // SuiteContext transfers @ctx to reflect.Value type or get it from @m.ctxType.
 func (m *MethodType) SuiteContext(ctx context.Context) reflect.Value {
 	if ctxV := reflect.ValueOf(ctx); ctxV.IsValid() {