client

type CallOption func(*CallOptions)

type CallOptions struct {
	SelectOptions []selector.SelectOption

	// Address of remote hosts
	Address []string
	// Backoff func
	//Backoff BackoffFunc
	// Check if retriable func
	Retry RetryFunc
	// Number of Call attempts
	Retries int
	// Transport Dial Timeout
	DialTimeout time.Duration
	// Request/Response timeout
	RequestTimeout time.Duration
	// Stream timeout for the stream
	StreamTimeout time.Duration
	// Use the services own auth token
	ServiceToken bool
	// Duration to cache the response for
	CacheExpiry time.Duration

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Config struct {
	config.Config `field:"-"`
	Name          string `field:"-"` // config name/path in config file
	PrefixName    string `field:"-"` // config prefix name
	// Other options for implementations of the interface
	// can be stored in a context
	Logger      logger.ILogger         `field:"-"` // 保留:提供给扩展使用
	Context     context.Context        `field:"-"`
	Client      IClient                `field:"-"`
	Transport   transport.ITransport   `field:"-"`
	Registry    registry.IRegistry     `field:"-"`
	Selector    selector.ISelector     `field:"-"`
	TlsConfig   *tls.Config            `field:"-"` // TLSConfig for tcp and quic
	CallOptions CallOptions            `field:"-"` // Default Call Options
	DialOptions []transport.DialOption `field:"-"` // TODO 		// 提供实时变化sturct

	// Connection Pool
	PoolSize int
	PoolTtl  time.Duration
	Retries  int // Retries retries to send

	// Used to select codec
	ContentType string

	// Group is used to select the services in the same group. Services set group info in their meta.
	// If it is empty, clients will ignore group.
	Group string

	// BackupLatency is used for Failbackup mode. rpc will sends another request if the first response doesn't return in BackupLatency time.
	BackupLatency time.Duration

	// 传输序列类型
	Serialize     codec.SerializeType `field:"-"`
	SerializeType string              //codec.SerializeType
	CompressType  transport.CompressType

	Heartbeat         bool
	HeartbeatInterval time.Duration

	Ja3      transport.Ja3 `field:"-"`
	ProxyUrl string
	// http options
	UserAgent     string
	AllowRedirect bool

	// Debug mode
	PrintRequest    bool
	PrintRequestAll bool

	// Registry
	RegistryType string
	RegistryHost string

	// Selector
	SelectorStrategy string
	// contains filtered or unexported fields
}

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

type HttpOption func(*Config)

type HttpRequest = httpRequest

type HttpResponse = httpResponse

type IClient interface {
	Init(...Option) error
	Config() *Config
}

type IRequest interface {
	// The service to call
	Service() string
	// The action to take
	Method() string
	// The endpoint to invoke
	//Endpoint() string
	// The content type
	ContentType() string
	Header() header.Header
	// The unencoded request body
	Body() *body.TBody
	// Write to the encoded request writer. This is nil before a call is made
	//Codec() codec.Writer
	// indicates whether the request will be a streaming one rather than unary
	Stream() bool
	Options() RequestOptions
}

type IResponse interface {
	Body() *body.TBody
	// Read the response
	//Codec() codec.Reader
	// read the header
	Header() header.Header
}

type Option func(*Config)

type RequestOption func(*RequestOptions)

type RequestOptions struct {
	ContentType   string
	Stream        bool
	Codec         codec.ICodec
	Encoded       bool // 传入的数据已经是编码器过的
	SerializeType codec.SerializeType

	Service string // 为该请求指定微服务名称
	// Request/Response timeout
	RequestTimeout time.Duration

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type RetryFunc func(ctx context.Context, req IRequest, retryCount int, err error) (bool, error)

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