kinesis

Documentation

Overview

Package kinesis contains helpers for AWS Kinesis.

Index

• func CreateDatastream(kc kinesisiface.KinesisAPI, f *framework.Framework) string
• func DeleteStream(kc kinesisiface.KinesisAPI, name string)
• func GetRecords(kc kinesisiface.KinesisAPI, name string) []*kinesis.Record
• func PutRecord(kc kinesisiface.KinesisAPI, name string) string

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

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.