uhttp

package
v0.2.58 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 41 Imported by: 87

Documentation

Index

Constants

View Source 
const (
	ContentType = "Content-Type"
)

Variables

This section is empty.

Functions

func ClearCaches added in v0.2.35 

func ClearCaches(ctx context.Context) error

func CreateCacheKey added in v0.2.15 

func CreateCacheKey(req *http.Request) (string, error)

CreateCacheKey generates a cache key based on the request URL, query parameters, and headers.

func IsJSONContentType added in v0.2.21 

func IsJSONContentType(contentType string) bool

func IsXMLContentType added in v0.2.21 

func IsXMLContentType(contentType string) bool

func NewClient 

func NewClient(ctx context.Context, options ...Option) (*http.Client, error)

NewClient creates a new HTTP client that uses the given context and options to create a new transport layer.

func NewHttpCache added in v0.2.46 

func NewHttpCache(ctx context.Context, config *CacheConfig) (icache, error)

func WrapErrors added in v0.2.48 

func WrapErrors(preferredCode codes.Code, statusMsg string, errs ...error) error

func WrapErrorsWithRateLimitInfo added in v0.2.29 

func WrapErrorsWithRateLimitInfo(preferredCode codes.Code, resp *http.Response, errs ...error) error

Types

type AuthCredentials added in v0.1.23 

type AuthCredentials interface {
	GetClient(ctx context.Context, options ...Option) (*http.Client, error)
}

type BaseHttpClient added in v0.1.24 

type BaseHttpClient struct {
	HttpClient *http.Client
	// contains filtered or unexported fields
}

func NewBaseHttpClient added in v0.1.25 

func NewBaseHttpClient(httpClient *http.Client, opts ...WrapperOption) *BaseHttpClient

func NewBaseHttpClientWithContext added in v0.2.15 

func NewBaseHttpClientWithContext(ctx context.Context, httpClient *http.Client, opts ...WrapperOption) (*BaseHttpClient, error)

func (*BaseHttpClient) Do added in v0.1.24 

func (c *BaseHttpClient) Do(req *http.Request, options ...DoOption) (*http.Response, error)

func (*BaseHttpClient) NewRequest added in v0.1.24 

func (c *BaseHttpClient) NewRequest(ctx context.Context, method string, url *url.URL, options ...RequestOption) (*http.Request, error)

type BasicAuth added in v0.1.23 

type BasicAuth struct {
	Username string
	Password string
}

func NewBasicAuth added in v0.1.23 

func NewBasicAuth(username, password string) *BasicAuth

func (*BasicAuth) GetClient added in v0.1.23 

func (b *BasicAuth) GetClient(ctx context.Context, options ...Option) (*http.Client, error)

type BearerAuth added in v0.1.23 

type BearerAuth struct {
	Token string
}

func NewBearerAuth added in v0.1.23 

func NewBearerAuth(token string) *BearerAuth

func (*BearerAuth) GetClient added in v0.1.23 

func (b *BearerAuth) GetClient(ctx context.Context, options ...Option) (*http.Client, error)

type CacheBackend added in v0.2.46 

type CacheBackend string
const (
	CacheBackendDB     CacheBackend = "db"
	CacheBackendMemory CacheBackend = "memory"
	CacheBackendNoop   CacheBackend = "noop"
)

type CacheConfig added in v0.2.15 

type CacheConfig struct {
	LogDebug bool
	TTL      uint64       // If 0, cache is disabled
	MaxSize  uint         // MB
	Backend  CacheBackend // If noop, cache is disabled
}

func DefaultCacheConfig added in v0.2.46 

func DefaultCacheConfig() CacheConfig

func NewCacheConfigFromCtx added in v0.2.46 

func NewCacheConfigFromCtx(ctx context.Context) (*CacheConfig, error)

func NewCacheConfigFromEnv added in v0.2.46 

func NewCacheConfigFromEnv() *CacheConfig

func (*CacheConfig) ToString added in v0.2.46 

func (cc *CacheConfig) ToString() string

type CacheRow added in v0.2.46 

type CacheRow struct {
	Key        string
	Value      []byte
	Expires    time.Time
	LastAccess time.Time
	Url        string
}

