middleware

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2024 License: Apache-2.0 Imports: 13 Imported by: 377

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddClientRequestIDMiddleware 

func AddClientRequestIDMiddleware(stack *middleware.Stack) error

AddClientRequestIDMiddleware adds ClientRequestID to the middleware stack

func AddRawResponseToMetadata 

func AddRawResponseToMetadata(stack *middleware.Stack) error

AddRawResponseToMetadata adds middleware to the middleware stack that store raw response on to the metadata.

func AddRecordResponseTiming 

func AddRecordResponseTiming(stack *middleware.Stack) error

AddRecordResponseTiming adds RecordResponseTiming middleware to the middleware stack.

func AddRecursionDetection 

func AddRecursionDetection(stack *middleware.Stack) error

AddRecursionDetection adds recursionDetection to the middleware stack

func AddRequestIDRetrieverMiddleware 

func AddRequestIDRetrieverMiddleware(stack *middleware.Stack) error

AddRequestIDRetrieverMiddleware adds request id retriever middleware

func AddRequestUserAgentMiddleware 

func AddRequestUserAgentMiddleware(stack *middleware.Stack) error

AddRequestUserAgentMiddleware registers a requestUserAgent middleware on the stack if not present.

func AddSDKAgentKey 

func AddSDKAgentKey(keyType SDKAgentKeyType, key string) func(*middleware.Stack) error

AddSDKAgentKey retrieves a requestUserAgent from the provided stack, or initializes one.

func AddSDKAgentKeyValue 

func AddSDKAgentKeyValue(keyType SDKAgentKeyType, key, value string) func(*middleware.Stack) error

AddSDKAgentKeyValue retrieves a requestUserAgent from the provided stack, or initializes one.

func AddUserAgentKey 

func AddUserAgentKey(key string) func(*middleware.Stack) error

AddUserAgentKey retrieves a requestUserAgent from the provided stack, or initializes one.

func AddUserAgentKeyValue 

func AddUserAgentKeyValue(key, value string) func(*middleware.Stack) error

AddUserAgentKeyValue retrieves a requestUserAgent from the provided stack, or initializes one.

func GetAttemptSkew 

func GetAttemptSkew(metadata middleware.Metadata) (v time.Duration, ok bool)

GetAttemptSkew returns Attempt clock skew for response from metadata.

func GetEndpointSource 

func GetEndpointSource(ctx context.Context) (v aws.EndpointSource)

GetEndpointSource returns an endpoint source if set on context

func GetOperationName 

func GetOperationName(ctx context.Context) (v string)

GetOperationName retrieves the service operation metadata from the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func GetPartitionID 

func GetPartitionID(ctx context.Context) string

GetPartitionID retrieves the endpoint partition id from the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func GetRawResponse 

func GetRawResponse(metadata middleware.Metadata) interface{}

GetRawResponse returns raw response set on metadata

func GetRegion 

func GetRegion(ctx context.Context) (v string)

GetRegion retrieves the endpoint region from the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func GetRequestIDMetadata 

func GetRequestIDMetadata(metadata middleware.Metadata) (string, bool)

GetRequestIDMetadata retrieves the request id from middleware metadata returns string and bool indicating value of request id, whether request id was set.

func GetRequiresLegacyEndpoints 

func GetRequiresLegacyEndpoints(ctx context.Context) bool

GetRequiresLegacyEndpoints the flag used to indicate if legacy endpoint customizations need to be executed.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func GetResponseAt 

func GetResponseAt(metadata middleware.Metadata) (v time.Time, ok bool)

GetResponseAt returns the time response was received at.

func GetServerTime 

func GetServerTime(metadata middleware.Metadata) (v time.Time, ok bool)

GetServerTime returns the server time for response.

func GetServiceID 

func GetServiceID(ctx context.Context) (v string)

GetServiceID retrieves the service id from the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func GetSigningCredentials 

func GetSigningCredentials(ctx context.Context) (v aws.Credentials)

GetSigningCredentials returns the credentials that were used for signing if set on context.

func GetSigningName deprecated 

