client

Documentation

Index

• Constants
• Variables
• type BasicProblemDecoder
  • func (d *BasicProblemDecoder) DecodeProblem(ctx context.Context, resp *http.Response) (problems.Problem, error)
• type Client
  • func NewClient(opts ...Option) *Client
  • func (c *Client) Do(ctx context.Context, r *Request) (*Response, error)
  • func (c *Client) DoAndUnmarshal(ctx context.Context, r *Request, v interface{}) error
• type HTTPError
  • func (e HTTPError) Error() string
  • func (e HTTPError) Is(target error) bool
• type Option
  • func WithBaseURL(baseURL string) Option
  • func WithDatadogTracing(opts ...dd_http.RoundTripperOption) Option
  • func WithDefaultHeader(header, value string) Option
  • func WithOpenCensusTracing() Option
  • func WithProblemDecoder(decoder ProblemDecoder) Option
  • func WithTokenProvider(provider auth.TokenProvider) Option
• type ProblemDecoder
• type Request
  • func Connect(uriTemplate string) *Request
  • func Delete(uriTemplate string) *Request
  • func Get(uriTemplate string) *Request
  • func Head(uriTemplate string) *Request
  • func NewRequest(method, uriTemplate string) *Request
  • func Options(uriTemplate string) *Request
  • func Patch(uriTemplate string) *Request
  • func Post(uriTemplate string) *Request
  • func Put(uriTemplate string) *Request
  • func Trace(uriTemplate string) *Request
  • func (r *Request) Assign(variable string, value interface{}) *Request
  • func (r *Request) ExpandURL(baseURL *url.URL) (*url.URL, error)
  • func (r *Request) SetHeader(key, value string) *Request
  • func (r *Request) WithJSONPayload(payload interface{}) *Request
• type Response
  • func (r *Response) Unmarshal(v interface{}) (err error)

Constants

const (
	DefaultUserAgent      string = "go-rest-utility/v1"
	DefaultAcceptEncoding string = "gzip"
)

Variables

var (
	ErrBadRequest                   = newHTTPError(http.StatusBadRequest)
	ErrUnauthorized                 = newHTTPError(http.StatusUnauthorized)
	ErrPaymentRequired              = newHTTPError(http.StatusPaymentRequired)
	ErrForbidden                    = newHTTPError(http.StatusForbidden)
	ErrNotFound                     = newHTTPError(http.StatusNotFound)
	ErrMethodNotAllowed             = newHTTPError(http.StatusMethodNotAllowed)
	ErrNotAcceptable                = newHTTPError(http.StatusNotAcceptable)
	ErrProxyAuthRequired            = newHTTPError(http.StatusProxyAuthRequired)
	ErrRequestTimeout               = newHTTPError(http.StatusRequestTimeout)
	ErrConflict                     = newHTTPError(http.StatusConflict)
	ErrGone                         = newHTTPError(http.StatusGone)
	ErrLengthRequired               = newHTTPError(http.StatusLengthRequired)
	ErrPreconditionFailed           = newHTTPError(http.StatusPreconditionFailed)
	ErrRequestEntityTooLarge        = newHTTPError(http.StatusRequestEntityTooLarge)
	ErrRequestURITooLong            = newHTTPError(http.StatusRequestURITooLong)
	ErrUnsupportedMediaType         = newHTTPError(http.StatusUnsupportedMediaType)
	ErrRequestedRangeNotSatisfiable = newHTTPError(http.StatusRequestedRangeNotSatisfiable)
	ErrExpectationFailed            = newHTTPError(http.StatusExpectationFailed)
	ErrTeapot                       = newHTTPError(http.StatusTeapot)
	ErrMisdirectedRequest           = newHTTPError(http.StatusMisdirectedRequest)
	ErrUnprocessableEntity          = newHTTPError(http.StatusUnprocessableEntity)
	ErrLocked                       = newHTTPError(http.StatusLocked)
	ErrFailedDependency             = newHTTPError(http.StatusFailedDependency)
	ErrTooEarly                     = newHTTPError(http.StatusTooEarly)
	ErrUpgradeRequired              = newHTTPError(http.StatusUpgradeRequired)
	ErrPreconditionRequired         = newHTTPError(http.StatusPreconditionRequired)
	ErrTooManyRequests              = newHTTPError(http.StatusTooManyRequests)
	ErrRequestHeaderFieldsTooLarge  = newHTTPError(http.StatusRequestHeaderFieldsTooLarge)
	ErrUnavailableForLegalReasons   = newHTTPError(http.StatusUnavailableForLegalReasons)

	ErrInternalServerError           = newHTTPError(http.StatusInternalServerError)
	ErrNotImplemented                = newHTTPError(http.StatusNotImplemented)
	ErrBadGateway                    = newHTTPError(http.StatusBadGateway)
	ErrServiceUnavailable            = newHTTPError(http.StatusServiceUnavailable)
	ErrGatewayTimeout                = newHTTPError(http.StatusGatewayTimeout)
	ErrHTTPVersionNotSupported       = newHTTPError(http.StatusHTTPVersionNotSupported)
	ErrVariantAlsoNegotiates         = newHTTPError(http.StatusVariantAlsoNegotiates)
	ErrInsufficientStorage           = newHTTPError(http.StatusInsufficientStorage)
	ErrLoopDetected                  = newHTTPError(http.StatusLoopDetected)
	ErrNotExtended                   = newHTTPError(http.StatusNotExtended)
	ErrNetworkAuthenticationRequired = newHTTPError(http.StatusNetworkAuthenticationRequired)
)

