package internal

import "github.com/Azure/azure-sdk-for-go/sdk/storage/azblob/internal"

Index ¶

• Constants
• Variables
• func Delay(ctx context.Context, delay time.Duration) error
• func EndpointToScope(endpoint string) string
• func GetJSON(resp *http.Response) (map[string]interface{}, error)
• func HasStatusCode(resp *http.Response, statusCodes ...int) bool
• func NewResponseError(inner error, resp *http.Response) error
• func NopCloser(rs io.ReadSeeker) io.ReadSeekCloser
• func RetryAfter(resp *http.Response) time.Duration
• type BodyDownloadPolicyOpValues
• type CtxWithHTTPHeaderKey
• type CtxWithRetryOptionsKey
• type ResponseError
• func (e *ResponseError) Error() string
• func (e *ResponseError) NonRetriable()
• func (e *ResponseError) RawResponse() *http.Response
• func (e *ResponseError) Unwrap() error

Constants ¶

const HeaderRetryAfter = "Retry-After"

Variables ¶

var ErrNoBody = errors.New("the response did not contain a body")

ErrNoBody is returned if the response didn't contain a body.

Functions ¶

func Delay ¶

func Delay(ctx context.Context, delay time.Duration) error

Delay waits for the duration to elapse or the context to be cancelled.

func EndpointToScope ¶

func EndpointToScope(endpoint string) string

EndpointToScope converts the provided URL endpoint to its default scope.

func GetJSON ¶

func GetJSON(resp *http.Response) (map[string]interface{}, error)

GetJSON reads the response body into a raw JSON object. It returns ErrNoBody if there was no content.

func HasStatusCode ¶

func HasStatusCode(resp *http.Response, statusCodes ...int) bool

HasStatusCode returns true if the Response's status code is one of the specified values.

func NewResponseError ¶

func NewResponseError(inner error, resp *http.Response) error

func NopCloser ¶

func NopCloser(rs io.ReadSeeker) io.ReadSeekCloser

NopCloser returns a ReadSeekCloser with a no-op close method wrapping the provided io.ReadSeeker.

func RetryAfter ¶

func RetryAfter(resp *http.Response) time.Duration

RetryAfter returns non-zero if the response contains a Retry-After header value.

Types ¶

type BodyDownloadPolicyOpValues ¶

type BodyDownloadPolicyOpValues struct {
	Skip bool
}

BodyDownloadPolicyOpValues is the struct containing the per-operation values

type CtxWithHTTPHeaderKey ¶

type CtxWithHTTPHeaderKey struct{}

CtxWithHTTPHeaderKey is used as a context key for adding/retrieving http.Header.

type CtxWithRetryOptionsKey ¶

type CtxWithRetryOptionsKey struct{}

CtxWithRetryOptionsKey is used as a context key for adding/retrieving RetryOptions.

type ResponseError ¶

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

func (*ResponseError) Error ¶

func (e *ResponseError) Error() string

Error implements the error interface for type ResponseError.

func (*ResponseError) NonRetriable ¶

func (e *ResponseError) NonRetriable()

NonRetriable indicates this error is non-transient.

func (*ResponseError) RawResponse ¶

func (e *ResponseError) RawResponse() *http.Response

RawResponse returns the HTTP response associated with this error.

func (*ResponseError) Unwrap ¶

func (e *ResponseError) Unwrap() error

Unwrap returns the inner error.

Source Files ¶

zc_shared.go