func GetSigningName(ctx context.Context) (v string)

GetSigningName retrieves the service signing name from the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

Deprecated: This value is unstable. The resolved signing name is available in the signer properties object passed to the signer.

func GetSigningRegion deprecated 

func GetSigningRegion(ctx context.Context) (v string)

GetSigningRegion retrieves the region from the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

Deprecated: This value is unstable. The resolved signing region is available in the signer properties object passed to the signer.

func SetEndpointSource 

func SetEndpointSource(ctx context.Context, value aws.EndpointSource) context.Context

SetEndpointSource sets endpoint source on context

func SetPartitionID 

func SetPartitionID(ctx context.Context, value string) context.Context

SetPartitionID sets the partition id of a resolved region on the context

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func SetRequestIDMetadata 

func SetRequestIDMetadata(metadata *middleware.Metadata, id string)

SetRequestIDMetadata sets the provided request id over middleware metadata

func SetRequiresLegacyEndpoints 

func SetRequiresLegacyEndpoints(ctx context.Context, value bool) context.Context

SetRequiresLegacyEndpoints set or modifies the flag indicated that legacy endpoint customizations are needed.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func SetServiceID 

func SetServiceID(ctx context.Context, value string) context.Context

SetServiceID sets the service id on the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

func SetSigningCredentials 

func SetSigningCredentials(ctx context.Context, value aws.Credentials) context.Context

SetSigningCredentials sets the credentails used for signing on the context.

func SetSigningName deprecated 

func SetSigningName(ctx context.Context, value string) context.Context

SetSigningName set or modifies the sigv4 or sigv4a signing name on the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

Deprecated: This value is unstable. Use WithSigV4SigningName client option funcs instead.

func SetSigningRegion deprecated 

func SetSigningRegion(ctx context.Context, value string) context.Context

SetSigningRegion sets or modifies the region on the context.

Scoped to stack values. Use github.com/aws/smithy-go/middleware#ClearStackValues to clear all stack values.

Deprecated: This value is unstable. Use WithSigV4SigningRegion client option funcs instead.

Types

type AddRawResponse 

type AddRawResponse struct{}

AddRawResponse middleware adds raw response on to the metadata

func (AddRawResponse) HandleDeserialize 

func (m AddRawResponse) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
	out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
)

HandleDeserialize adds raw response on the middleware metadata

func (*AddRawResponse) ID 

func (m *AddRawResponse) ID() string

ID the identifier for the ClientRequestID

type ClientRequestID 

type ClientRequestID struct{}

ClientRequestID is a Smithy BuildMiddleware that will generate a unique ID for logical API operation invocation.

func (ClientRequestID) HandleBuild 

func (r ClientRequestID) HandleBuild(ctx context.Context, in middleware.BuildInput, next middleware.BuildHandler) (
	out middleware.BuildOutput, metadata middleware.Metadata, err error,
)

HandleBuild attaches a unique operation invocation id for the operation to the request

func (*ClientRequestID) ID 

func (r *ClientRequestID) ID() string

ID the identifier for the ClientRequestID

type RecordResponseTiming 

type RecordResponseTiming struct{}

RecordResponseTiming records the response timing for the SDK client requests.

func (RecordResponseTiming) HandleDeserialize 

func (a RecordResponseTiming) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
	out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
)

HandleDeserialize calculates response metadata and clock skew

func (*RecordResponseTiming) ID 

func (a *RecordResponseTiming) ID() string

ID is the middleware identifier

type RecursionDetection 

type RecursionDetection struct{}

RecursionDetection detects Lambda environment and sets its X-Ray trace ID to request header if absent to avoid recursion invocation in Lambda

func (*RecursionDetection) HandleBuild 

func (m *RecursionDetection) HandleBuild(
	ctx context.Context, in middleware.BuildInput, next middleware.BuildHandler,
) (
	out middleware.BuildOutput, metadata middleware.Metadata, err error,
)

HandleBuild detects Lambda environment and adds its trace ID to request header if absent

func (*RecursionDetection) ID 

func (m *RecursionDetection) ID() string