type CacheStats added in v0.2.46 

type CacheStats struct {
	Hits   int64
	Misses int64
}

type ContextKey added in v0.2.15 

type ContextKey struct{}

type CreateJWTConfig added in v0.1.23 

type CreateJWTConfig func(credentials []byte, scopes ...string) (*jwt.Config, error)

type DBCache added in v0.2.46 

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

func NewDBCache added in v0.2.46 

func NewDBCache(ctx context.Context, cfg CacheConfig) (*DBCache, error)

TODO (ggreer): obey c1z-temp-dir CLI arg or environment variable

func (*DBCache) Clear added in v0.2.46 

func (d *DBCache) Clear(ctx context.Context) error

func (*DBCache) Get added in v0.2.46 

func (d *DBCache) Get(req *http.Request) (*http.Response, error)

Get returns cached response (if exists).

func (*DBCache) Set added in v0.2.46 

func (d *DBCache) Set(req *http.Request, value *http.Response) error

Set stores and save response in the db.

func (*DBCache) Stats added in v0.2.46 

func (d *DBCache) Stats(ctx context.Context) CacheStats

type DoOption added in v0.1.24 

type DoOption func(resp *WrapperResponse) error

func WithAlwaysJSONResponse added in v0.2.48 

func WithAlwaysJSONResponse(response interface{}) DoOption

Ignore content type header and always try to parse the response as JSON.

func WithErrorResponse added in v0.1.27 

func WithErrorResponse(resource ErrorResponse) DoOption

func WithJSONResponse added in v0.1.24 

func WithJSONResponse(response interface{}) DoOption

WithJSONResponse is a wrapper that marshals the returned response body into the provided shape. If the API should return an empty JSON body (i.e. HTTP status code 204 No Content), then pass a `nil` to `response`.

func WithRatelimitData added in v0.1.27 

func WithRatelimitData(resource *v2.RateLimitDescription) DoOption

func WithResponse added in v0.1.32 

func WithResponse(response interface{}) DoOption

func WithXMLResponse added in v0.1.28 

func WithXMLResponse(response interface{}) DoOption

type ErrorResponse added in v0.1.27 

type ErrorResponse interface {
	Message() string
}

type GoCache added in v0.2.15 

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

func NewGoCache added in v0.2.15 

func NewGoCache(ctx context.Context, cfg CacheConfig) (*GoCache, error)

func (*GoCache) Clear added in v0.2.15 

func (g *GoCache) Clear(ctx context.Context) error

func (*GoCache) Delete added in v0.2.15 

func (g *GoCache) Delete(key string) error

func (*GoCache) Get added in v0.2.15 

func (g *GoCache) Get(req *http.Request) (*http.Response, error)

func (*GoCache) Has added in v0.2.15 

func (g *GoCache) Has(key string) bool

func (*GoCache) Set added in v0.2.15 

func (g *GoCache) Set(req *http.Request, value *http.Response) error

func (*GoCache) Stats added in v0.2.46 

func (g *GoCache) Stats(ctx context.Context) CacheStats

type HttpClient added in v0.1.24 

type HttpClient interface {
	HttpClient() *http.Client
	Do(req *http.Request, options ...DoOption) (*http.Response, error)
	NewRequest(ctx context.Context, method string, url *url.URL, options ...RequestOption) (*http.Request, error)
}

type NoAuth added in v0.1.23 

type NoAuth struct{}

func (*NoAuth) GetClient added in v0.1.23 

func (n *NoAuth) GetClient(ctx context.Context, options ...Option) (*http.Client, error)

type NoopCache added in v0.2.46 

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

func NewNoopCache added in v0.2.46 

func NewNoopCache(ctx context.Context) *NoopCache

func (*NoopCache) Clear added in v0.2.46 

func (n *NoopCache) Clear(ctx context.Context) error

func (*NoopCache) Get added in v0.2.46 

func (g *NoopCache) Get(req *http.Request) (*http.Response, error)

func (*NoopCache) Set added in v0.2.46 

func (n *NoopCache) Set(req *http.Request, value *http.Response) error

func (*NoopCache) Stats added in v0.2.46 

