transport

type CallOption func(o *options)

type Client interface {
	Use(selector string, mws ...middleware.Middleware)
	//Invoke(ctx context.Context, method string, req interface{}, resp interface{}, opts ...CallOption) error
	Close() error
}

type ClientInfo struct {
	Type   string
	Target string
	Op     *xrpc.Operation
}

type ErrorConverter interface {
	// FromRPCError converts RPC error to a transport error.
	FromRPCError(err error) error
	// ToRPCError converts ngo error to rpc error.
	ToRPCError(err error) error
}

type Server interface {
	Use(selector string, mws ...middleware.Middleware)
	Start() error
	Healthz(ctx context.Context) bool
	Online(ctx context.Context) error
	Offline(ctx context.Context) error
	Stop()
	GracefulStop()
}

type ServerInfo struct {
	Type string
	Op   *xrpc.Operation
	Peer *xrpc.Peer
}