Versions in this module Expand all Collapse all v1 v1.50.8 Feb 1, 2024 Changes in this version + const APICallDurationKey + const APICallSuccessfulKey + const AWSExtendedRequestIDKey + const AWSRequestIDKey + const AttemptNumberKey + const AvailableConcurrencyKey + const BackoffDelayDurationKey + const ClientRequestIDKey + const ConcurrencyAcquireDurationKey + const EndpointResolutionDurationKey + const HTTPStatusCodeKey + const InThroughputKey + const MarshallingDurationKey + const MaxConcurrencyKey + const OperationNameKey + const OutThroughputKey + const PendingConcurrencyAcquiresKey + const RetryCountKey + const ServiceCallDurationKey + const ServiceIDKey + const SigningDurationKey + const StreamThroughputKey + const TimeToFirstByteKey + const UnmarshallingDurationKey + func InitMetricContext(ctx context.Context, counter *SharedConnectionCounter, ...) context.Context + type AttemptMetrics struct + ActiveRequests int + AvailableConcurrency int + ConcurrencyAcquireDuration time.Duration + ConnObtainedTime time.Time + ConnRequestedTime time.Time + CredentialFetchEndTime time.Time + CredentialFetchStartTime time.Time + DeserializeEndTime time.Time + DeserializeStartTime time.Time + ExtendedRequestID string + FirstByteTime time.Time + HTTPClient string + MaxConcurrency int + PendingConnectionAcquires int + RequestID string + ResponseContentLength int64 + RetryDelay time.Duration + ReusedConnection bool + ServiceCallDuration time.Duration + ServiceCallEnd time.Time + ServiceCallStart time.Time + SignEndTime time.Time + SignStartTime time.Time + SigningDuration time.Duration + StatusCode int + TimeToFirstByte time.Duration + UnMarshallingDuration time.Duration + type DefaultSerializer struct + func (DefaultSerializer) Serialize(obj interface{}) (string, error) + type MetricContext struct + func Context(ctx context.Context) *MetricContext + func (mc *MetricContext) ConnectionCounter() *SharedConnectionCounter + func (mc *MetricContext) Data() *MetricData + func (mc *MetricContext) Publisher() MetricPublisher + type MetricData struct + APICallDuration time.Duration + Attempts []AttemptMetrics + ClientRequestID string + EndpointResolutionDuration time.Duration + InThroughput float64 + MarshallingDuration time.Duration + OperationName string + OutThroughput float64 + PartitionID string + Region string + RequestContentLength int64 + RequestEndTime time.Time + RequestStartTime time.Time + ResolveEndpointEndTime time.Time + ResolveEndpointStartTime time.Time + RetryCount int + SerializeEndTime time.Time + SerializeStartTime time.Time + ServiceID string + StatusCode int + Stream StreamMetrics + Success uint8 + func (md *MetricData) ComputeRequestMetrics() + func (md *MetricData) LatestAttempt() (*AttemptMetrics, error) + func (md *MetricData) NewAttempt() + type MetricPublisher interface + PostRequestMetrics func(*MetricData) error + PostStreamMetrics func(*MetricData) error + type Serializer interface + Serialize func(obj interface{}) (string, error) + type SharedConnectionCounter struct + func (cc *SharedConnectionCounter) ActiveRequests() int + func (cc *SharedConnectionCounter) AddActiveRequest() + func (cc *SharedConnectionCounter) AddPendingConnectionAcquire() + func (cc *SharedConnectionCounter) PendingConnectionAcquire() int + func (cc *SharedConnectionCounter) RemoveActiveRequest() + func (cc *SharedConnectionCounter) RemovePendingConnectionAcquire() + type StreamMetrics struct + ReadBytes int64 + ReadDuration time.Duration + Throughput float64
Go to main page