rpc

Documentation

Index

• func Register(mu *http.ServeMux, en *encoding.EncoderMap, p *sync.BufferPool)
• 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 WithClientContentType(ct string) ClientOption
  • func WithClientRoundTripper(rt http.RoundTripper) ClientOption
  • func WithClientTimeout(timeout string) ClientOption
• type Handler

Functions

func Register

func Register(mu *http.ServeMux, en *encoding.EncoderMap, p *sync.BufferPool)

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 WithClientContentType

func WithClientContentType(ct string) ClientOption

WithClientContentType for rpc.

func WithClientRoundTripper

func WithClientRoundTripper(rt http.RoundTripper) ClientOption

WithSenderRoundTripper for rpc.

func WithClientTimeout

func WithClientTimeout(timeout string) ClientOption

WithClientTimeout for rpc.

type Handler

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

Handler for rpc.