rpc

Documentation

Index

• func Register(mu *http.ServeMux, en *encoding.Map)
• func Route[Req any, Res any](path string, handler Handler[Req, Res])
• type Client
  • func NewClient[Req any, Res any](url string, opts ...ClientOption) *Client[Req, Res]
  • func (c *Client[Req, Res]) Invoke(ctx context.Context, req *Req) (res *Res, err error)
• type ClientOption
  • func WithClient(client *http.Client) ClientOption
  • func WithClientContentType(ct string) ClientOption
• type Handler

Functions

func Register

func Register(mu *http.ServeMux, en *encoding.Map)

Register for rpc.

func Route

func Route[Req any, Res any](path string, handler Handler[Req, Res])

Route for rpc.

Types

type Client

type Client[Req any, Res any] struct {
	// contains filtered or unexported fields
}

Client for HTTP.

func NewClient

func NewClient[Req any, Res any](url string, opts ...ClientOption) *Client[Req, Res]

NewClient for rpc.

func (*Client[Req, Res]) Invoke

func (c *Client[Req, Res]) Invoke(ctx context.Context, req *Req) (res *Res, err error)

Invoke for rpc.

type ClientOption

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

ClientOption for rpc.

func WithClient

func WithClient(client *http.Client) ClientOption

WithClient for rpc.

func WithClientContentType

func WithClientContentType(ct string) ClientOption

WithClientContentType for rpc.

type Handler

type Handler[Req any, Res any] func(ctx context.Context, req *Req) (*Res, error)

Handler for rpc.