func (n *NoopCache) Stats(ctx context.Context) CacheStats

type OAuth2ClientCredentials added in v0.1.23 

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

func NewOAuth2ClientCredentials added in v0.1.23 

func NewOAuth2ClientCredentials(clientId, clientSecret string, tokenURL *url.URL, scopes []string) *OAuth2ClientCredentials

func (*OAuth2ClientCredentials) GetClient added in v0.1.23 

func (o *OAuth2ClientCredentials) GetClient(ctx context.Context, options ...Option) (*http.Client, error)

type OAuth2JWT added in v0.1.23 

type OAuth2JWT struct {
	Credentials     []byte
	Scopes          []string
	CreateJWTConfig CreateJWTConfig
}

func NewOAuth2JWT added in v0.1.23 

func NewOAuth2JWT(credentials []byte, scopes []string, createfn CreateJWTConfig) *OAuth2JWT

func (*OAuth2JWT) GetClient added in v0.1.23 

func (o *OAuth2JWT) GetClient(ctx context.Context, options ...Option) (*http.Client, error)

type OAuth2RefreshToken added in v0.1.34 

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

func NewOAuth2RefreshToken added in v0.1.34 

func NewOAuth2RefreshToken(clientID, clientSecret, redirectURI, tokenURL, accessToken, refreshToken string, scopes []string) *OAuth2RefreshToken

func (*OAuth2RefreshToken) GetClient added in v0.1.34 

func (o *OAuth2RefreshToken) GetClient(ctx context.Context, options ...Option) (*http.Client, error)

type Option 

type Option interface {
	Apply(*Transport)
}

func WithLogger 

func WithLogger(log bool, logger *zap.Logger) Option

WithLogger sets a logger options to the transport layer.

func WithTLSClientConfig 

func WithTLSClientConfig(tlsConfig *tls.Config) Option

WithTLSClientConfig returns an Option that sets the TLS client configuration. `tlsConfig` is a structure that is used to configure a TLS client or server.

func WithUserAgent 

func WithUserAgent(userAgent string) Option

WithUserAgent sets a user agent option to the transport layer.

type RequestOption added in v0.1.24 

type RequestOption func() (io.ReadWriter, map[string]string, error)

func WithAccept added in v0.2.13 

func WithAccept(value string) RequestOption

func WithAcceptJSONHeader added in v0.1.24 

func WithAcceptJSONHeader() RequestOption

func WithAcceptVndJSONHeader added in v0.2.13 

func WithAcceptVndJSONHeader() RequestOption

func WithAcceptXMLHeader added in v0.1.28 

func WithAcceptXMLHeader() RequestOption

func WithContentType added in v0.2.13 

func WithContentType(ctype string) RequestOption

func WithContentTypeFormHeader added in v0.2.13 

func WithContentTypeFormHeader() RequestOption

func WithContentTypeJSONHeader added in v0.1.24 

func WithContentTypeJSONHeader() RequestOption

func WithContentTypeVndHeader added in v0.2.13 

func WithContentTypeVndHeader() RequestOption

func WithFormBody added in v0.2.13 

func WithFormBody(body string) RequestOption

func WithHeader added in v0.1.33 

func WithHeader(key, value string) RequestOption

func WithJSONBody added in v0.1.24 

func WithJSONBody(body interface{}) RequestOption

type Transport 

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

func NewTransport 

func NewTransport(ctx context.Context, options ...Option) (*Transport, error)

NewTransport creates a new Transport, applies the options, and then cycles the transport.

func (*Transport) RoundTrip 

func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

type WrapperOption added in v0.2.38 

type WrapperOption interface {
	Apply(*BaseHttpClient)
}

func WithRateLimiter added in v0.2.38 

func WithRateLimiter(rate int, per time.Duration) WrapperOption

WithRateLimiter returns a WrapperOption that sets the rate limiter for the http client. `rate` is the number of requests allowed per `per` duration. `per` is the duration in which the rate limit is enforced. Example: WithRateLimiter(10, time.Second) will allow 10 requests per second.

type WrapperResponse added in v0.1.27 

type WrapperResponse struct {
	Header     http.Header
	Body       []byte
	Status     string
	StatusCode int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.