kinesis

Documentation

Index

• func GetStatusCodeFromError(err error) int
• func Produce(jsonData json.RawMessage) (int, string, string)
• type Config

Functions

func GetStatusCodeFromError

func GetStatusCodeFromError(err error) int

GetStatusCodeFromError parses the error and returns the status so that event gets retried or failed.

func Produce

func Produce(jsonData json.RawMessage) (int, string, string)

Produce creates a producer and send data to Kinesis.

Types

type Config

type Config struct {
	Region       string
	Stream       string
	AccessKeyID  string
	AccessKey    string
	UseMessageID bool
}

Config is the config that is required to send data to Kinesis