Documentation
¶
Index ¶
- func RecordHubBufferBytes(storyRun, step string, bytes int)
- func RecordHubBufferFlush(storyRun, step string, count int)
- func RecordHubBufferSize(storyRun, step string, size int)
- func RecordHubMessageDropped(storyRun, step, reason string)
- func RecordHubMessageReceived(storyRun, step string)
- func RecordHubMessageSent(storyRun, step string)
- func StreamServerInterceptor() grpc.StreamServerInterceptor
- func UnaryServerInterceptor() grpc.UnaryServerInterceptor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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 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
Click to show internal directories.
Click to hide internal directories.