http

Documentation

Index

• Variables
• func HttpHandler(s *server.Server) http.Handler
• func ServerMaker() (*server.Server, jrpctest.ClientMaker, func())
• func ValidateRequest(r *http.Request) (int, error)
• type Client
  • func Dial(ctx context.Context, client *http.Client, target string) (*Client, error)
  • func DialHTTP(target string) (*Client, error)
  • func (c *Client) BatchCall(ctx context.Context, b ...*codec.BatchElem) error
  • func (c *Client) Close() error
  • func (c *Client) Closed() <-chan struct{}
  • func (c *Client) Do(ctx context.Context, result any, method string, params any) error
  • func (c *Client) Mount(h codec.Middleware)
  • func (c *Client) Notify(ctx context.Context, method string, params any) error
  • func (c *Client) SetHeader(key string, value string)
• type Codec
  • func NewCodec(w http.ResponseWriter, r *http.Request) *Codec
  • func (c *Codec) Close() error
  • func (c *Codec) Closed() <-chan struct{}
  • func (c *Codec) PeerInfo() codec.PeerInfo
  • func (c *Codec) ReadBatch(ctx context.Context) ([]*codec.Message, bool, error)
  • func (c *Codec) RemoteAddr() string
  • func (c *Codec) Reset(w http.ResponseWriter, r *http.Request)
  • func (c *Codec) Send(fn func(e *jx.Encoder) error) error
• type Server
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

Variables

var (
	ErrClientQuit                = errors.New("client is closed")
	ErrNoResult                  = errors.New("no result in JSON-RPC response")
	ErrSubscriptionQueueOverflow = errors.New("subscription queue overflow")
)

var ErrInvalidContentType = errors.New("invalid content type")

Functions

func HttpHandler

func HttpHandler(s *server.Server) http.Handler

func ServerMaker

func ServerMaker() (*server.Server, jrpctest.ClientMaker, func())

func ValidateRequest

func ValidateRequest(r *http.Request) (int, error)

validateRequest returns a non-zero response code and error message if the request is invalid.

Types

type Client

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

Client represents a connection to an RPC server.

func Dial

func Dial(ctx context.Context, client *http.Client, target string) (*Client, error)

func DialHTTP

func DialHTTP(target string) (*Client, error)

func (*Client) BatchCall

func (c *Client) BatchCall(ctx context.Context, b ...*codec.BatchElem) error

func (*Client) Close

func (c *Client) Close() error

func (*Client) Closed

func (c *Client) Closed() <-chan struct{}

func (*Client) Do

func (c *Client) Do(ctx context.Context, result any, method string, params any) error

func (*Client) Mount

func (c *Client) Mount(h codec.Middleware)

func (*Client) Notify

func (c *Client) Notify(ctx context.Context, method string, params any) error

func (*Client) SetHeader

func (c *Client) SetHeader(key string, value string)

type Codec

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

Reusable codec. use Reset()

func NewCodec

func NewCodec(w http.ResponseWriter, r *http.Request) *Codec

func (*Codec) Close

func (c *Codec) Close() error

closes the connection

func (*Codec) Closed

func (c *Codec) Closed() <-chan struct{}

Closed returns a channel which is closed when the connection is closed.

func (*Codec) PeerInfo

func (c *Codec) PeerInfo() codec.PeerInfo

gets the peer info

func (*Codec) ReadBatch

func (c *Codec) ReadBatch(ctx context.Context) ([]*codec.Message, bool, error)

func (*Codec) RemoteAddr

func (c *Codec) RemoteAddr() string

RemoteAddr returns the peer address of the connection.

func (*Codec) Reset

func (c *Codec) Reset(w http.ResponseWriter, r *http.Request)

func (*Codec) Send

func (c *Codec) Send(fn func(e *jx.Encoder) error) error

type Server

type Server struct {
	Server *server.Server
}

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)