jet

package

Go to main page

Versions in this module

v2

v2.27.0

Jan 5, 2025

v2.26.3

Dec 15, 2024

v2.26.2

Dec 6, 2024

v2.26.1

Nov 28, 2024

v2.26.0

Nov 12, 2024

v2.25.1

Nov 7, 2024

v2.25.0

Oct 29, 2024

v2.24.0

Oct 25, 2024

Changes in this version

+ var JSONRPCVersion = "2.0"

+ func ContextWithClient(ctx context.Context, client *Client) context.Context

type Client

+ func ClientFromContext(ctx context.Context) (*Client, bool)

type Formatter

+ Kind func() FormatterKind

+ type FormatterKind string

+ const FormatterKindJSONRPC

type HTTPTransporter

+ Addr string

type JSONRPCFormatter

+ func (j *JSONRPCFormatter) Kind() FormatterKind

v2.23.0

Oct 22, 2024

v2.22.1

Oct 16, 2024

v2.22.0

Oct 9, 2024

v2.21.0

Sep 26, 2024

v2.20.0

Sep 13, 2024

v2.19.0

Sep 3, 2024

v2.18.1

Aug 16, 2024

Changes in this version

+ func IsHTTPTransporterServerError(err error) bool

type Client

+ func (c *Client) GetFormatter() Formatter

+ func (c *Client) GetIDGenerator() IDGenerator

+ func (c *Client) GetPacker() Packer

+ func (c *Client) GetPathGenerator() PathGenerator

+ func (c *Client) GetService() string

+ func (c *Client) GetTransporter() Transporter

+ type HTTPTransporterServerError struct

+ Err error

+ Message string

+ StatusCode int

+ func (e *HTTPTransporterServerError) Error() string

+ func (e *HTTPTransporterServerError) Unwrap() error

v2.18.0

Aug 14, 2024

Changes in this version

+ var ErrClientServiceIsRequired = errors.New("jet/client: service is required")

+ var ErrClientTransporterIsRequired = errors.New("jet/client: transporter is required")

+ var ErrHTTPTransporterAddrIsRequired = errors.New("jet/transporter: addr is required")

+ var ErrorHTTPTransporterClientIsRequired = errors.New("jet/transporter: client is required")

+ type Client struct

+ func NewClient(opts ...Option) (*Client, error)

+ func (c *Client) Invoke(ctx context.Context, name string, request any, response any, ...) (err error)

+ func (c *Client) Use(m ...Middleware)

+ type Formatter interface

+ FormatRequest func(req *RPCRequest) ([]byte, error)

+ FormatResponse func(resp *RPCResponse, err *RPCResponseError) ([]byte, error)

+ ParseRequest func(data []byte) (*RPCRequest, error)

+ ParseResponse func(data []byte) (*RPCResponse, error)

+ var DefaultFormatter Formatter = NewJSONRPCFormatter()

+ type FullPathGenerator struct

+ func NewFullPathGenerator() *FullPathGenerator

+ func (f *FullPathGenerator) Generate(service string, name string) string

+ type GeneralPathGenerator struct

+ func NewGeneralPathGenerator() *GeneralPathGenerator

+ func (g *GeneralPathGenerator) Generate(service string, name string) string

+ type HTTPTransporter struct

+ func NewHTTPTransporter(opts ...HTTPTransporterOption) (*HTTPTransporter, error)

+ func (t *HTTPTransporter) Send(ctx context.Context, data []byte) ([]byte, error)

+ type HTTPTransporterOption func(*HTTPTransporter)

+ func WithHTTPTransporterAddr(addr string) HTTPTransporterOption

+ func WithHTTPTransporterClient(client *http.Client) HTTPTransporterOption

+ type Handler func(ctx context.Context, name string, request any) (response any, err error)

+ type IDGenerator interface

+ Generate func() string

+ var DefaultIDGenerator IDGenerator = NewUUIDGenerator()

+ type IDGeneratorFunc func() string

+ func (f IDGeneratorFunc) Generate() string

+ type JSONPacker struct

+ func NewJSONPacker() *JSONPacker

+ func (p *JSONPacker) Pack(v interface{}) ([]byte, error)

+ func (p *JSONPacker) Unpack(data []byte, v interface{}) error

+ type JSONRPCFormatter struct

+ func NewJSONRPCFormatter() *JSONRPCFormatter

+ func (j *JSONRPCFormatter) FormatRequest(req *RPCRequest) ([]byte, error)

+ func (j *JSONRPCFormatter) FormatResponse(resp *RPCResponse, err *RPCResponseError) ([]byte, error)

+ func (j *JSONRPCFormatter) ParseRequest(data []byte) (*RPCRequest, error)

+ func (j *JSONRPCFormatter) ParseResponse(data []byte) (*RPCResponse, error)

+ type JSONRPCFormatterRequest struct

+ ID string

+ Jsonrpc string

+ Method string

+ Params json.RawMessage

+ type JSONRPCFormatterResponse struct

+ Error *JSONRPCFormatterResponseError

+ ID string

+ Jsonrpc string

+ Result json.RawMessage

+ type JSONRPCFormatterResponseError struct

+ Code int

+ Data error

+ Message string

+ type Middleware func(Handler) Handler

+ func Chain(m ...Middleware) Middleware

+ type Option func(*Client)

+ func WithFormatter(formatter Formatter) Option

+ func WithIDGenerator(generator IDGenerator) Option

+ func WithMiddleware(m ...Middleware) Option

+ func WithPacker(packer Packer) Option

+ func WithPathGenerator(generator PathGenerator) Option

+ func WithService(service string) Option

+ func WithTransporter(transporter Transporter) Option

+ type Packer interface

+ Pack func(interface{}) ([]byte, error)

+ Unpack func([]byte, interface{}) error

+ var DefaultPacker Packer = NewJSONPacker()

+ type PathGenerator interface

+ Generate func(service string, name string) string

+ var DefaultPathGenerator PathGenerator = NewGeneralPathGenerator()

+ type PathGeneratorFunc func(service string, name string) string

+ func (f PathGeneratorFunc) Generate(service string, name string) string

+ type RPCRequest struct

+ ID string

+ Params []byte

+ Path string

+ type RPCResponse struct

+ ID string

+ Result []byte

+ type RPCResponseError struct

+ Code int

+ Err error

+ ID string

+ Message string

+ func (r *RPCResponseError) Error() string

+ type Transporter interface

+ Send func(ctx context.Context, data []byte) ([]byte, error)

+ type UUIDGenerator struct

+ func NewUUIDGenerator() *UUIDGenerator

+ func (u *UUIDGenerator) Generate() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL