utils

Documentation

Index

• Variables
• func FloatEquals(a, b float32) bool
• func IsRetryable(err error) bool
• func LogData(st string, data string)
• func RetrieveInfo(pr interface{}) string
• func RetryAll(err error) bool
• type ErrBadAccent
  • func NewErrBadAccent(badAccents []string) *ErrBadAccent
  • func (r *ErrBadAccent) Error() string
• type ErrBadSymbols
  • func NewErrBadSymbols(word, cleaned string) *ErrBadSymbols
  • func (r *ErrBadSymbols) Error() string
• type ErrTextTooLong
  • func NewErrTextTooLong(len, max int) *ErrTextTooLong
  • func (r *ErrTextTooLong) Error() string
• type ErrWordTooLong
  • func NewErrWordTooLong(word string) *ErrWordTooLong
  • func (r *ErrWordTooLong) Error() string
• type HTTPBackoff
  • func NewHTTPBackoff(realWrapper HTTPInvokerJSON, backoffF func() backoff.BackOff, ...) (*HTTPBackoff, error)
  • func (hw *HTTPBackoff) Info() string
  • func (hw *HTTPBackoff) InvokeJSON(dataIn interface{}, dataOut interface{}) error
  • func (hw *HTTPBackoff) InvokeJSONU(URL string, dataIn interface{}, dataOut interface{}) error
  • func (hw *HTTPBackoff) InvokeText(dataIn string, dataOut interface{}) error
• type HTTPInvokerJSON
• type HTTPWrap
  • func NewHTTPWrap(urlStr string) (*HTTPWrap, error)
  • func NewHTTPWrapT(urlStr string, timeout time.Duration) (*HTTPWrap, error)
  • func (hw *HTTPWrap) Info() string
  • func (hw *HTTPWrap) InvokeJSON(dataIn interface{}, dataOut interface{}) error
  • func (hw *HTTPWrap) InvokeJSONU(URL string, dataIn interface{}, dataOut interface{}) error
  • func (hw *HTTPWrap) InvokeText(dataIn string, dataOut interface{}) error
• type RequestTypeEnum
  • func (e RequestTypeEnum) String() string

Variables

var ErrNoInput = errors.New("no input")

ErrNoInput indicates no text input

var ErrNoRecord = errors.New("no record found")

ErrNoRecord indicates no record found error

var ErrTextDoesNotMatch = errors.New("wrong text")

ErrTextDoesNotMatch indicates old text does not match a new one

var MaxLogDataSize = 100

MaxLogDataSize indicates how many bytes of data to log

Functions

func FloatEquals

func FloatEquals(a, b float32) bool

FloatEquals compares two floats

func IsRetryable

func IsRetryable(err error) bool

IsRetryable - check if error is retryable io.EOF or timeout

func LogData

func LogData(st string, data string)

LogData logs data to debug

func RetrieveInfo

func RetrieveInfo(pr interface{}) string

RetrieveInfo invokes Info() if interface has one else returns ""

func RetryAll

func RetryAll(err error) bool

RetryAll - retries all errors

Types

type ErrBadAccent

type ErrBadAccent struct {
	BadAccents []string
}

ErrBadAccent indicate bad accent error

func NewErrBadAccent

func NewErrBadAccent(badAccents []string) *ErrBadAccent

NewErrBadAccent creates new error

func (*ErrBadAccent) Error

func (r *ErrBadAccent) Error() string

type ErrBadSymbols

type ErrBadSymbols struct {
	Orig, Cleaned string
}

ErrBadSymbols indicates a word with wrong symbols

func NewErrBadSymbols

func NewErrBadSymbols(word, cleaned string) *ErrBadSymbols

NewErrBadSymbols creates new error

func (*ErrBadSymbols) Error

func (r *ErrBadSymbols) Error() string

type ErrTextTooLong

type ErrTextTooLong struct {
	Max, Len int
}

ErrTextTooLong indicates too long input

func NewErrTextTooLong

func NewErrTextTooLong(len, max int) *ErrTextTooLong

NewErrTextTooLong creates new error

func (*ErrTextTooLong) Error

func (r *ErrTextTooLong) Error() string

type ErrWordTooLong

type ErrWordTooLong struct {
	Word string
}

ErrWordTooLong indicates too long word

func NewErrWordTooLong

func NewErrWordTooLong(word string) *ErrWordTooLong

NewErrWordTooLong creates new error

func (*ErrWordTooLong) Error

func (r *ErrWordTooLong) Error() string

type HTTPBackoff

type HTTPBackoff struct {
	HTTPClient HTTPInvokerJSON

	InvokeIndicatorFunc func(interface{})
	RetryIndicatorFunc  func(interface{})
	// contains filtered or unexported fields
}

HTTPBackoff http call with backoff

func NewHTTPBackoff

func NewHTTPBackoff(realWrapper HTTPInvokerJSON, backoffF func() backoff.BackOff, retryF func(error) bool) (*HTTPBackoff, error)

NewHTTPBackoff creates new wrapper with backoff errF must return same error or wrap to backoff.PermanentError to stop backoff

func (*HTTPBackoff) Info

func (hw *HTTPBackoff) Info() string

Info returns info about wrapper

func (*HTTPBackoff) InvokeJSON

func (hw *HTTPBackoff) InvokeJSON(dataIn interface{}, dataOut interface{}) error

InvokeJSON makes http call with json

func (*HTTPBackoff) InvokeJSONU

func (hw *HTTPBackoff) InvokeJSONU(URL string, dataIn interface{}, dataOut interface{}) error

InvokeJSONU makes call to URL wits JSON

func (*HTTPBackoff) InvokeText

func (hw *HTTPBackoff) InvokeText(dataIn string, dataOut interface{}) error

InvokeText makes http call with text input

type HTTPInvokerJSON

type HTTPInvokerJSON interface {
	InvokeJSONU(string, interface{}, interface{}) error
	InvokeJSON(interface{}, interface{}) error
	InvokeText(string, interface{}) error
}

HTTPInvokerJSON http POST invoker with JSON in, out params

type HTTPWrap

type HTTPWrap struct {
	HTTPClient *http.Client
	URL        string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

HTTPWrap for http call

func NewHTTPWrap

func NewHTTPWrap(urlStr string) (*HTTPWrap, error)

NewHTTPWrap creates new wrapper

func NewHTTPWrapT

func NewHTTPWrapT(urlStr string, timeout time.Duration) (*HTTPWrap, error)

NewHTTPWrapT creates new wrapper with timer

func (*HTTPWrap) Info

func (hw *HTTPWrap) Info() string

Info returns info about wrapper

func (*HTTPWrap) InvokeJSON

func (hw *HTTPWrap) InvokeJSON(dataIn interface{}, dataOut interface{}) error

InvokeJSON makes http call with json

func (*HTTPWrap) InvokeJSONU

func (hw *HTTPWrap) InvokeJSONU(URL string, dataIn interface{}, dataOut interface{}) error

InvokeJSONU makes http call to URL with JSON

func (*HTTPWrap) InvokeText

func (hw *HTTPWrap) InvokeText(dataIn string, dataOut interface{}) error

InvokeText makes http call with text

type RequestTypeEnum

type RequestTypeEnum int

RequestTypeEnum represent possible request types

const (
	//RequestOriginal value
	RequestOriginal RequestTypeEnum = iota + 1
	//RequestNormalized value - text after number replace
	RequestNormalized
	//RequestCleaned value - text after clean, normalize and url replace
	RequestCleaned
	//RequestUser value - data normalized by user
	RequestUser
	//RequestOriginalSSML value
	RequestOriginalSSML
)

func (RequestTypeEnum) String

func (e RequestTypeEnum) String() string