candiutils

Documentation

Index

• type HTTPRequest
  • func NewHTTPRequest(opts ...HTTPRequestOption) HTTPRequest
• type 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 NoopLocker
  • func (NoopLocker) Disconnect(context.Context) error
  • func (NoopLocker) HasBeenLocked(string) bool
  • func (NoopLocker) IsLocked(string) bool
  • func (NoopLocker) Lock(string, time.Duration) (func(), error)
  • func (NoopLocker) Reset(string)
  • func (NoopLocker) Unlock(string)
• type RedisLocker
  • func NewRedisLocker(pool *redis.Pool) *RedisLocker
  • func (r *RedisLocker) Disconnect(ctx context.Context) error
  • func (r *RedisLocker) HasBeenLocked(key string) bool
  • func (r *RedisLocker) IsLocked(key string) bool
  • func (r *RedisLocker) Lock(key string, timeout time.Duration) (unlockFunc func(), err error)
  • func (r *RedisLocker) Reset(key string)
  • func (r *RedisLocker) Unlock(key string)
• type SyncPool
  • func NewSyncPool[T any](newFunc func() T, onPut func(T)) SyncPool[T]
  • func (s *SyncPool[T]) Get() T
  • func (s *SyncPool[T]) Put(x T)
• type WorkerPool
  • func NewWorkerPool[T any](maxWorker int) WorkerPool[T]

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 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 NoopLocker

type NoopLocker struct{}

NoopLocker empty locker

func (NoopLocker) Disconnect

func (NoopLocker) Disconnect(context.Context) error

func (NoopLocker) HasBeenLocked

func (NoopLocker) HasBeenLocked(string) bool

HasBeenLocked method

func (NoopLocker) IsLocked

func (NoopLocker) IsLocked(string) bool

IsLocked method

func (NoopLocker) Lock

func (NoopLocker) Lock(string, time.Duration) (func(), error)

Lock method

func (NoopLocker) Reset

func (NoopLocker) Reset(string)

Reset method

func (NoopLocker) Unlock

func (NoopLocker) Unlock(string)

Unlock method

type RedisLocker

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

RedisLocker lock using redis

func NewRedisLocker

func NewRedisLocker(pool *redis.Pool) *RedisLocker

NewRedisLocker constructor

func (*RedisLocker) Disconnect

func (r *RedisLocker) Disconnect(ctx context.Context) error

Disconnect close and reset

func (*RedisLocker) HasBeenLocked

func (r *RedisLocker) HasBeenLocked(key string) bool

func (*RedisLocker) IsLocked

func (r *RedisLocker) IsLocked(key string) bool

func (*RedisLocker) Lock

func (r *RedisLocker) Lock(key string, timeout time.Duration) (unlockFunc func(), err error)

Lock method

func (*RedisLocker) Reset

func (r *RedisLocker) Reset(key string)

Reset method

func (*RedisLocker) Unlock

func (r *RedisLocker) Unlock(key string)

Unlock method

type SyncPool

type SyncPool[T any] struct {
	// contains filtered or unexported fields
}

func NewSyncPool

func NewSyncPool[T any](newFunc func() T, onPut func(T)) SyncPool[T]

func (*SyncPool[T]) Get

func (s *SyncPool[T]) Get() T

func (*SyncPool[T]) Put

func (s *SyncPool[T]) Put(x T)

type WorkerPool

type WorkerPool[T any] interface {
	Dispatch(ctx context.Context, jobFunc func(context.Context, T))
	AddJob(job T)
	Finish()
}

WorkerPool implementation

func NewWorkerPool

func NewWorkerPool[T any](maxWorker int) WorkerPool[T]

NewWorkerPool create an instance of WorkerPool.