Documentation
¶
Overview ¶
Package kinesis contains helpers for AWS Kinesis.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateDatastream ¶
func CreateDatastream(kc kinesisiface.KinesisAPI, f *framework.Framework) string
CreateDatastream creates a stream named after the given framework.Framework.
func DeleteStream ¶
func DeleteStream(kc kinesisiface.KinesisAPI, name string)
DeleteStream deletes a Kinesis stream by name.
func GetRecords ¶ added in v1.14.0
func GetRecords(kc kinesisiface.KinesisAPI, name string) []*kinesis.Record
GetRecords get records from a kinesis data stream.
func PutRecord ¶
func PutRecord(kc kinesisiface.KinesisAPI, name string) string
PutRecord sends a message to a stream by name.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.