rpc

Documentation

Index

• func Register(mu *http.ServeMux, en *encoding.Map)
• func Request(ctx context.Context) *http.Request
• func Response(ctx context.Context) http.ResponseWriter
• func Unary[Req any, Res any](path string, handler UnaryHandler[Req, Res])
• func WithRequest(ctx context.Context, r *http.Request) context.Context
• func WithResponse(ctx context.Context, r http.ResponseWriter) context.Context
• 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 Request

func Request(ctx context.Context) *http.Request

Request for rpc.

func Response

func Response(ctx context.Context) http.ResponseWriter

Response for rpc.

func Unary

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

Unary for rpc.

func WithRequest

func WithRequest(ctx context.Context, r *http.Request) context.Context

WithRequest for rpc.

func WithResponse

func WithResponse(ctx context.Context, r http.ResponseWriter) context.Context

WithResponse 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.