rpc

type Client interface {
	// Method*** handle response by yourself
	Do(ctx context.Context, req *http.Request) (*http.Response, error)
	Head(ctx context.Context, url string) (*http.Response, error)
	Get(ctx context.Context, url string) (*http.Response, error)
	Delete(ctx context.Context, url string) (*http.Response, error)
	Form(ctx context.Context, method, url string, form map[string][]string) (*http.Response, error)
	Put(ctx context.Context, url string, params interface{}) (*http.Response, error)
	Post(ctx context.Context, url string, params interface{}) (*http.Response, error)

	// ***With means parse result in client
	DoWith(ctx context.Context, req *http.Request, ret interface{}, opts ...Option) error
	GetWith(ctx context.Context, url string, ret interface{}) error
	PutWith(ctx context.Context, url string, ret interface{}, params interface{}, opts ...Option) error
	PostWith(ctx context.Context, url string, ret interface{}, params interface{}, opts ...Option) error

	// Close background goroutines in lb client
	Close()
}

type Config struct {
	// the whole request and response timeout
	ClientTimeoutMs int64 `json:"client_timeout_ms"`
	// bandwidthBPMs for read body
	BodyBandwidthMBPs float64 `json:"body_bandwidth_mbps"`

	// base timeout for read body
	BodyBaseTimeoutMs int64 `json:"body_base_timeout_ms"`
	// transport config
	Tc TransportConfig `json:"transport_config"`
}

type Context struct {
	Param httprouter.Params

	Request *http.Request
	Writer  http.ResponseWriter

	Meta map[string]interface{}
	// contains filtered or unexported fields
}

type Error struct {
	Status int    // http status code
	Code   string // error code
	Err    error  // error
}

type HTTPError interface {
	// StatusCode http status code
	StatusCode() int
	// ErrorCode special defined code
	ErrorCode() string
	// Error detail message
	Error() string
}

type HandlerFunc func(*Context)

type LbConfig struct {
	// hosts
	Hosts []string `json:"hosts"`
	// backup hosts
	BackupHosts []string `json:"backup_hosts"`
	// HostTryTimes Number of host failure retries, HostTryTimes < RequestTryTimes,
	// Avoid requesting the unavailable host all the time
	HostTryTimes int `json:"host_try_times"`
	// Failure retry interval, default value is -1, if FailRetryIntervalS < 0,
	// remove failed hosts will not work.
	FailRetryIntervalS int `json:"fail_retry_interval_s"`
	// Within MaxFailsPeriodS, if the number of failures is greater than or equal
	// to MaxFails, the host is considered disconnected.
	MaxFailsPeriodS int `json:"max_fails_period_s"`

	// RequestTryTimes The maximum number of attempts for a request hosts.
	RequestTryTimes int `json:"try_times"`

	// should retry function
	ShouldRetry func(code int, err error) bool `json:"-"`

	// config for simple client
	Config
}

type Marshaler interface {
	Marshal() ([]byte, string, error)
}

type MarshalerTo interface {
	MarshalTo(responseBody io.Writer) (string, error)
}

type Option func(req *http.Request)

type Parser interface {
	Parse(ValueGetter) error
}

type ProgressHandler interface {
	Handler(http.ResponseWriter, *http.Request, func(http.ResponseWriter, *http.Request))
}

type Router struct {
	Router *httprouter.Router // router
	// contains filtered or unexported fields
}

type Selector interface {
	// GetAvailableHosts get the available hosts
	GetAvailableHosts() []string
	// SetFail Mark host unavailable
	SetFail(string)
	// Close If use a background coroutine to enable the broken host, you can use it to close the coroutine
	Close()
}

type ServerOption interface {
	// contains filtered or unexported methods
}

type TransportConfig struct {
	// DialTimeoutMs dial timeout in milliseconds
	DialTimeoutMs int64 `json:"dial_timeout_ms"`
	// ResponseHeaderTimeoutMs response header timeout after send the request
	ResponseHeaderTimeoutMs int64 `json:"response_header_timeout_ms"`

	MaxConnsPerHost     int `json:"max_conns_per_host"`
	MaxIdleConns        int `json:"max_idle_conns"`
	MaxIdleConnsPerHost int `json:"max_idle_conns_per_host"`
	// IdleConnTimeout is the maximum amount of time an idle
	// (keep-alive) connection will remain idle before closing
	// itself.Zero means no limit.
	IdleConnTimeoutMs int64 `json:"idle_conn_timeout_ms"`
	// DisableCompression, if true, prevents the Transport from
	// requesting compression with an "Accept-Encoding: gzip"
	DisableCompression bool `json:"disable_compression"`

	// auth config
	Auth auth.Config `json:"auth"`
}

type Unmarshaler interface {
	Unmarshal([]byte) error
}

type UnmarshalerFrom interface {
	UnmarshalFrom(requestBody io.Reader) error
}

type ValueGetter func(string) string