aws

package

Go to main page

Versions in this module

v0

v0.23.3

Jun 25, 2020

v0.23.2

Jun 25, 2020

Changes in this version

+ const ParamFormatErrCode

+ const ParamMaxLenErrCode

+ var DefaultDialConnectTimeout = 30 * time.Second

+ var DefaultDialKeepAliveTimeout = 30 * time.Second

+ var DefaultHTTPTransportExpectContinueTimeout = 1 * time.Second

+ var DefaultHTTPTransportIdleConnTimeout = 90 * time.Second

+ var DefaultHTTPTransportMaxIdleConns = 100

+ var DefaultHTTPTransportMaxIdleConnsPerHost = 10

+ var DefaultHTTPTransportTLSHandleshakeTimeout = 10 * time.Second

+ func Float32(v float32) *float32

+ func Float32Map(src map[string]float32) map[string]*float32

+ func Float32Slice(src []float32) []*float32

+ func Float32Value(v *float32) float32

+ func Float32ValueMap(src map[string]*float32) map[string]float32

+ func Float32ValueSlice(src []*float32) []float32

+ func Int16(v int16) *int16

+ func Int16Map(src map[string]int16) map[string]*int16

+ func Int16Slice(src []int16) []*int16

+ func Int16Value(v *int16) int16

+ func Int16ValueMap(src map[string]*int16) map[string]int16

+ func Int16ValueSlice(src []*int16) []int16

+ func Int32(v int32) *int32

+ func Int32Map(src map[string]int32) map[string]*int32

+ func Int32Slice(src []int32) []*int32

+ func Int32Value(v *int32) int32

+ func Int32ValueMap(src map[string]*int32) map[string]int32

+ func Int32ValueSlice(src []*int32) []int32

+ func Int8(v int8) *int8

+ func Int8Map(src map[string]int8) map[string]*int8

+ func Int8Slice(src []int8) []*int8

+ func Int8Value(v *int8) int8

+ func Int8ValueMap(src map[string]*int8) map[string]int8

+ func Int8ValueSlice(src []*int8) []int8

+ func IsReaderSeekable(r io.Reader) bool

+ func SanitizeHostForHeader(r *http.Request)

+ func SeekerLen(s io.Seeker) (int64, error)

+ func Uint(v uint) *uint

+ func Uint16(v uint16) *uint16

+ func Uint16Map(src map[string]uint16) map[string]*uint16

+ func Uint16Slice(src []uint16) []*uint16

+ func Uint16Value(v *uint16) uint16

+ func Uint16ValueMap(src map[string]*uint16) map[string]uint16

+ func Uint16ValueSlice(src []*uint16) []uint16

+ func Uint32(v uint32) *uint32

+ func Uint32Map(src map[string]uint32) map[string]*uint32

+ func Uint32Slice(src []uint32) []*uint32

+ func Uint32Value(v *uint32) uint32

+ func Uint32ValueMap(src map[string]*uint32) map[string]uint32

+ func Uint32ValueSlice(src []*uint32) []uint32

+ func Uint64(v uint64) *uint64

+ func Uint64Map(src map[string]uint64) map[string]*uint64

+ func Uint64Slice(src []uint64) []*uint64

+ func Uint64Value(v *uint64) uint64

+ func Uint64ValueMap(src map[string]*uint64) map[string]uint64

+ func Uint64ValueSlice(src []*uint64) []uint64

+ func Uint8(v uint8) *uint8

+ func Uint8Map(src map[string]uint8) map[string]*uint8

+ func Uint8Slice(src []uint8) []*uint8

+ func Uint8Value(v *uint8) uint8

+ func Uint8ValueMap(src map[string]*uint8) map[string]uint8

+ func Uint8ValueSlice(src []*uint8) []uint8

+ func UintMap(src map[string]uint) map[string]*uint

+ func UintSlice(src []uint) []*uint

+ func UintValue(v *uint) uint

