kinesis

package
v0.1.9-patch-2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 20, 2020 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL