Documentation
¶
Index ¶
- func CreateReplayDevices(t *testing.T, logger zerolog.Logger, deviceMessages map[string][][]byte, ...) ([]*loadgen.Device, int)
- func ReadMessagesFromGCS(t *testing.T, ctx context.Context, logger zerolog.Logger, ...) (map[string][][]byte, error)
- func ReplayGCSMessagesToMQTT(t *testing.T, ctx context.Context, logger zerolog.Logger, ...) (int, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateReplayDevices ¶
func CreateReplayDevices( t *testing.T, logger zerolog.Logger, deviceMessages map[string][][]byte, replayDuration time.Duration, ) ([]*loadgen.Device, int)
CreateReplayDevices takes messages grouped by device ID and a replay duration, and returns a slice of loadgen.Device objects configured for replay.
func ReadMessagesFromGCS ¶
func ReadMessagesFromGCS( t *testing.T, ctx context.Context, logger zerolog.Logger, gcsClient *storage.Client, bucketName string, ) (map[string][][]byte, error)
ReadMessagesFromGCS reads gzipped JSON messages from a GCS bucket. It assumes the messages are in a format from which a deviceID can be extracted and groups them by device ID.
func ReplayGCSMessagesToMQTT ¶
func ReplayGCSMessagesToMQTT( t *testing.T, ctx context.Context, logger zerolog.Logger, mqttEmulatorAddress string, devices []*loadgen.Device, replayDuration time.Duration, ) (int, error)
ReplayGCSMessagesToMQTT takes a slice of pre-configured loadgen.Device objects and publishes their messages to the MQTT emulator.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.