candiutils

Documentation

Index

• type HTTPRequest
  • func NewHTTPRequest(opts ...HTTPRequestOption) HTTPRequest
• type HTTPRequestOption
  • func HTTPRequestAddHystrixOptions(opts ...hystrix.Option) HTTPRequestOption
  • func HTTPRequestSetBreakerName(breakerName string) HTTPRequestOption
  • func HTTPRequestSetClient(cl *http.Client) HTTPRequestOption
  • func HTTPRequestSetHTTPErrorCodeThreshold(minHTTPStatusCode int) HTTPRequestOption
  • func HTTPRequestSetRetries(retries int) HTTPRequestOption
  • func HTTPRequestSetSleepBetweenRetry(sleepBetweenRetry time.Duration) HTTPRequestOption
  • func HTTPRequestSetTLS(tlsConfig *tls.Config) HTTPRequestOption
  • func HTTPRequestSetTimeout(timeout time.Duration) HTTPRequestOption
• type HTTPRequestResult
• type Locker
  • func NewRedisLocker(pool *redis.Pool) Locker
• type NoopLocker
  • func (NoopLocker) IsLocked(key string) bool
  • func (NoopLocker) Reset(key string)
  • func (NoopLocker) Unlock(key string)

Types

type HTTPRequest

type HTTPRequest interface {
	DoRequest(ctx context.Context, method, url string, requestBody []byte, headers map[string]string) (result *HTTPRequestResult, err error)
	Do(context context.Context, method, url string, reqBody []byte, headers map[string]string) (respBody []byte, respCode int, err error)
}

HTTPRequest interface

func NewHTTPRequest

func NewHTTPRequest(opts ...HTTPRequestOption) HTTPRequest

NewHTTPRequest function Request's Constructor

type HTTPRequestOption

type HTTPRequestOption func(*httpRequestImpl)

HTTPRequestOption func type

func HTTPRequestAddHystrixOptions

func HTTPRequestAddHystrixOptions(opts ...hystrix.Option) HTTPRequestOption

HTTPRequestAddHystrixOptions option func

func HTTPRequestSetBreakerName

func HTTPRequestSetBreakerName(breakerName string) HTTPRequestOption

HTTPRequestSetBreakerName option func

func HTTPRequestSetClient

func HTTPRequestSetClient(cl *http.Client) HTTPRequestOption

HTTPRequestSetClient option func

func HTTPRequestSetHTTPErrorCodeThreshold

func HTTPRequestSetHTTPErrorCodeThreshold(minHTTPStatusCode int) HTTPRequestOption

HTTPRequestSetHTTPErrorCodeThreshold option func, set minimum http response code for return error when exec client request

func HTTPRequestSetRetries

func HTTPRequestSetRetries(retries int) HTTPRequestOption

HTTPRequestSetRetries option func

func HTTPRequestSetSleepBetweenRetry

func HTTPRequestSetSleepBetweenRetry(sleepBetweenRetry time.Duration) HTTPRequestOption

HTTPRequestSetSleepBetweenRetry option func

func HTTPRequestSetTLS

func HTTPRequestSetTLS(tlsConfig *tls.Config) HTTPRequestOption

HTTPRequestSetTLS option func

func HTTPRequestSetTimeout

func HTTPRequestSetTimeout(timeout time.Duration) HTTPRequestOption

HTTPRequestSetTimeout option func

type HTTPRequestResult

type HTTPRequestResult struct {
	*bytes.Buffer
	RespCode int
}

HTTPRequestResult struct

type Locker

type Locker interface {
	IsLocked(key string) bool
	Unlock(key string)
	Reset(key string)
}

Locker abstraction, lock concurrent processs

func NewRedisLocker

func NewRedisLocker(pool *redis.Pool) Locker

NewRedisLocker constructor

type NoopLocker

type NoopLocker struct{}

NoopLocker empty locker

func (NoopLocker) IsLocked

func (NoopLocker) IsLocked(key string) bool

IsLocked method

func (NoopLocker) Reset

func (NoopLocker) Reset(key string)

Reset method

func (NoopLocker) Unlock

func (NoopLocker) Unlock(key string)

Unlock method