+ func UintValueMap(src map[string]*uint) map[string]uint

+ func UintValueSlice(src []*uint) []uint

+ type BuildableHTTPClient struct

+ func NewBuildableHTTPClient() *BuildableHTTPClient

+ func (b *BuildableHTTPClient) Do(req *http.Request) (*http.Response, error)

+ func (b *BuildableHTTPClient) GetDialer() *net.Dialer

+ func (b *BuildableHTTPClient) GetTimeout() time.Duration

+ func (b *BuildableHTTPClient) GetTransport() *http.Transport

+ func (b *BuildableHTTPClient) WithDialerOptions(opts ...func(*net.Dialer)) HTTPClient

+ func (b *BuildableHTTPClient) WithTimeout(timeout time.Duration) HTTPClient

+ func (b *BuildableHTTPClient) WithTransportOptions(opts ...func(*http.Transport)) HTTPClient

type Config

+ ConfigSources []interface{}

+ DisableEndpointHostPrefix bool

+ EnableEndpointDiscovery bool

+ type DeserializationError struct

+ Err error

+ func (e *DeserializationError) Error() string

+ func (e *DeserializationError) Unwrap() error

type Endpoint

+ PartitionID string

type ErrInvalidParam

+ Code func() string

+ Error func() string

+ Message func() string

type ErrInvalidParams

+ func (e ErrInvalidParams) Errs() []error

+ type ErrParamFormat struct

+ func NewErrParamFormat(field string, format, value string) *ErrParamFormat

+ func (e *ErrParamFormat) AddNestedContext(ctx string)

+ func (e *ErrParamFormat) Code() string

+ func (e *ErrParamFormat) Error() string

+ func (e *ErrParamFormat) Field() string

+ func (e *ErrParamFormat) Format() string

+ func (e *ErrParamFormat) Message() string

+ func (e *ErrParamFormat) SetContext(ctx string)

+ type ErrParamMaxLen struct

+ func NewErrParamMaxLen(field string, max int, value string) *ErrParamMaxLen

+ func (e *ErrParamMaxLen) AddNestedContext(ctx string)

+ func (e *ErrParamMaxLen) Code() string

+ func (e *ErrParamMaxLen) Error() string

+ func (e *ErrParamMaxLen) Field() string

+ func (e *ErrParamMaxLen) MaxLen() int

+ func (e *ErrParamMaxLen) Message() string

+ func (e *ErrParamMaxLen) SetContext(ctx string)

+ type HTTPClient interface

+ Do func(*http.Request) (*http.Response, error)

+ type HTTPResponseError struct

+ Response *http.Response

+ func (e *HTTPResponseError) Error() string

+ func (e *HTTPResponseError) StatusCode() int

type HandlerList

+ func (l *HandlerList) Swap(name string, replace NamedHandler) bool

type Handlers

+ CompleteAttempt HandlerList

+ ShouldRetry HandlerList

+ type MaxAttemptsError struct

+ Attempt int

+ Err error

+ func (e *MaxAttemptsError) Error() string

+ func (e *MaxAttemptsError) Unwrap() error

type Metadata

+ EndpointsID string

+ ServiceID string

+ type MissingEndpointError struct

+ func (*MissingEndpointError) Error() string

+ type MissingRegionError struct

+ func (*MissingRegionError) Error() string

+ type NoOpRetryer struct

+ func (NoOpRetryer) GetInitialToken() func(error) error

+ func (NoOpRetryer) GetRetryToken(context.Context, error) (func(error) error, error)

+ func (NoOpRetryer) IsErrorRetryable(error) bool

+ func (NoOpRetryer) MaxAttempts() int

+ func (NoOpRetryer) RetryDelay(int, error) (time.Duration, error)

type ReaderSeekerCloser

+ func (r ReaderSeekerCloser) GetLen() (int64, error)

+ func (r ReaderSeekerCloser) HasLen() (int, bool)

