Documentation
¶
Index ¶
- func ObserveTransportBindingWait(transportName, phase string, duration time.Duration)
- func RecordConnectorCapabilityChange(namespace, binding, field string)
- func RecordConnectorCapabilityFieldEvent(namespace, binding, field, outcome string)
- func RecordConnectorConnectionState(endpoint string, connected bool)
- func RecordConnectorControlDirective(namespace, binding, direction, typ string)
- func RecordConnectorDownstreamDrop(namespace, binding, reason string)
- func RecordConnectorObservationDrop(namespace, binding, reason string)
- func RecordConnectorObservationSkip(namespace, binding, reason string)
- func RecordConnectorPatchFailure(namespace, binding string)
- func RecordConnectorPatchSuccess(namespace, binding string)
- func RecordConnectorReporterExit(namespace, binding, reason string)
- func RecordEngramTransportReadyChange(ready bool)
- func RecordHubActiveStreams(count float64)
- func RecordHubBufferBytes(storyRun, step string, bytes int)
- func RecordHubBufferFlush(storyRun, step string, count int)
- func RecordHubBufferSize(storyRun, step string, size int)
- func RecordHubEventTime(storyRun, step string, eventTime time.Time, lag time.Duration)
- func RecordHubHeartbeat(storyRun, step string)
- func RecordHubHeartbeatFailure()
- func RecordHubHeartbeatInterval(interval time.Duration)
- func RecordHubMessageDropped(storyRun, step, reason string)
- func RecordHubMessageReceived(storyRun, step string)
- func RecordHubMessageSent(storyRun, step string)
- func RecordHubRecording(storyRun, step, mode, status string)
- func RecordHubReplayLastAck(storyRun, step, partition string, ack uint64)
- func RecordHubReplayPending(storyRun, step string, pending int)
- func RecordHubStartupCapabilitiesObservation(mode string)
- func RecordTransportBindingPending(transportName string)
- func RecordTransportCleanup(namespace string, count int)
- func RefreshHubConfigMetrics(maxMessages, maxBytes int)
- func SetConnectorCapabilityListeners(namespace, binding string, count float64)
- func StreamServerInterceptor() grpc.StreamServerInterceptor
- func UnaryServerInterceptor() grpc.UnaryServerInterceptor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ObserveTransportBindingWait ¶ added in v0.3.0
ObserveTransportBindingWait records how long a StoryRun has waited (or waited before succeeding) for TransportBindings to appear.
func RecordConnectorCapabilityChange ¶ added in v0.3.0
func RecordConnectorCapabilityChange(namespace, binding, field string)
RecordConnectorCapabilityChange increments the counter for the provided binding/field.
func RecordConnectorCapabilityFieldEvent ¶ added in v0.3.0
func RecordConnectorCapabilityFieldEvent(namespace, binding, field, outcome string)
RecordConnectorCapabilityFieldEvent records capability field observations keyed by outcome.
func RecordConnectorConnectionState ¶ added in v0.3.0
RecordConnectorConnectionState sets the connection state gauge for the given hub endpoint. Pass connected=true when the connector establishes a connection, false when disconnected.
func RecordConnectorControlDirective ¶ added in v0.3.0
func RecordConnectorControlDirective(namespace, binding, direction, typ string)
RecordConnectorControlDirective increments the counter for sent/received control directives.
func RecordConnectorDownstreamDrop ¶ added in v0.3.0
func RecordConnectorDownstreamDrop(namespace, binding, reason string)
RecordConnectorDownstreamDrop increments the counter when Subscribe drops a frame.
func RecordConnectorObservationDrop ¶ added in v0.3.0
func RecordConnectorObservationDrop(namespace, binding, reason string)
RecordConnectorObservationDrop increments the counter when an observation is dropped.
func RecordConnectorObservationSkip ¶ added in v0.3.0
func RecordConnectorObservationSkip(namespace, binding, reason string)
RecordConnectorObservationSkip increments the counter when an observation is skipped.
func RecordConnectorPatchFailure ¶ added in v0.3.0
func RecordConnectorPatchFailure(namespace, binding string)
RecordConnectorPatchFailure increments the counter when TransportBinding status patches fail.
func RecordConnectorPatchSuccess ¶ added in v0.3.0
func RecordConnectorPatchSuccess(namespace, binding string)
RecordConnectorPatchSuccess increments the counter when TransportBinding status patches succeed.
func RecordConnectorReporterExit ¶ added in v0.3.0
func RecordConnectorReporterExit(namespace, binding, reason string)
RecordConnectorReporterExit increments the counter when the reporter stops draining observations.
func RecordEngramTransportReadyChange ¶ added in v0.3.0
func RecordEngramTransportReadyChange(ready bool)
RecordEngramTransportReadyChange increments the readiness-change counter when Engram annotations flip between ready states.
func RecordHubActiveStreams ¶ added in v0.3.0
func RecordHubActiveStreams(count float64)
RecordHubActiveStreams sets the current number of active streams in the hub.
func RecordHubBufferBytes ¶
RecordHubBufferBytes records the current buffer size in bytes
func RecordHubBufferFlush ¶
RecordHubBufferFlush records a successful buffer flush
func RecordHubBufferSize ¶
RecordHubBufferSize records the current buffer size (for autoscaling)
func RecordHubEventTime ¶ added in v0.3.0
RecordHubEventTime records event-time watermark and lag metrics.
func RecordHubHeartbeat ¶ added in v0.3.0
func RecordHubHeartbeat(storyRun, step string)
RecordHubHeartbeat records a heartbeat packet received on the stream.
func RecordHubHeartbeatFailure ¶ added in v0.3.0
func RecordHubHeartbeatFailure()
RecordHubHeartbeatFailure increments the failure counter when SendHeartbeats fails.
func RecordHubHeartbeatInterval ¶ added in v0.3.0
RecordHubHeartbeatInterval records the currently effective heartbeat interval.
func RecordHubMessageDropped ¶
func RecordHubMessageDropped(storyRun, step, reason string)
RecordHubMessageDropped records a dropped message
func RecordHubMessageReceived ¶
func RecordHubMessageReceived(storyRun, step string)
RecordHubMessageReceived records a received message at the hub
func RecordHubMessageSent ¶
func RecordHubMessageSent(storyRun, step string)
RecordHubMessageSent records a message successfully sent from the hub
func RecordHubRecording ¶ added in v0.3.0
func RecordHubRecording(storyRun, step, mode, status string)
RecordHubRecording records stream recording outcomes.
func RecordHubReplayLastAck ¶ added in v0.3.0
RecordHubReplayLastAck records the last acknowledged sequence for a partition.
func RecordHubReplayPending ¶ added in v0.3.0
RecordHubReplayPending records the current number of unacked messages.
func RecordHubStartupCapabilitiesObservation ¶ added in v0.3.0
func RecordHubStartupCapabilitiesObservation(mode string)
RecordHubStartupCapabilitiesObservation records the startup capability mode declared by a connector on the hub stream metadata.
func RecordTransportBindingPending ¶ added in v0.3.0
func RecordTransportBindingPending(transportName string)
RecordTransportBindingPending increments the counter when a transport needs to requeue waiting for the operator to seed TransportBindings.
func RecordTransportCleanup ¶ added in v0.3.0
RecordTransportCleanup increments the cleanup counter when EnsureCleanUp resets Engram annotations.
func RefreshHubConfigMetrics ¶ added in v0.3.0
func RefreshHubConfigMetrics(maxMessages, maxBytes int)
RefreshHubConfigMetrics updates the configuration gauges at runtime. Call this when the operator configuration changes to keep metrics accurate.
func SetConnectorCapabilityListeners ¶ added in v0.3.0
SetConnectorCapabilityListeners records how many listeners are currently registered.
func StreamServerInterceptor ¶
func StreamServerInterceptor() grpc.StreamServerInterceptor
StreamServerInterceptor records duration and status code for streaming RPCs.
func UnaryServerInterceptor ¶
func UnaryServerInterceptor() grpc.UnaryServerInterceptor
UnaryServerInterceptor records duration and status code for unary RPCs.
Types ¶
This section is empty.
Source Files