Documentation ¶
Index ¶
- Constants
- func Bool(a bool) *bool
- func BoolSlice(a []bool) []*bool
- func BoolSliceValue(a []*bool) []bool
- func BoolValue(a *bool) bool
- func Convert(in interface{}, out interface{}) error
- func Float32(a float32) *float32
- func Float32Slice(a []float32) []*float32
- func Float32Value(a *float32) float32
- func Float32ValueSlice(a []*float32) []float32
- func Float64(a float64) *float64
- func Float64Slice(a []float64) []*float64
- func Float64Value(a *float64) float64
- func Float64ValueSlice(a []*float64) []float64
- func GetBackoffDelay(options *RetryOptions, ctx *RetryPolicyContext) *int64
- func Int(a int) *int
- func Int16(a int16) *int16
- func Int16Slice(a []int16) []*int16
- func Int16Value(a *int16) int16
- func Int16ValueSlice(a []*int16) []int16
- func Int32(a int32) *int32
- func Int32Slice(a []int32) []*int32
- func Int32Value(a *int32) int32
- func Int32ValueSlice(a []*int32) []int32
- func Int64(a int64) *int64
- func Int64Slice(a []int64) []*int64
- func Int64Value(a *int64) int64
- func Int64ValueSlice(a []*int64) []int64
- func Int8(a int8) *int8
- func Int8Slice(a []int8) []*int8
- func Int8Value(a *int8) int8
- func Int8ValueSlice(a []*int8) []int8
- func IntSlice(a []int) []*int
- func IntValue(a *int) int
- func IntValueSlice(a []*int) []int
- func Merge(args ...interface{}) map[string]*string
- func Prettify(i interface{}) string
- func Recover(in interface{}) error
- func Retryable(err error) *bool
- func ShouldRetry(options *RetryOptions, ctx *RetryPolicyContext) *bool
- func Sleep(backoffTime *int64)
- func String(a string) *string
- func StringSlice(a []string) []*string
- func StringSliceValue(a []*string) []string
- func StringValue(a *string) string
- func ToInt(a *int32) *int
- func ToInt32(a *int) *int32
- func ToMap(args ...interface{}) map[string]interface{}
- func ToObject(obj interface{}) map[string]interface{}
- func ToReader(obj interface{}) io.Reader
- func ToString(val interface{}) string
- func TransInterfaceToBool(val interface{}) *bool
- func TransInterfaceToInt(val interface{}) *int
- func TransInterfaceToInt64(val interface{}) *int64
- func TransInterfaceToString(val interface{}) *string
- func Uint(a uint) *uint
- func Uint16(a uint16) *uint16
- func Uint16Slice(a []uint16) []*uint16
- func Uint16Value(a *uint16) uint16
- func Uint16ValueSlice(a []*uint16) []uint16
- func Uint32(a uint32) *uint32
- func Uint32Slice(a []uint32) []*uint32
- func Uint32Value(a *uint32) uint32
- func Uint32ValueSlice(a []*uint32) []uint32
- func Uint64(a uint64) *uint64
- func Uint64Slice(a []uint64) []*uint64
- func Uint64Value(a *uint64) uint64
- func Uint64ValueSlice(a []*uint64) []uint64
- func Uint8(a uint8) *uint8
- func Uint8Slice(a []uint8) []*uint8
- func Uint8Value(a *uint8) uint8
- func Uint8ValueSlice(a []*uint8) []uint8
- func UintSlice(a []uint) []*uint
- func UintValue(a *uint) uint
- func UintValueSlice(a []*uint) []uint
- func Validate(params interface{}) error
- type BackoffPolicy
- type BaseError
- type CastError
- type EqualJitterBackoffPolicy
- type ExponentialBackoffPolicy
- type FixedBackoffPolicy
- type FullJitterBackoffPolicy
- type RandomBackoffPolicy
- type Request
- type Response
- type RetryCondition
- type RetryOptions
- type RetryPolicyContext
- type RuntimeObject
- type SDKError
Constants ¶
View Source
const ( // DefaultMaxAttempts sets maximum number of retries DefaultMaxAttempts = 3 // DefaultMinDelay sets minimum retry delay DefaultMinDelay = 100 * time.Millisecond // DefaultMaxDelayTimeMillis sets maximum retry delay DefaultMaxDelay = 120 * time.Second )
Variables ¶
This section is empty.
Functions ¶
func BoolSliceValue ¶
func Convert ¶
func Convert(in interface{}, out interface{}) error
Convert is use convert map[string]interface object to struct
func Float32Slice ¶
func Float32Value ¶
func Float32ValueSlice ¶
func Float64Slice ¶
func Float64Value ¶
func Float64ValueSlice ¶
func GetBackoffDelay ¶
func GetBackoffDelay(options *RetryOptions, ctx *RetryPolicyContext) *int64
func Int16Slice ¶
func Int16Value ¶
func Int16ValueSlice ¶
func Int32Slice ¶
func Int32Value ¶
func Int32ValueSlice ¶
func Int64Slice ¶
func Int64Value ¶
func Int64ValueSlice ¶
func Int8ValueSlice ¶
func IntValueSlice ¶
func ShouldRetry ¶
func ShouldRetry(options *RetryOptions, ctx *RetryPolicyContext) *bool
func StringSlice ¶
func StringSliceValue ¶
func StringValue ¶
func TransInterfaceToBool ¶
func TransInterfaceToBool(val interface{}) *bool
func TransInterfaceToInt ¶
func TransInterfaceToInt(val interface{}) *int
func TransInterfaceToInt64 ¶
func TransInterfaceToInt64(val interface{}) *int64
func TransInterfaceToString ¶
func TransInterfaceToString(val interface{}) *string
func Uint16Slice ¶
func Uint16Value ¶
func Uint16ValueSlice ¶
func Uint32Slice ¶
func Uint32Value ¶
func Uint32ValueSlice ¶
func Uint64Slice ¶
func Uint64Value ¶
func Uint64ValueSlice ¶
func Uint8Slice ¶
func Uint8Value ¶
func Uint8ValueSlice ¶
func UintValueSlice ¶
Types ¶
type BackoffPolicy ¶
type BackoffPolicy interface {
GetDelayTimeMillis(ctx *RetryPolicyContext) *int64
}
func NewBackoffPolicy ¶
func NewBackoffPolicy(options map[string]interface{}) (backoffPolicy BackoffPolicy)
type BaseError ¶
type BaseError interface { error ErrorName() *string ErrorCode() *string RetryAfterTimeMillis() *int64 }
BaseError is an interface for getting actual error
type CastError ¶
CastError is used for cast type fails
func NewCastError ¶
NewCastError is used for cast type fails
func (*CastError) RetryAfterTimeMillis ¶
type EqualJitterBackoffPolicy ¶
func (*EqualJitterBackoffPolicy) GetDelayTimeMillis ¶
func (equalJitterBackoff *EqualJitterBackoffPolicy) GetDelayTimeMillis(ctx *RetryPolicyContext) *int64
type ExponentialBackoffPolicy ¶
func (*ExponentialBackoffPolicy) GetDelayTimeMillis ¶
func (exponentialBackoff *ExponentialBackoffPolicy) GetDelayTimeMillis(ctx *RetryPolicyContext) *int64
type FixedBackoffPolicy ¶
type FixedBackoffPolicy struct {
Period *int
}
func (*FixedBackoffPolicy) GetDelayTimeMillis ¶
func (fixedBackoff *FixedBackoffPolicy) GetDelayTimeMillis(ctx *RetryPolicyContext) *int64
type FullJitterBackoffPolicy ¶
func (*FullJitterBackoffPolicy) GetDelayTimeMillis ¶
func (fullJitterBackof *FullJitterBackoffPolicy) GetDelayTimeMillis(ctx *RetryPolicyContext) *int64
type RandomBackoffPolicy ¶
func (*RandomBackoffPolicy) GetDelayTimeMillis ¶
func (randomBackoff *RandomBackoffPolicy) GetDelayTimeMillis(ctx *RetryPolicyContext) *int64
type Request ¶
type Request struct { Protocol *string Port *int Method *string Pathname *string Domain *string Headers map[string]*string Query map[string]*string Body io.Reader }
Request is used wrap http request
type Response ¶
type Response struct { Body io.ReadCloser StatusCode *int StatusMessage *string Headers map[string]*string }
Response is use d wrap http response
func DoRequest ¶
func DoRequest(request *Request, runtimeObject *RuntimeObject) (response *Response, err error)
DoRequest is used send request to server
func NewResponse ¶
NewResponse is create response with http response
type RetryCondition ¶
type RetryCondition struct { MaxAttempts *int MaxDelayTimeMillis *int64 Backoff *BackoffPolicy Exception []*string ErrorCode []*string }
type RetryOptions ¶
type RetryOptions struct { Retryable *bool RetryCondition []*RetryCondition NoRetryCondition []*RetryCondition }
type RetryPolicyContext ¶
type RuntimeObject ¶
type RuntimeObject struct { IgnoreSSL *bool `json:"ignoreSSL" xml:"ignoreSSL"` ReadTimeout *int `json:"readTimeout" xml:"readTimeout"` ConnectTimeout *int `json:"connectTimeout" xml:"connectTimeout"` LocalAddr *string `json:"localAddr" xml:"localAddr"` HttpProxy *string `json:"httpProxy" xml:"httpProxy"` HttpsProxy *string `json:"httpsProxy" xml:"httpsProxy"` NoProxy *string `json:"noProxy" xml:"noProxy"` MaxIdleConns *int `json:"maxIdleConns" xml:"maxIdleConns"` Key *string `json:"key" xml:"key"` Cert *string `json:"cert" xml:"cert"` CA *string `json:"ca" xml:"ca"` Socks5Proxy *string `json:"socks5Proxy" xml:"socks5Proxy"` Socks5NetWork *string `json:"socks5NetWork" xml:"socks5NetWork"` Listener utils.ProgressListener `json:"listener" xml:"listener"` Tracker *utils.ReaderTracker `json:"tracker" xml:"tracker"` Logger *utils.Logger `json:"logger" xml:"logger"` RetryOptions *RetryOptions `json:"retryOptions" xml:"retryOptions"` }
RuntimeObject is used for converting http configuration
func NewRuntimeObject ¶
func NewRuntimeObject(runtime map[string]interface{}) *RuntimeObject
NewRuntimeObject is used for shortly create runtime object
type SDKError ¶
type SDKError struct { Code *string StatusCode *int Message *string Data *string Stack *string Description *string AccessDeniedDetail map[string]interface{} // contains filtered or unexported fields }
SDKError struct is used save error code and message
func NewSDKError ¶
NewSDKError is used for shortly create SDKError object
func (*SDKError) RetryAfterTimeMillis ¶
Click to show internal directories.
Click to hide internal directories.