type Request

+ AttemptClockSkews []time.Duration

+ AttemptNum int

+ AttemptTime time.Time

+ Endpoint Endpoint

+ InvocationID string

+ ResponseAt time.Time

+ Retryer Retryer

+ ShouldRetry bool

+ ThrottleErrorCodes []string

+ func (r *Request) SetEndpoint(endpoint Endpoint)

+ type RequestCanceledError struct

+ Err error

+ func (*RequestCanceledError) CanceledError() bool

+ func (e *RequestCanceledError) Error() string

+ func (e *RequestCanceledError) Unwrap() error

+ type RequestSendError struct

+ Err error

+ Response interface{}

+ func (e *RequestSendError) ConnectionError() bool

+ func (e *RequestSendError) Error() string

+ func (e *RequestSendError) Unwrap() error

+ type ResponseTimeoutError struct

+ TimeoutDur time.Duration

+ func (*ResponseTimeoutError) Timeout() bool

+ func (e *ResponseTimeoutError) Error() string

type Retryer

+ GetInitialToken func() (releaseToken func(error) error)

+ GetRetryToken func(ctx context.Context, opErr error) (releaseToken func(error) error, err error)

+ IsErrorRetryable func(error) bool

+ MaxAttempts func() int

+ RetryDelay func(attempt int, opErr error) (time.Duration, error)

+ type SerializationError struct

+ Err error

+ func (e *SerializationError) Error() string

+ func (e *SerializationError) Unwrap() error

+ type StaticCredentialsEmptyError struct

+ func (*StaticCredentialsEmptyError) Error() string

+ type Ternary int

+ const FalseTernary

+ const TrueTernary

+ const UnknownTernary

+ func BoolTernary(v bool) Ternary

+ func (t Ternary) Bool() bool

+ func (t Ternary) String() string

type Waiter

+ func (w Waiter) Wait(ctx context.Context) error

v0.4.0

May 26, 2018

Changes in this version

type Endpoint

+ SigningNameDerived bool

v0.3.0

Mar 8, 2018

Changes in this version

+ const ErrCodeRequestCanceled

+ type Pager struct

+ NewRequest func() (*Request, error)

+ func (p *Pager) CurrentPage() interface{}

+ func (p *Pager) Err() error

+ func (p *Pager) Next() bool

v0.2.0

Jan 15, 2018

v0.1.0

Dec 21, 2017

Changes in this version

+ const CanceledErrorCode

+ const ErrCodeRead

+ const ErrCodeResponseTimeout

+ const ErrCodeSerialization

+ const HandlerResponseTimeout

+ const InvalidParameterErrCode

+ const ParamMinLenErrCode

+ const ParamMinValueErrCode

+ const ParamRequiredErrCode

+ const SDKName

+ const SDKVersion

+ const StaticCredentialsProviderName

+ const WaiterResourceNotReadyErrorCode

+ var AnonymousCredentials = StaticCredentialsProvider

+ var ErrMissingEndpoint = awserr.New("MissingEndpoint", "'Endpoint' configuration is required for this service", ...)

+ var ErrMissingRegion = awserr.New("MissingRegion", "could not find region configuration", nil)

+ var ErrStaticCredentialsEmpty = awserr.New("EmptyStaticCreds", "static credentials are empty", nil)

+ var NeverExpire = time.Unix(math.MaxInt64, 0)

+ var NoBody = http.NoBody

+ func AddToUserAgent(r *Request, s string)

+ func Bool(v bool) *bool

+ func BoolMap(src map[string]bool) map[string]*bool

+ func BoolSlice(src []bool) []*bool

+ func BoolValue(v *bool) bool

+ func BoolValueMap(src map[string]*bool) map[string]bool

+ func BoolValueSlice(src []*bool) []bool

+ func Float64(v float64) *float64

+ func Float64Map(src map[string]float64) map[string]*float64

+ func Float64Slice(src []float64) []*float64

