package middleware

import "github.com/aws/aws-sdk-go-v2/aws/middleware/private/metrics/middleware"

Index

Functions

func WithMetricMiddlewares 

func WithMetricMiddlewares(
	publisher metrics.MetricPublisher, client *http.Client,
) func(stack *middleware.Stack) error

Types

type EndpointResolutionEnd 

type EndpointResolutionEnd struct{}

func GetRecordEndpointResolutionEndMiddleware 

func GetRecordEndpointResolutionEndMiddleware() *EndpointResolutionEnd

func (*EndpointResolutionEnd) HandleSerialize 

func (m *EndpointResolutionEnd) HandleSerialize(
	ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler,
) (
	out middleware.SerializeOutput, metadata middleware.Metadata, err error,
)

func (*EndpointResolutionEnd) ID 

func (m *EndpointResolutionEnd) ID() string

type EndpointResolutionStart 

type EndpointResolutionStart struct{}

func GetRecordEndpointResolutionStartMiddleware 

func GetRecordEndpointResolutionStartMiddleware() *EndpointResolutionStart

func (*EndpointResolutionStart) HandleSerialize 

func (m *EndpointResolutionStart) HandleSerialize(
	ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler,
) (
	out middleware.SerializeOutput, metadata middleware.Metadata, err error,
)

func (*EndpointResolutionStart) ID 

func (m *EndpointResolutionStart) ID() string

type HTTPMetrics 

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

func GetHttpMetricMiddleware 

func GetHttpMetricMiddleware(client *http.Client) *HTTPMetrics

func (*HTTPMetrics) HandleFinalize 

func (m *HTTPMetrics) HandleFinalize(
	ctx context.Context, in middleware.FinalizeInput, next middleware.FinalizeHandler,
) (
	out middleware.FinalizeOutput, metadata middleware.Metadata, attemptError error,
)

func (*HTTPMetrics) ID 

func (m *HTTPMetrics) ID() string

type MetricCollection 

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

func GetSetupMetricCollectionMiddleware 

func GetSetupMetricCollectionMiddleware(
	counter *metrics.SharedConnectionCounter, publisher metrics.MetricPublisher,
) *MetricCollection

func (*MetricCollection) HandleInitialize 

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

func (*MetricCollection) ID 

func (m *MetricCollection) ID() string

type RegisterAttemptMetricContext 

type RegisterAttemptMetricContext struct{}

func GetRegisterAttemptMetricContextMiddleware 

func GetRegisterAttemptMetricContextMiddleware() *RegisterAttemptMetricContext

func (*RegisterAttemptMetricContext) HandleFinalize 

func (m *RegisterAttemptMetricContext) HandleFinalize(
	ctx context.Context, in middleware.FinalizeInput, next middleware.FinalizeHandler,
) (
	out middleware.FinalizeOutput, metadata middleware.Metadata, err error,
)

func (*RegisterAttemptMetricContext) ID 

func (m *RegisterAttemptMetricContext) ID() string

type RegisterMetricContext 

type RegisterMetricContext struct{}

func GetRegisterRequestMetricContextMiddleware 

func GetRegisterRequestMetricContextMiddleware() *RegisterMetricContext

func (*RegisterMetricContext) HandleFinalize 

func (m *RegisterMetricContext) HandleFinalize(
	ctx context.Context, in middleware.FinalizeInput, next middleware.FinalizeHandler,
) (
	out middleware.FinalizeOutput, metadata middleware.Metadata, err error,
)

func (*RegisterMetricContext) ID 

func (m *RegisterMetricContext) ID() string

type StackDeserializeEnd 

type StackDeserializeEnd struct{}

func GetRecordStackDeserializeEndMiddleware 

func GetRecordStackDeserializeEndMiddleware() *StackDeserializeEnd

func (*StackDeserializeEnd) HandleDeserialize 

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

func (*StackDeserializeEnd) ID 

func (m *StackDeserializeEnd) ID() string

type StackDeserializeStart 

type StackDeserializeStart struct{}

func GetRecordStackDeserializeStartMiddleware 

func GetRecordStackDeserializeStartMiddleware() *StackDeserializeStart

func (*StackDeserializeStart) HandleDeserialize 

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

func (*StackDeserializeStart) ID 

func (m *StackDeserializeStart) ID() string

type StackSerializeEnd 

type StackSerializeEnd struct{}

func GetRecordStackSerializeEndMiddleware 

func GetRecordStackSerializeEndMiddleware() *StackSerializeEnd

func (*StackSerializeEnd) HandleSerialize 

func (m *StackSerializeEnd) HandleSerialize(
	ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler,
) (
	out middleware.SerializeOutput, metadata middleware.Metadata, err error,
)

func (*StackSerializeEnd) ID 

func (m *StackSerializeEnd) ID() string

type StackSerializeStart 

type StackSerializeStart struct{}

func GetRecordStackSerializeStartMiddleware 

func GetRecordStackSerializeStartMiddleware() *StackSerializeStart

func (*StackSerializeStart) HandleSerialize 

func (m *StackSerializeStart) HandleSerialize(
	ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler,
) (
	out middleware.SerializeOutput, metadata middleware.Metadata, err error,
)

func (*StackSerializeStart) ID 

func (m *StackSerializeStart) ID() string

type TransportMetrics 

type TransportMetrics struct{}

func GetTransportMetricsMiddleware 

func GetTransportMetricsMiddleware() *TransportMetrics

func (*TransportMetrics) HandleDeserialize 

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

func (*TransportMetrics) ID 

func (m *TransportMetrics) ID() string

type WrapDataContext 

type WrapDataContext struct{}

func GetWrapDataStreamMiddleware 

func GetWrapDataStreamMiddleware() *WrapDataContext

func (*WrapDataContext) HandleBuild 

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

func (*WrapDataContext) ID 

func (m *WrapDataContext) ID() string

Source Files

configuration.go endpoint_resolution_end.go endpoint_resolution_start.go http.go metric_collection.go request.go request_attempt.go stack_deserialize_end.go stack_deserialize_start.go stack_serialize_end.go stack_serialize_start.go transport.go wrap_data_stream.go

Version
v1.26.1
Published
Mar 29, 2024
Platform
linux/amd64
Imports
13 packages
Last checked
10 minutes ago –

Tools for package owners.