kinesis

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2022 License: AGPL-3.0 Imports: 11 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 NewProducer added in v0.1.10

func NewProducer(destinationConfig interface{}, o Opts) (kinesis.Kinesis, error)

NewProducer creates a producer based on destination config

func Produce

func Produce(jsonData json.RawMessage, producer, destConfig interface{}) (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

type Opts added in v0.1.10

type Opts struct {
	Timeout time.Duration
}

Jump to

Keyboard shortcuts

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