rest

Documentation

Index

• func CopyBody(req *http.Request) ([]byte, error)
• func Decode(body io.ReadCloser, v interface{}) error
• func ExponentialBackoff(retry int)
• func IsClosedConnectionErr(err error) bool
• func NewClientAssertion(tokenUrl string, clientId string, clientCert string, signingKey string, ...) (string, error)
• func NewHTTPClient(proxyUrl string) (*http.Client, error)
• func NewRequest(ctx context.Context, verb string, endpoint *url.URL, body interface{}, ...) (*http.Request, error)
• func ParseAud(accessToken string) (string, error)
• func ParseBody(accessToken string) (map[string]interface{}, error)
• type RestClient
  • func NewRestClient(apiUrl string, config config.Config) (RestClient, error)
• type Token
  • func (s Token) IsExpired() bool
  • func (s Token) String() string
  • func (s *Token) UnmarshalJSON(data []byte) error

Functions

func CopyBody

func CopyBody(req *http.Request) ([]byte, error)

func Decode

func Decode(body io.ReadCloser, v interface{}) error

func ExponentialBackoff

func ExponentialBackoff(retry int)

func IsClosedConnectionErr

func IsClosedConnectionErr(err error) bool

func NewClientAssertion

func NewClientAssertion(tokenUrl string, clientId string, clientCert string, signingKey string, keyPassphrase string) (string, error)

func NewHTTPClient

func NewHTTPClient(proxyUrl string) (*http.Client, error)

func NewRequest

func NewRequest(
	ctx context.Context,
	verb string,
	endpoint *url.URL,
	body interface{},
	params map[string]string,
	headers map[string]string,
) (*http.Request, error)

func ParseAud

func ParseAud(accessToken string) (string, error)

func ParseBody

func ParseBody(accessToken string) (map[string]interface{}, error)

Types

type RestClient

type RestClient interface {
	Authenticate() error
	Delete(ctx context.Context, path string, body interface{}, params query.Params, headers map[string]string) (*http.Response, error)
	Get(ctx context.Context, path string, params query.Params, headers map[string]string) (*http.Response, error)
	Patch(ctx context.Context, path string, body interface{}, params query.Params, headers map[string]string) (*http.Response, error)
	Post(ctx context.Context, path string, body interface{}, params query.Params, headers map[string]string) (*http.Response, error)
	Put(ctx context.Context, path string, body interface{}, params query.Params, headers map[string]string) (*http.Response, error)
	Send(req *http.Request) (*http.Response, error)
	CloseIdleConnections()
}

func NewRestClient

func NewRestClient(apiUrl string, config config.Config) (RestClient, error)

type Token

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

func (Token) IsExpired

func (s Token) IsExpired() bool

func (Token) String

func (s Token) String() string

func (*Token) UnmarshalJSON

func (s *Token) UnmarshalJSON(data []byte) error