ID returns the middleware identifier

type RegisterServiceMetadata 

type RegisterServiceMetadata struct {
	ServiceID     string
	SigningName   string
	Region        string
	OperationName string
}

RegisterServiceMetadata registers metadata about the service and operation into the middleware context so that it is available at runtime for other middleware to introspect.

func (RegisterServiceMetadata) HandleInitialize 

func (s RegisterServiceMetadata) HandleInitialize(
	ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler,
) (out middleware.InitializeOutput, metadata middleware.Metadata, err error)

HandleInitialize registers service metadata information into the middleware context, allowing for introspection.

func (*RegisterServiceMetadata) ID 

func (s *RegisterServiceMetadata) ID() string

ID returns the middleware identifier.

type RequestIDRetriever 

type RequestIDRetriever struct {
}

RequestIDRetriever middleware captures the AWS service request ID from the raw response.

func (*RequestIDRetriever) HandleDeserialize 

func (m *RequestIDRetriever) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
	out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
)

HandleDeserialize pulls the AWS request ID from the response, storing it in operation metadata.

func (*RequestIDRetriever) ID 

func (m *RequestIDRetriever) ID() string

ID returns the middleware identifier

type RequestUserAgent 

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

RequestUserAgent is a build middleware that set the User-Agent for the request.

func NewRequestUserAgent 

func NewRequestUserAgent() *RequestUserAgent

NewRequestUserAgent returns a new requestUserAgent which will set the User-Agent and X-Amz-User-Agent for the request.

User-Agent example: 

aws-sdk-go-v2/1.2.3

X-Amz-User-Agent example: 

aws-sdk-go-v2/1.2.3 md/GOOS/linux md/GOARCH/amd64 lang/go/1.15

func (*RequestUserAgent) AddSDKAgentKey 

func (u *RequestUserAgent) AddSDKAgentKey(keyType SDKAgentKeyType, key string)

AddSDKAgentKey adds the component identified by name to the User-Agent string.

func (*RequestUserAgent) AddSDKAgentKeyValue 

func (u *RequestUserAgent) AddSDKAgentKeyValue(keyType SDKAgentKeyType, key, value string)

AddSDKAgentKeyValue adds the key identified by the given name and value to the User-Agent string.

func (*RequestUserAgent) AddUserAgentKey 

func (u *RequestUserAgent) AddUserAgentKey(key string)

AddUserAgentKey adds the component identified by name to the User-Agent string.

func (*RequestUserAgent) AddUserAgentKeyValue 

func (u *RequestUserAgent) AddUserAgentKeyValue(key, value string)

AddUserAgentKeyValue adds the key identified by the given name and value to the User-Agent string.

func (*RequestUserAgent) HandleBuild 

func (u *RequestUserAgent) HandleBuild(ctx context.Context, in middleware.BuildInput, next middleware.BuildHandler) (
	out middleware.BuildOutput, metadata middleware.Metadata, err error,
)

HandleBuild adds or appends the constructed user agent to the request.

func (*RequestUserAgent) ID 

func (u *RequestUserAgent) ID() string

ID the name of the middleware.

type SDKAgentKeyType 

type SDKAgentKeyType int

SDKAgentKeyType is the metadata type to add to the SDK agent string 

const (
	APIMetadata SDKAgentKeyType
	OperatingSystemMetadata
	LanguageMetadata
	EnvironmentMetadata
	FeatureMetadata
	ConfigMetadata
	FrameworkMetadata
	AdditionalMetadata
	ApplicationIdentifier
)

The set of valid SDKAgentKeyType constants. If an unknown value is assigned for SDKAgentKeyType it will be mapped to AdditionalMetadata.

Source Files

View all Source files

Directories

Path Synopsis
private
metrics
Package metrics implements metrics gathering for SDK development purposes.
 Package metrics implements metrics gathering for SDK development purposes.
metrics/emf
Package emf implements an EMF metrics publisher.
 Package emf implements an EMF metrics publisher.
metrics/middleware
metrics/publisher
metrics/readcloserwithmetrics
metrics/testutils

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.