client

type Client interface {
	// Apply to init client
	Apply() error

	// Close close the client
	Close() error

	// Call invoke the downstream service.
	Call(req *Request) (res any, err error)

	// MapParams mapping param, uri, query, body ...
	MapParams(req *Request) (reqData any, err error)
}

type DubboMetadata struct {
	ApplicationName      string   `yaml:"application_name" json:"application_name" mapstructure:"application_name"`
	Group                string   `yaml:"group" json:"group" mapstructure:"group"`
	Version              string   `yaml:"version" json:"version" mapstructure:"version"`
	Interface            string   `yaml:"interface" json:"interface" mapstructure:"interface"`
	Method               string   `yaml:"method" json:"method" mapstructure:"method"`
	Types                []string `yaml:"types" json:"types" mapstructure:"types"`
	Retries              string   `yaml:"retries"  json:"retries,omitempty" property:"retries"`
	ClusterName          string   `yaml:"cluster_name"  json:"cluster_name,omitempty" property:"cluster_name"`
	ProtocolTypeStr      string   `yaml:"protocol_type"  json:"protocol_type,omitempty" property:"protocol_type"`
	SerializationTypeStr string   `yaml:"serialization_type"  json:"serialization_type,omitempty" property:"serialization_type"`
}

type MapOption map[string]RequestOption

type ParamMapper interface {
	// Map implements how the request parameters map to the target parameters described by config.MappingParam
	Map(config.MappingParam, *Request, any, RequestOption) error
}

type Request struct {
	Context        context.Context
	IngressRequest *http.Request
	API            router.API
	Timeout        time.Duration
}

type RequestOption interface {
	Action(target, val any) error
}

type StreamResponse struct {
	Stream      io.ReadCloser
	IsSSEStream bool
}

type UnaryResponse struct {
	Data []byte
}