rpc

Documentation

Index

• func Code(err error) int
• func Error(code int, msg string) error
• func IsError(err error) bool
• 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 Code

func Code(err error) int

Code from the error. If nil 200, otherwise 500.

func Error

func Error(code int, msg string) error

Error representing code and msg.

func IsError

func IsError(err error) bool

IsError verifies if the package created this error.

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.