client

Documentation

Index

• func Module() *module.Module
• func SetErrorFilter(ctx context.Context, filter func(error) (bool, error)) context.Context
• func SetFallbackFunc(ctx context.Context, fb func(context.Context, error) (interface{}, error)) context.Context
• type Base
  • func (b *Base) Request(ctx context.Context) *resty.Request
  • func (b *Base) RequestWithCommand(ctx context.Context, command string) *resty.Request
• type CircuitRoundTripper
  • func (c *CircuitRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type DelayType
• type DriverWrapper
  • func WithTransport(tr http.RoundTripper) DriverWrapper
• type ErrDecoder
  • func DefaultErrDecoder(name string) ErrDecoder
• type Factory
  • func NewFactory(cfg *config.Config, wrappers []DriverWrapper) *Factory
  • func (f *Factory) Get(name string, opts ...Option) *Base
• type GenericClientError
  • func (e GenericClientError) Error() string
  • func (e GenericClientError) Status() int
• type Option
  • func WithDriverWrappers(wrappers ...DriverWrapper) Option
  • func WithErrDecoder(ed ErrDecoder) Option
• type RetryRoundTripper
  • func (r *RetryRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

Functions

func Module

func Module() *module.Module

func SetErrorFilter

func SetErrorFilter(ctx context.Context, filter func(error) (bool, error)) context.Context

func SetFallbackFunc

func SetFallbackFunc(ctx context.Context, fb func(context.Context, error) (interface{}, error)) context.Context

Types

type Base

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

func (*Base) Request

func (b *Base) Request(ctx context.Context) *resty.Request

func (*Base) RequestWithCommand

func (b *Base) RequestWithCommand(ctx context.Context, command string) *resty.Request

type CircuitRoundTripper

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

func (*CircuitRoundTripper) RoundTrip

func (c *CircuitRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type DelayType

type DelayType string

const (
	ConstantDelay    DelayType = "constant"
	ExponentialDelay DelayType = "exponential"
)

type DriverWrapper

type DriverWrapper wrapper.Wrapper[*resty.Client]

func WithTransport

func WithTransport(tr http.RoundTripper) DriverWrapper

type ErrDecoder

type ErrDecoder func(context.Context, *resty.Response) error

func DefaultErrDecoder

func DefaultErrDecoder(name string) ErrDecoder

type Factory

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

func NewFactory

func NewFactory(cfg *config.Config, wrappers []DriverWrapper) *Factory

func (*Factory) Get

func (f *Factory) Get(name string, opts ...Option) *Base

type GenericClientError

type GenericClientError struct {
	ClientName string
	StatusCode int
	RawBody    []byte
	ParsedBody interface{}
}

func (GenericClientError) Error

func (e GenericClientError) Error() string

func (GenericClientError) Status

func (e GenericClientError) Status() int

type Option

type Option interface {
	Apply(*options)
}

func WithDriverWrappers

func WithDriverWrappers(wrappers ...DriverWrapper) Option

func WithErrDecoder

func WithErrDecoder(ed ErrDecoder) Option

type RetryRoundTripper

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

func (*RetryRoundTripper) RoundTrip

func (r *RetryRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)