sdk

Documentation

Index

• func AddRequestInterceptor(interceptor func(ctx context.Context, req *http.Request) error) opt.Option[Config]
• func AddResponseInterceptor(interceptor func(ctx context.Context, resp *http.Response) error) opt.Option[Config]
• func ApiKeyAuth(headerName, headerValue string) opt.Option[Config]
• func BearerAuth(token string) opt.Option[Config]
• func Execute[Response any](ctx context.Context, endpoint Client, request *Request) (*Response, error)
• func SetErrorResponseType[T any](handler ...func(response T) string) opt.Option[Config]
• func WithFormBody[Body any](value Body) opt.Option[Request]
• func WithHeader(name string, value string) opt.Option[Request]
• func WithJsonBody[Body any](value Body) opt.Option[Request]
• func WithMultipartFormBody(formWriter multipart.Writer, value *bytes.Buffer) opt.Option[Request]
• func WithQueryFloat(name string, value any) opt.Option[Request]
• func WithQueryInt(name string, value any) opt.Option[Request]
• func WithQueryParam(name string, value string) opt.Option[Request]
• func WithQueryStrings(name string, values ...string) opt.Option[Request]
• func WithQueryStruct[T any](value T) opt.Option[Request]
• func WithTimeout(ttl time.Duration) opt.Option[Request]
• type Client
  • func New(endpoint string, opts ...opt.Option[Config]) (*Client, error)
  • func (c Client) Request(method, path string, opts ...opt.Option[Request]) *Request
• type Config
  • func NewConfig(opts ...opt.Option[Config]) Config
  • func (c *Config) InterceptRequest(ctx context.Context, req *http.Request) error
  • func (c *Config) InterceptResponse(ctx context.Context, resp *http.Response) error
• type Endpoint
• type ErrorResponse
  • func (e ErrorResponse[T]) Error() string
• type Request
• type RequestInterceptor
• type ResponseInterceptor

Functions

func AddRequestInterceptor

func AddRequestInterceptor(interceptor func(ctx context.Context, req *http.Request) error) opt.Option[Config]

func AddResponseInterceptor

func AddResponseInterceptor(interceptor func(ctx context.Context, resp *http.Response) error) opt.Option[Config]

func ApiKeyAuth

func ApiKeyAuth(headerName, headerValue string) opt.Option[Config]

func BearerAuth

func BearerAuth(token string) opt.Option[Config]

func Execute

func Execute[Response any](
	ctx context.Context,
	endpoint Client,
	request *Request,
) (*Response, error)

func SetErrorResponseType

func SetErrorResponseType[T any](handler ...func(response T) string) opt.Option[Config]

func WithFormBody

func WithFormBody[Body any](value Body) opt.Option[Request]

func WithHeader

func WithHeader(name string, value string) opt.Option[Request]

func WithJsonBody

func WithJsonBody[Body any](value Body) opt.Option[Request]

func WithMultipartFormBody

func WithMultipartFormBody(formWriter multipart.Writer, value *bytes.Buffer) opt.Option[Request]

func WithQueryFloat

func WithQueryFloat(name string, value any) opt.Option[Request]

func WithQueryInt

func WithQueryInt(name string, value any) opt.Option[Request]

func WithQueryParam

func WithQueryParam(name string, value string) opt.Option[Request]

func WithQueryStrings

func WithQueryStrings(name string, values ...string) opt.Option[Request]

func WithQueryStruct

func WithQueryStruct[T any](value T) opt.Option[Request]

func WithTimeout

func WithTimeout(ttl time.Duration) opt.Option[Request]

Types

type Client

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

func New

func New(endpoint string, opts ...opt.Option[Config]) (*Client, error)

func (Client) Request

func (c Client) Request(method, path string, opts ...opt.Option[Request]) *Request

type Config

type Config struct {
	Timeout              time.Duration
	RequestInterceptors  []RequestInterceptor
	ResponseInterceptors []ResponseInterceptor
}

func NewConfig

func NewConfig(opts ...opt.Option[Config]) Config

func (*Config) InterceptRequest

func (c *Config) InterceptRequest(ctx context.Context, req *http.Request) error

func (*Config) InterceptResponse

func (c *Config) InterceptResponse(ctx context.Context, resp *http.Response) error

type Endpoint

type Endpoint interface {
	Config() Config
}

type ErrorResponse

type ErrorResponse[T any] struct {
	Response T
}

func (ErrorResponse[T]) Error

func (e ErrorResponse[T]) Error() string

type Request

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

type RequestInterceptor

type RequestInterceptor func(ctx context.Context, req *http.Request) error

type ResponseInterceptor

type ResponseInterceptor func(ctx context.Context, resp *http.Response) error