+ func Float64Value(v *float64) float64

+ func Float64ValueMap(src map[string]*float64) map[string]float64

+ func Float64ValueSlice(src []*float64) []float64

+ func HandlerListLogItem(item HandlerListRunItem) bool

+ func HandlerListStopOnError(item HandlerListRunItem) bool

+ func Int(v int) *int

+ func Int64(v int64) *int64

+ func Int64Map(src map[string]int64) map[string]*int64

+ func Int64Slice(src []int64) []*int64

+ func Int64Value(v *int64) int64

+ func Int64ValueMap(src map[string]*int64) map[string]int64

+ func Int64ValueSlice(src []*int64) []int64

+ func IntMap(src map[string]int) map[string]*int

+ func IntSlice(src []int) []*int

+ func IntValue(v *int) int

+ func IntValueMap(src map[string]*int) map[string]int

+ func IntValueSlice(src []*int) []int

+ func IsErrorExpiredCreds(err error) bool

+ func IsErrorRetryable(err error) bool

+ func IsErrorThrottle(err error) bool

+ func MakeAddToUserAgentFreeFormHandler(s string) func(*Request)

+ func MakeAddToUserAgentHandler(name, version string, extra ...string) func(*Request)

+ func MillisecondsTimeValue(v *int64) time.Time

+ func SecondsTimeValue(v *int64) time.Time

+ func SleepWithContext(ctx Context, dur time.Duration) error

+ func String(v string) *string

+ func StringMap(src map[string]string) map[string]*string

+ func StringSlice(src []string) []*string

+ func StringValue(v *string) string

+ func StringValueMap(src map[string]*string) map[string]string

+ func StringValueSlice(src []*string) []string

+ func Time(v time.Time) *time.Time

+ func TimeMap(src map[string]time.Time) map[string]*time.Time

+ func TimeSlice(src []time.Time) []*time.Time

+ func TimeUnixMilli(t time.Time) int64

+ func TimeValue(v *time.Time) time.Time

+ func TimeValueMap(src map[string]*time.Time) map[string]time.Time

+ func TimeValueSlice(src []*time.Time) []time.Time

+ func URLHostname(url *url.URL) string

+ type ChainProvider struct

+ Providers []CredentialsProvider

+ func NewChainProvider(providers []CredentialsProvider) *ChainProvider

+ type Client struct

+ Config Config

+ Credentials CredentialsProvider

+ EndpointResolver EndpointResolver

+ HTTPClient *http.Client

+ Handlers Handlers

+ LogLevel LogLevel

+ Logger Logger

+ Metadata Metadata

+ Region string

+ Retryer Retryer

+ func NewClient(cfg Config, metadata Metadata) *Client

+ func (c *Client) AddDebugHandlers()

+ func (c *Client) NewRequest(operation *Operation, params interface{}, data interface{}) *Request

+ type Config struct

+ Credentials CredentialsProvider

+ DisableRestProtocolURICleaning bool

+ EndpointResolver EndpointResolver

+ EnforceShouldRetryCheck bool

+ HTTPClient *http.Client

+ Handlers Handlers

+ LogLevel LogLevel

+ Logger Logger

+ Region string

+ Retryer Retryer

+ func NewConfig() *Config

+ func WithRetryer(cfg *Config, retryer Retryer) *Config

+ func (c Config) Copy() Config

+ type Context interface

+ Deadline func() (deadline time.Time, ok bool)

+ Done func() <-chan struct{}

+ Err func() error

+ Value func(key interface{}) interface{}

+ func BackgroundContext() Context

+ type Credentials struct

+ AccessKeyID string

+ CanExpire bool

+ Expires time.Time

+ SecretAccessKey string

+ SessionToken string

+ Source string

+ func (v Credentials) Expired() bool

+ func (v Credentials) HasKeys() bool

+ type CredentialsProvider interface

+ Retrieve func() (Credentials, error)

