rpc

Documentation

Index

• func Register(mu *http.ServeMux, en *encoding.Map)
• func Unary[Req any, Res any](path string, handler UnaryHandler[Req, Res])
• func WriteError(ctx context.Context, err error)
• type Client
  • func NewClient[Req any, Res any](url, contentType string, client *http.Client, enc *encoding.Map) *Client[Req, Res]
  • func (c *Client[Req, Res]) Call(ctx context.Context, req *Req) (res *Res, err error)
• type UnaryHandler

Functions

func Register

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

Register for HTTP.

func Unary

func Unary[Req any, Res any](path string, handler UnaryHandler[Req, Res])

Unary for rpc.

func WriteError

func WriteError(ctx context.Context, err error)

WriteError 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, contentType string, client *http.Client, enc *encoding.Map) *Client[Req, Res]

NewClient for HTTP.

func (*Client[Req, Res]) Call

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

Call for HTTP.

type UnaryHandler

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

UnaryHandler for rpc.