Documentation
¶
Overview ¶
Package pings provides utilities for creating and handling ping tasks.
Index ¶
Constants ¶
View Source
const IsPingMetadataKey = "is-ping"
IsPingMetadataKey is the metadata key used to identify ping tasks.
View Source
const IsPingMetadataValue = "true"
IsPingMetadataValue is the metadata value used to mark a task as a ping.
View Source
const PingTimestampMetadataKey = "ping-timestamp"
PingTimestampMetadataKey is the metadata key for storing ping timestamp.
Variables ¶
This section is empty.
Functions ¶
func IsTaskAPing ¶
IsTaskAPing checks if the task is a ping by checking the metadata.
func NewProcessHitsPingTask ¶
func NewProcessHitsPingTask( encoder encoding.EncoderFunc, ) func() (*worker.Task, error)
NewProcessHitsPingTask creates a new empty process hits task. It may be used in conjunction with pinging publisher to make the handler advance processing ticks.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.