+ type DefaultRetryer struct

+ NumMaxRetries int

+ func (d DefaultRetryer) MaxRetries() int

+ func (d DefaultRetryer) RetryRules(r *Request) time.Duration

+ func (d DefaultRetryer) ShouldRetry(r *Request) bool

+ type Endpoint struct

+ SigningMethod string

+ SigningName string

+ SigningRegion string

+ URL string

+ type EndpointResolver interface

+ ResolveEndpoint func(service, region string) (Endpoint, error)

+ type EndpointResolverFunc func(service, region string) (Endpoint, error)

+ func (fn EndpointResolverFunc) ResolveEndpoint(service, region string) (Endpoint, error)

+ type ErrInvalidParam interface

+ AddNestedContext func(string)

+ Field func() string

+ SetContext func(string)

+ type ErrInvalidParams struct

+ Context string

+ func (e *ErrInvalidParams) Add(err ErrInvalidParam)

+ func (e *ErrInvalidParams) AddNested(nestedCtx string, nested ErrInvalidParams)

+ func (e ErrInvalidParams) Code() string

+ func (e ErrInvalidParams) Error() string

+ func (e ErrInvalidParams) Len() int

+ func (e ErrInvalidParams) Message() string

+ func (e ErrInvalidParams) OrigErr() error

+ func (e ErrInvalidParams) OrigErrs() []error

+ type ErrParamMinLen struct

+ func NewErrParamMinLen(field string, min int) *ErrParamMinLen

+ func (e *ErrParamMinLen) AddNestedContext(ctx string)

+ func (e *ErrParamMinLen) Code() string

+ func (e *ErrParamMinLen) Error() string

+ func (e *ErrParamMinLen) Field() string

+ func (e *ErrParamMinLen) Message() string

+ func (e *ErrParamMinLen) MinLen() int

+ func (e *ErrParamMinLen) OrigErr() error

+ func (e *ErrParamMinLen) SetContext(ctx string)

+ type ErrParamMinValue struct

+ func NewErrParamMinValue(field string, min float64) *ErrParamMinValue

+ func (e *ErrParamMinValue) AddNestedContext(ctx string)

+ func (e *ErrParamMinValue) Code() string

+ func (e *ErrParamMinValue) Error() string

+ func (e *ErrParamMinValue) Field() string

+ func (e *ErrParamMinValue) Message() string

+ func (e *ErrParamMinValue) MinValue() float64

+ func (e *ErrParamMinValue) OrigErr() error

+ func (e *ErrParamMinValue) SetContext(ctx string)

+ type ErrParamRequired struct

+ func NewErrParamRequired(field string) *ErrParamRequired

+ func (e *ErrParamRequired) AddNestedContext(ctx string)

+ func (e *ErrParamRequired) Code() string

+ func (e *ErrParamRequired) Error() string

+ func (e *ErrParamRequired) Field() string

+ func (e *ErrParamRequired) Message() string

+ func (e *ErrParamRequired) OrigErr() error

+ func (e *ErrParamRequired) SetContext(ctx string)

+ type Expiration time.Time

+ type HandlerList struct

+ AfterEachFn func(item HandlerListRunItem) bool

+ func (l *HandlerList) Clear()

+ func (l *HandlerList) Len() int

+ func (l *HandlerList) PushBack(f func(*Request))

+ func (l *HandlerList) PushBackNamed(n NamedHandler)

+ func (l *HandlerList) PushFront(f func(*Request))

+ func (l *HandlerList) PushFrontNamed(n NamedHandler)

+ func (l *HandlerList) Remove(n NamedHandler)

+ func (l *HandlerList) RemoveByName(name string)

+ func (l *HandlerList) Run(r *Request)

+ func (l *HandlerList) SetBackNamed(n NamedHandler)

+ func (l *HandlerList) SetFrontNamed(n NamedHandler)

