kinesis

Documentation

Index

• type KinesisClient
  • func GetClient(kinesisStreamName string, awsregion string) KinesisClient
• type KinesisEvents

Types

type KinesisClient

type KinesisClient interface {
	Send(machineID string, events KinesisEvents) (err error)
}

func GetClient

func GetClient(kinesisStreamName string, awsregion string) KinesisClient

type KinesisEvents

type KinesisEvents struct {
	Items []interface{}
}

KinesisEventUploadEvent is a single event entry that appends the MachineID with the EventUploadEvent details