Types

type BasicProblemDecoder

type BasicProblemDecoder struct{}

func (*BasicProblemDecoder) DecodeProblem

func (d *BasicProblemDecoder) DecodeProblem(ctx context.Context, resp *http.Response) (problems.Problem, error)

type Client

type Client struct {
	BaseURL       *url.URL
	TokenProvider auth.TokenProvider
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opts ...Option) *Client

NewClient will create a new REST Client.

func (*Client) Do

func (c *Client) Do(ctx context.Context, r *Request) (*Response, error)

func (*Client) DoAndUnmarshal

func (c *Client) DoAndUnmarshal(ctx context.Context, r *Request, v interface{}) error

type HTTPError

type HTTPError struct {
	StatusCode int
	Status     string

	Instance string
	Body     string
}

func (HTTPError) Error

func (e HTTPError) Error() string

func (HTTPError) Is

func (e HTTPError) Is(target error) bool

type Option

type Option func(*Client)

func WithBaseURL

func WithBaseURL(baseURL string) Option

func WithDatadogTracing

func WithDatadogTracing(opts ...dd_http.RoundTripperOption) Option

WithDatadogTracing will add a Datadog transport to the client so that it will automatically inject trace-headers.

Should be used when you trace your application with Datadog.

Note, when used in AWS Lambda, make sure to set the service name. client.WithDatadogTracing(

dd_http.RTWithServiceName("<service_name>"),

)

func WithDefaultHeader

func WithDefaultHeader(header, value string) Option

func WithOpenCensusTracing

func WithOpenCensusTracing() Option

WithOpenCensusTracing will add an OpenCensus transport to the client so that it will automatically inject trace-headers.

Should be used when you trace your application with OpenCensus.

func WithProblemDecoder

func WithProblemDecoder(decoder ProblemDecoder) Option

func WithTokenProvider

func WithTokenProvider(provider auth.TokenProvider) Option

type ProblemDecoder

type ProblemDecoder interface {
	DecodeProblem(context.Context, *http.Response) (problems.Problem, error)
}

type Request

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

func Connect

func Connect(uriTemplate string) *Request

func Delete

func Delete(uriTemplate string) *Request

func Get

func Get(uriTemplate string) *Request

func Head

func Head(uriTemplate string) *Request

func NewRequest

func NewRequest(method, uriTemplate string) *Request

func Options

func Options(uriTemplate string) *Request

func Patch

func Patch(uriTemplate string) *Request

func Post

func Post(uriTemplate string) *Request

func Put

func Put(uriTemplate string) *Request

func Trace

func Trace(uriTemplate string) *Request

func (*Request) Assign

func (r *Request) Assign(variable string, value interface{}) *Request

func (*Request) ExpandURL

func (r *Request) ExpandURL(baseURL *url.URL) (*url.URL, error)

ExpandURL combines the baseURL with the expanded URI template to form the final URL to be used for this Request. If no baseURL is provided the returned URL is just the expanded URI template

func (*Request) SetHeader

func (r *Request) SetHeader(key, value string) *Request

func (*Request) WithJSONPayload

func (r *Request) WithJSONPayload(payload interface{}) *Request

type Response

type Response struct {
	http.Response
}

func (*Response) Unmarshal

func (r *Response) Unmarshal(v interface{}) (err error)