+ func (l *HandlerList) SwapNamed(n NamedHandler) (swapped bool)

+ type HandlerListRunItem struct

+ Handler NamedHandler

+ Index int

+ Request *Request

+ type Handlers struct

+ AfterRetry HandlerList

+ Build HandlerList

+ Complete HandlerList

+ Retry HandlerList

+ Send HandlerList

+ Sign HandlerList

+ Unmarshal HandlerList

+ UnmarshalError HandlerList

+ UnmarshalMeta HandlerList

+ Validate HandlerList

+ ValidateResponse HandlerList

+ func (h *Handlers) Clear()

+ func (h *Handlers) Copy() Handlers

+ type JSONValue map[string]interface

+ type LogLevel uint

+ const LogDebug

+ const LogDebugWithHTTPBody

+ const LogDebugWithRequestErrors

+ const LogDebugWithRequestRetries

+ const LogDebugWithSigning

+ const LogOff

+ func (l LogLevel) AtLeast(v LogLevel) bool

+ func (l LogLevel) Matches(v LogLevel) bool

+ type Logger interface

+ Log func(...interface{})

+ func NewDefaultLogger() Logger

+ type LoggerFunc func(...interface{})

+ func (f LoggerFunc) Log(args ...interface{})

+ type Metadata struct

+ APIVersion string

+ Endpoint string

+ JSONVersion string

+ ServiceName string

+ SigningName string

+ SigningRegion string

+ TargetPrefix string

+ type NamedHandler struct

+ Fn func(*Request)

+ Name string

+ type Operation struct

+ BeforePresignFn func(r *Request) error

+ HTTPMethod string

+ HTTPPath string

+ Name string

+ type Option func(*Request)

+ func WithAppendUserAgent(s string) Option

+ func WithGetResponseHeader(key string, val *string) Option

+ func WithGetResponseHeaders(headers *http.Header) Option

+ func WithLogLevel(l LogLevel) Option

+ func WithResponseReadTimeout(duration time.Duration) Option

+ type Pagination struct

+ NewRequest func() (*Request, error)

+ func (p *Pagination) Err() error

+ func (p *Pagination) HasNextPage() bool

+ func (p *Pagination) Next() bool

+ func (p *Pagination) Page() interface{}

+ type Paginator struct

+ InputTokens []string

+ LimitToken string

+ OutputTokens []string

+ TruncationToken string

+ type ReaderSeekerCloser struct

+ func ReadSeekCloser(r io.Reader) ReaderSeekerCloser

+ func (r ReaderSeekerCloser) Close() error

+ func (r ReaderSeekerCloser) IsSeeker() bool

+ func (r ReaderSeekerCloser) Read(p []byte) (int, error)

+ func (r ReaderSeekerCloser) Seek(offset int64, whence int) (int64, error)

+ type Request struct

+ Body io.ReadSeeker

+ BodyStart int64

+ Config Config

+ Data interface{}

+ DisableFollowRedirects bool

+ Error error

+ ExpireTime time.Duration

+ HTTPRequest *http.Request

+ HTTPResponse *http.Response

+ Handlers Handlers

+ LastSignedAt time.Time

+ Metadata Metadata

+ NotHoist bool

+ Operation *Operation

+ Params interface{}

+ RequestID string

+ RetryCount int

+ RetryDelay time.Duration

+ Retryable *bool

+ SignedHeaderVals http.Header

+ Time time.Time

+ func New(cfg Config, metadata Metadata, handlers Handlers, retryer Retryer, ...) *Request

+ func (r *Request) ApplyOptions(opts ...Option)

+ func (r *Request) Build() error

+ func (r *Request) Context() Context

+ func (r *Request) EachPage(fn func(data interface{}, isLastPage bool) (shouldContinue bool)) error

+ func (r *Request) GetBody() io.ReadSeeker

+ func (r *Request) HasNextPage() bool

+ func (r *Request) IsErrorExpired() bool

