util

Documentation

Index

• Constants
• Variables
• func BeginningOfTheDay(t time.Time) time.Time
• func FormatFloat(val float64, prec int) string
• func FormatValue(val fixedpoint.Value, prec int) string
• func GetEnvVarBool(n string) (bool, bool)
• func GetEnvVarDuration(n string) (time.Duration, bool)
• func GetEnvVarInt(n string) (int, bool)
• func MaskKey(key string) string
• func MillisecondsJitter(d time.Duration, jitterInMilliseconds int) time.Duration
• func MustParseFloat(s string) float64
• func NewValidLimiter(r rate.Limit, b int) (*rate.Limiter, error)
• func NotZero(v float64) bool
• func Over24Hours(since time.Time) bool
• func ParseFloat(s string) (float64, error)
• func ParseTimeWithFormats(strTime string, formats []string) (time.Time, error)
• func Pow10(n int64) int64
• func Render(tpl string, args interface{}) string
• func Retry(ctx context.Context, attempts int, duration time.Duration, ...) (err error)
• func SetEnvVarBool(n string, v *bool) bool
• func ShouldDelay(l *rate.Limiter, minInterval time.Duration) time.Duration
• func StringSliceContains(slice []string, needle string) bool
• func UnixMilli() int64
• func Zero(v float64) bool
• type Reonce
  • func (o *Reonce) Do(f func())
  • func (o *Reonce) Reset()
• type Response
  • func NewResponse(r *http.Response) (response *Response, err error)
  • func (r *Response) DecodeJSON(o interface{}) error
  • func (r *Response) IsError() bool
  • func (r *Response) IsHTML() bool
  • func (r *Response) IsJSON() bool
  • func (r *Response) String() string
• type RetryPredicator
• type TimeProfile
  • func StartTimeProfile() TimeProfile
  • func (p *TimeProfile) Stop() time.Duration
  • func (p *TimeProfile) TilNow() time.Duration
• type VolatileMemory
  • func NewDetectorCache() *VolatileMemory
  • func (i *VolatileMemory) IsObjectFresh(obj interface{}, ttl time.Duration) bool
  • func (i *VolatileMemory) IsTextFresh(text string, ttl time.Duration) bool

Constants

const (
	InfiniteRetry = 0
)

const MaxDigits = 18 // MAX_INT64 ~ 9 * 10^18

Variables

var Pow10Table = [MaxDigits + 1]int64{
	1, 1e1, 1e2, 1e3, 1e4, 1e5, 1e6, 1e7, 1e8, 1e9, 1e10, 1e11, 1e12, 1e13, 1e14, 1e15, 1e16, 1e17, 1e18,
}

Functions

func BeginningOfTheDay

func BeginningOfTheDay(t time.Time) time.Time

func FormatFloat

func FormatFloat(val float64, prec int) string

func FormatValue

func FormatValue(val fixedpoint.Value, prec int) string

func GetEnvVarBool

func GetEnvVarBool(n string) (bool, bool)

func GetEnvVarDuration

func GetEnvVarDuration(n string) (time.Duration, bool)

func GetEnvVarInt

func GetEnvVarInt(n string) (int, bool)

func MaskKey

func MaskKey(key string) string

func MillisecondsJitter

func MillisecondsJitter(d time.Duration, jitterInMilliseconds int) time.Duration

func MustParseFloat

func MustParseFloat(s string) float64

func NewValidLimiter

func NewValidLimiter(r rate.Limit, b int) (*rate.Limiter, error)

func NotZero

func NotZero(v float64) bool

func Over24Hours

func Over24Hours(since time.Time) bool

func ParseFloat

func ParseFloat(s string) (float64, error)

func ParseTimeWithFormats

func ParseTimeWithFormats(strTime string, formats []string) (time.Time, error)

func Pow10

func Pow10(n int64) int64

func Render

func Render(tpl string, args interface{}) string

func Retry

func Retry(ctx context.Context, attempts int, duration time.Duration, fnToRetry func() error, errHandler func(error), predicators ...RetryPredicator) (err error)

Retry retrys the passed function for "attempts" times, if passed function return error. Setting attempts to zero means keep retrying.

func SetEnvVarBool

func SetEnvVarBool(n string, v *bool) bool

func ShouldDelay

func ShouldDelay(l *rate.Limiter, minInterval time.Duration) time.Duration

func StringSliceContains

func StringSliceContains(slice []string, needle string) bool

func UnixMilli

func UnixMilli() int64

func Zero

func Zero(v float64) bool

Types

type Reonce

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

func (*Reonce) Do

func (o *Reonce) Do(f func())

func (*Reonce) Reset

func (o *Reonce) Reset()

type Response

type Response struct {
	*http.Response

	// Body overrides the composited Body field.
	Body []byte
}

Response is wrapper for standard http.Response and provides more methods.

func NewResponse

func NewResponse(r *http.Response) (response *Response, err error)

NewResponse is a wrapper of the http.Response instance, it reads the response body and close the file.

func (*Response) DecodeJSON

func (r *Response) DecodeJSON(o interface{}) error

func (*Response) IsError

func (r *Response) IsError() bool

func (*Response) IsHTML

func (r *Response) IsHTML() bool

func (*Response) IsJSON

func (r *Response) IsJSON() bool

func (*Response) String

func (r *Response) String() string

String converts response body to string. An empty string will be returned if error.

type RetryPredicator

type RetryPredicator func(e error) bool

type TimeProfile

type TimeProfile struct {
	StartTime, EndTime time.Time
	Duration           time.Duration
}

func StartTimeProfile

func StartTimeProfile() TimeProfile

func (*TimeProfile) Stop

func (p *TimeProfile) Stop() time.Duration

func (*TimeProfile) TilNow

func (p *TimeProfile) TilNow() time.Duration

type VolatileMemory

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

func NewDetectorCache

func NewDetectorCache() *VolatileMemory

func (*VolatileMemory) IsObjectFresh

func (i *VolatileMemory) IsObjectFresh(obj interface{}, ttl time.Duration) bool

func (*VolatileMemory) IsTextFresh

func (i *VolatileMemory) IsTextFresh(text string, ttl time.Duration) bool