utils

Documentation

Index

• Variables
• func AsSecuritySource(security interface{}) func(context.Context) (interface{}, error)
• func ConsumeRawBody(res *http.Response) ([]byte, error)
• func Contains(slice []string, item string) bool
• func GenerateURL(_ context.Context, serverURL, path string, pathParams interface{}, ...) (string, error)
• func GetEnv(name, defaultValue string) string
• func MarshalJSON(v interface{}, tag reflect.StructTag, topLevel bool) ([]byte, error)
• func MatchContentType(contentType string, pattern string) bool
• func MatchStatusCodes(expectedCodes []string, statusCode int) bool
• func PopulateHeaders(_ context.Context, req *http.Request, headers interface{}, globals interface{})
• func PopulateQueryParams(_ context.Context, req *http.Request, queryParams interface{}, ...) error
• func PopulateSecurity(ctx context.Context, req *http.Request, ...) error
• func ReplaceParameters(stringWithParams string, params map[string]string) string
• func Retry(ctx context.Context, r Retries, operation func() (*http.Response, error)) (*http.Response, error)
• func SerializeRequestBody(_ context.Context, request interface{}, nullable, optional bool, ...) (io.Reader, string, error)
• func UnmarshalJSON(b []byte, v interface{}, tag reflect.StructTag, topLevel bool, ...) error
• func UnmarshalJsonFromResponseBody(body io.Reader, out interface{}, tag string) error
• type BackoffStrategy
• type Retries
• type RetryConfig
• type Timer

Variables

var (
	SerializationMethodToContentType = map[string]string{
		"json":      "application/json",
		"form":      "application/x-www-form-urlencoded",
		"multipart": "multipart/form-data",
		"raw":       "application/octet-stream",
		"string":    "text/plain",
	}
)

Functions

func AsSecuritySource

func AsSecuritySource(security interface{}) func(context.Context) (interface{}, error)

func ConsumeRawBody

func ConsumeRawBody(res *http.Response) ([]byte, error)

func Contains

func Contains(slice []string, item string) bool

func GenerateURL

func GenerateURL(_ context.Context, serverURL, path string, pathParams interface{}, globals interface{}) (string, error)

func GetEnv

func GetEnv(name, defaultValue string) string

GetEnv returns the value of the environment variable named by the key or the defaultValue if the environment variable is not set.

func MarshalJSON

func MarshalJSON(v interface{}, tag reflect.StructTag, topLevel bool) ([]byte, error)

func MatchContentType

func MatchContentType(contentType string, pattern string) bool

func MatchStatusCodes

func MatchStatusCodes(expectedCodes []string, statusCode int) bool

func PopulateHeaders

func PopulateHeaders(_ context.Context, req *http.Request, headers interface{}, globals interface{})

func PopulateQueryParams

func PopulateQueryParams(_ context.Context, req *http.Request, queryParams interface{}, globals interface{}) error

func PopulateSecurity

func PopulateSecurity(ctx context.Context, req *http.Request, securitySource func(context.Context) (interface{}, error)) error

func ReplaceParameters

func ReplaceParameters(stringWithParams string, params map[string]string) string

func Retry

func Retry(ctx context.Context, r Retries, operation func() (*http.Response, error)) (*http.Response, error)

func SerializeRequestBody

func SerializeRequestBody(_ context.Context, request interface{}, nullable, optional bool, requestFieldName, serializationMethod, tag string) (io.Reader, string, error)

func UnmarshalJSON

func UnmarshalJSON(b []byte, v interface{}, tag reflect.StructTag, topLevel bool, disallowUnknownFields bool) error

func UnmarshalJsonFromResponseBody

func UnmarshalJsonFromResponseBody(body io.Reader, out interface{}, tag string) error

Types

type BackoffStrategy

type BackoffStrategy = retry.BackoffStrategy

Deprecated: Use retry.BackoffStrategy instead.

type Retries

type Retries struct {
	Config      *retry.Config
	StatusCodes []string
}

type RetryConfig

type RetryConfig = retry.Config

Deprecated: Use retry.Config instead.

type Timer

type Timer interface {
	Start(duration time.Duration)
	Stop()
	C() <-chan time.Time
}