client

type CallFunc func(ctx context.Context, req Request, rsp interface{}, opts CallOptions) error

type CallOption func(options *CallOptions)

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

type CallWrapper func(CallFunc) CallFunc

type Conn interface {
	// rpc调度服务方法
	Call(ctx context.Context, req Request, resp interface{}, callOption CallOptions) error
	// 关闭连接
	Close() error
	// 获取连接的创建时间
	Created() time.Time
	// 获取连接的地址
	Remote() string
	// 连接的异常记录
	Error() error
	// 连接id
	Id() int64
}

type CreateConnectHandle func() (Conn, error)

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

type Message struct {
	Header http.Header
	Body   interface{}
}

type Pool interface {
	// 获取连接
	Get(ctx context.Context) (Conn, error)
	// 释放连接
	Release(conn Conn)
	// 关闭连接
	Close()
}

type PoolOptions struct {
	Id   string
	Size int
	TTl  time.Duration
	CreateConnectHandle
}

type Request interface {
	// 服务名
	Service() string
	// 请求方法
	Method() string
	// 请求主题，也就是参数
	Body() interface{}

	SetHeader(key string, value interface{})

	Header() http.Header
}

type RequestOption func(optiones *requestOptiones)

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

type RpcClient interface {
	ConnRelease(serverName string, conn Conn)
	NewConnect(serverName string) (Conn, error)
	Call(ctx context.Context, req Request, resp interface{}, callOption ...CallOption) error
	NewRequest(serverName string, serverMethod string, req interface{}, opts ...RequestOption) Request
}

type Server struct {
	CartFile      string
	TlsServerName string
	Network       string
	Address       string
	// contains filtered or unexported fields
}