middleware

package
v1.50.8 Latest Latest
Warning

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

Go to latest
Published: Feb 1, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 (*EndpointResolutionEnd) ID

func (m *EndpointResolutionEnd) ID() string

type EndpointResolutionStart

type EndpointResolutionStart struct{}

func GetRecordEndpointResolutionStartMiddleware

func GetRecordEndpointResolutionStartMiddleware() *EndpointResolutionStart

func (*EndpointResolutionStart) HandleSerialize

func (*EndpointResolutionStart) ID

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 (*MetricCollection) ID

func (m *MetricCollection) ID() string

type RegisterAttemptMetricContext

type RegisterAttemptMetricContext struct{}

func GetRegisterAttemptMetricContextMiddleware

func GetRegisterAttemptMetricContextMiddleware() *RegisterAttemptMetricContext

func (*RegisterAttemptMetricContext) HandleFinalize

func (*RegisterAttemptMetricContext) ID

type RegisterMetricContext

type RegisterMetricContext struct{}

func GetRegisterRequestMetricContextMiddleware

func GetRegisterRequestMetricContextMiddleware() *RegisterMetricContext

func (*RegisterMetricContext) HandleFinalize

func (*RegisterMetricContext) ID

func (m *RegisterMetricContext) ID() string

type StackDeserializeEnd

type StackDeserializeEnd struct{}

func GetRecordStackDeserializeEndMiddleware

func GetRecordStackDeserializeEndMiddleware() *StackDeserializeEnd

func (*StackDeserializeEnd) HandleDeserialize

func (*StackDeserializeEnd) ID

func (m *StackDeserializeEnd) ID() string

type StackDeserializeStart

type StackDeserializeStart struct{}

func GetRecordStackDeserializeStartMiddleware

func GetRecordStackDeserializeStartMiddleware() *StackDeserializeStart

func (*StackDeserializeStart) HandleDeserialize

func (*StackDeserializeStart) ID

func (m *StackDeserializeStart) ID() string

type StackSerializeEnd

type StackSerializeEnd struct{}

func GetRecordStackSerializeEndMiddleware

func GetRecordStackSerializeEndMiddleware() *StackSerializeEnd

func (*StackSerializeEnd) HandleSerialize

func (*StackSerializeEnd) ID

func (m *StackSerializeEnd) ID() string

type StackSerializeStart

type StackSerializeStart struct{}

func GetRecordStackSerializeStartMiddleware

func GetRecordStackSerializeStartMiddleware() *StackSerializeStart

func (*StackSerializeStart) HandleSerialize

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

Jump to

Keyboard shortcuts

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