cl

Documentation

Index

• Constants
• func MustObserve()
• type AlertMapper
• type BodyParser
• type Client
  • func HostGenerator(stage, module string, port uint32) *Client
  • func New(module, host string, port uint32, tls bool) *Client
  • func (c *Client) Request(ctx context.Context, method, path string, modifiers ...any) error
• type ClientError
  • func (e ClientError) Alerts() alert.Alerts
  • func (e ClientError) Error() string
  • func (e ClientError) Status() int
  • func (e ClientError) Unwrap() error
• type HTTPError
• type HeaderParser
• type JSONArrayParser
• type JSONError
  • func (e JSONError) Alert() alert.Alert
  • func (e JSONError) Error() string
  • func (e JSONError) IsRecoverable() bool
  • func (e JSONError) Unwrap() error
• type JSONObjectParser
• type NetError
  • func (e NetError) Error() string
  • func (e NetError) IsRecoverable() bool
  • func (e NetError) Unwrap() error
• type RequestModifier
  • func WithStream(stream *jsoniter.Stream) RequestModifier
• type ServerError
  • func (e ServerError) Alerts() alert.Alerts
  • func (e ServerError) Error() string
  • func (e ServerError) Status() int
  • func (e ServerError) Unwrap() error
• type URIModifier
  • func WithPathSubstr(subs ...any) URIModifier

Constants

const (
	HTTPPort  = 80
	HTTPSPort = 443
)

Functions

func MustObserve

func MustObserve()

Types

type AlertMapper

type AlertMapper = func(context.Context, alert.Alert) error

type BodyParser

type BodyParser = func(context.Context, []byte, []byte)

type Client

type Client struct {
	// contains filtered or unexported fields
}

func HostGenerator

func HostGenerator(stage, module string, port uint32) *Client

func New

func New(module, host string, port uint32, tls bool) *Client

func (*Client) Request

func (c *Client) Request(
	ctx context.Context,
	method,
	path string,
	modifiers ...any,
) error

type ClientError

type ClientError struct {
	// contains filtered or unexported fields
}

func (ClientError) Alerts

func (e ClientError) Alerts() alert.Alerts

func (ClientError) Error

func (e ClientError) Error() string

func (ClientError) Status

func (e ClientError) Status() int

func (ClientError) Unwrap

func (e ClientError) Unwrap() error

type HTTPError

type HTTPError interface {
	Error() string
	Alerts() alert.Alerts
	Status() int
}

type HeaderParser

type HeaderParser = func(context.Context, *fasthttp.ResponseHeader)

type JSONArrayParser

type JSONArrayParser = func(context.Context, *jsoniter.Iterator)

type JSONError

type JSONError struct {
	// contains filtered or unexported fields
}

func (JSONError) Alert

func (e JSONError) Alert() alert.Alert

func (JSONError) Error

func (e JSONError) Error() string

func (JSONError) IsRecoverable

func (e JSONError) IsRecoverable() bool

func (JSONError) Unwrap

func (e JSONError) Unwrap() error

type JSONObjectParser

type JSONObjectParser = func(context.Context, *jsoniter.Iterator, string)

type NetError

type NetError struct {
	// contains filtered or unexported fields
}

func (NetError) Error

func (e NetError) Error() string

func (NetError) IsRecoverable

func (e NetError) IsRecoverable() bool

func (NetError) Unwrap

func (e NetError) Unwrap() error

type RequestModifier

type RequestModifier = func(context.Context, *fasthttp.Request) error

func WithStream

func WithStream(stream *jsoniter.Stream) RequestModifier

type ServerError

type ServerError struct {
	// contains filtered or unexported fields
}

func (ServerError) Alerts

func (e ServerError) Alerts() alert.Alerts

func (ServerError) Error

func (e ServerError) Error() string

func (ServerError) Status

func (e ServerError) Status() int

func (ServerError) Unwrap

func (e ServerError) Unwrap() error

type URIModifier

type URIModifier = func(context.Context, *fasthttp.URI) error

func WithPathSubstr

func WithPathSubstr(subs ...any) URIModifier