+ func (r *Request) IsErrorRetryable() bool

+ func (r *Request) IsErrorThrottle() bool

+ func (r *Request) NextPage() *Request

+ func (r *Request) ParamsFilled() bool

+ func (r *Request) Presign(expireTime time.Duration) (string, error)

+ func (r *Request) PresignRequest(expireTime time.Duration) (string, http.Header, error)

+ func (r *Request) ResetBody()

+ func (r *Request) Send() error

+ func (r *Request) SetBufferBody(buf []byte)

+ func (r *Request) SetContext(ctx Context)

+ func (r *Request) SetReaderBody(reader io.ReadSeeker)

+ func (r *Request) SetStringBody(s string)

+ func (r *Request) Sign() error

+ func (r *Request) WillRetry() bool

+ type ResolveWithEndpoint Endpoint

+ func ResolveWithEndpointURL(url string) ResolveWithEndpoint

+ func (v ResolveWithEndpoint) ResolveEndpoint(service, region string) (Endpoint, error)

+ type Response struct

+ Request *Request

+ type Retryer interface

+ MaxRetries func() int

+ RetryRules func(*Request) time.Duration

+ ShouldRetry func(*Request) bool

+ type SafeCredentialsProvider struct

+ RetrieveFn func() (Credentials, error)

+ func (p *SafeCredentialsProvider) Invalidate()

+ func (p *SafeCredentialsProvider) Retrieve() (Credentials, error)

+ type StaticCredentialsProvider struct

+ Value Credentials

+ func NewStaticCredentialsProvider(key, secret, session string) StaticCredentialsProvider

+ func (s StaticCredentialsProvider) IsExpired() bool

+ func (s StaticCredentialsProvider) Retrieve() (Credentials, error)

+ type Validator interface

+ Validate func() error

+ type Waiter struct

+ Acceptors []WaiterAcceptor

+ Delay WaiterDelay

+ Logger Logger

+ MaxAttempts int

+ Name string

+ NewRequest func([]Option) (*Request, error)

+ RequestOptions []Option

+ SleepWithContext func(Context, time.Duration) error

+ func (w *Waiter) ApplyOptions(opts ...WaiterOption)

+ func (w Waiter) WaitWithContext(ctx Context) error

+ type WaiterAcceptor struct

+ Argument string

+ Expected interface{}

+ Matcher WaiterMatchMode

+ State WaiterState

+ type WaiterDelay func(attempt int) time.Duration

+ func ConstantWaiterDelay(delay time.Duration) WaiterDelay

+ type WaiterMatchMode int

+ const ErrorWaiterMatch

+ const PathAllWaiterMatch

+ const PathAnyWaiterMatch

+ const PathListWaiterMatch

+ const PathWaiterMatch

+ const StatusWaiterMatch

+ func (m WaiterMatchMode) String() string

+ type WaiterOption func(*Waiter)

+ func WithWaiterDelay(delayer WaiterDelay) WaiterOption

+ func WithWaiterLogger(logger Logger) WaiterOption

+ func WithWaiterMaxAttempts(max int) WaiterOption

+ func WithWaiterRequestOptions(opts ...Option) WaiterOption

+ type WaiterState int

+ const FailureWaiterState

+ const RetryWaiterState

+ const SuccessWaiterState

+ func (s WaiterState) String() string

+ type WriteAtBuffer struct

+ GrowthCoeff float64

+ func NewWriteAtBuffer(buf []byte) *WriteAtBuffer

+ func (b *WriteAtBuffer) Bytes() []byte

+ func (b *WriteAtBuffer) WriteAt(p []byte, pos int64) (n int, err error)

Incompatible versions in this module

v2.0.0-preview.4+incompatible

May 26, 2018

v2.0.0-preview.3+incompatible

Mar 8, 2018

v2.0.0-preview.2+incompatible

Jan 15, 2018

v2.0.0-preview.1+incompatible

Dec 21, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL