Documentation
¶
Index ¶
- func AddJitter(duration time.Duration, jitter time.Duration) time.Duration
- func CompleteJsonUnmarshal(b []byte, iface interface{}) error
- func DefaultIfBlank(str string, default_value string) string
- func JsonKeys(b []byte) ([]string, error)
- func NewMultiError(errs ...error) error
- func ParseBool(str string, default_ bool) bool
- func RandHex() string
- func RetryNWithBackoff(backoff Backoff, n int, fn func() error) error
- func RetryWithBackoff(backoff Backoff, fn func() error) error
- func SignHTTPRequest(req *http.Request, region, service string, creds *credentials.Credentials)
- func SlicesDeepEqual(slice1, slice2 interface{}) bool
- func StrSliceEqual(s1, s2 []string) bool
- func Strptr(s string) *string
- func Uint16SliceToStringSlice(slice []uint16) []*string
- func ZeroOrNil(obj interface{}) bool
- type Backoff
- type ChanSemaphore
- type DefaultRetriable
- type DefaultRetriableError
- type MultiErr
- type Retriable
- type RetriableError
- type Semaphore
- type SimpleBackoff
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddJitter ¶
AddJitter adds an amount of jitter between 0 and the given jitter to the given duration
func CompleteJsonUnmarshal ¶
CompleteJsonUnmarshal determines if a given struct has members corresponding to every key of a json object (passed as the json string). By default, Go ignores fields in an object which have no corresponding struct member and this can be used to determine if this ignoring has occured Errors will result in "false" as a return value
func DefaultIfBlank ¶
func JsonKeys ¶
JsonKeys takes an arbitrary byte array representing a json stringified object and returns all the keys of that object.
func NewMultiError ¶
func RetryNWithBackoff ¶
RetryNWithBackoff takes a Backoff, a maximum number of tries 'n', and a function that returns an error. The function is called until either it does not return an error or the maximum tries have been reached. If the error returned is Retriable, the Retriability of it will be respected. If the number of tries is exhausted, the last error will be returned.
func RetryWithBackoff ¶
RetryWithBackoff takes a Backoff and a function to call that returns an error If the error is nil then the function will no longer be called If the error is Retriable then that will be used to determine if it should be retried
func SignHTTPRequest ¶ added in v1.3.1
func SignHTTPRequest(req *http.Request, region, service string, creds *credentials.Credentials)
SignHTTPRequest signs an http.Request struct with authv4 using the given region, service, and credentials.
func SlicesDeepEqual ¶
func SlicesDeepEqual(slice1, slice2 interface{}) bool
SlicesDeepEqual checks if slice1 and slice2 are equal, disregarding order.
func StrSliceEqual ¶
func Uint16SliceToStringSlice ¶
Uint16SliceToStringSlice converts a slice of type uint16 to a slice of type *string. It uses strconv.Itoa on each element
Types ¶
type ChanSemaphore ¶
type ChanSemaphore struct {
Count int // Public for introspection; should not be written to
// contains filtered or unexported fields
}
Implements semaphore
func (*ChanSemaphore) Post ¶
func (s *ChanSemaphore) Post()
func (*ChanSemaphore) Wait ¶
func (s *ChanSemaphore) Wait()
type DefaultRetriable ¶
type DefaultRetriable struct {
// contains filtered or unexported fields
}
func (DefaultRetriable) Retry ¶
func (dr DefaultRetriable) Retry() bool
type DefaultRetriableError ¶
type DefaultRetriableError struct {
Retriable
// contains filtered or unexported fields
}
type RetriableError ¶
func NewRetriableError ¶
func NewRetriableError(retriable Retriable, err error) RetriableError
type SimpleBackoff ¶
type SimpleBackoff struct {
// contains filtered or unexported fields
}
func NewSimpleBackoff ¶
func NewSimpleBackoff(min, max time.Duration, jitterMultiple, multiple float64) *SimpleBackoff
NewSimpleBackoff creates a Backoff which ranges from min to max increasing by multiple each time. It also adds (and yes, the jitter is always added, never subtracted) a random amount of jitter up to jitterMultiple percent (that is, jitterMultiple = 0.0 is no jitter, 0.15 is 15% added jitter). The total time may exceed "max" when accounting for jitter, such that the absolute max is max + max * jiterMultiple
func (*SimpleBackoff) Duration ¶
func (sb *SimpleBackoff) Duration() time.Duration
func (*SimpleBackoff) Reset ¶
func (sb *SimpleBackoff) Reset()
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package atomic implements higher level constructs on top of the stdlib atomic package
|
Package atomic implements higher level constructs on top of the stdlib atomic package |
|
Package sync is an analogue to the stdlib sync package.
|
Package sync is an analogue to the stdlib sync package. |
|
Package ttime implements a testable alternative to the Go "time" package.
|
Package ttime implements a testable alternative to the Go "time" package. |