kinesis

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Sep 18, 2019 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package kinesis is the AWS Kinesis implementation of an event stream.

Index

Constants

View Source
const (

	// StreamNameOption is the stream name option
	StreamNameOption = "stream_name"

	// ExplicitHashKeyOption is the explicit hash key option
	ExplicitHashKeyOption = "explicit_hash_key"

	// PartitionKeyOption is the partition key option
	PartitionKeyOption = "partition_key"

	// SequenceNumberForOrderingOption is the sequence number for ordering option
	SequenceNumberForOrderingOption = "partition_key"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Kinesis

type Kinesis struct {
	// contains filtered or unexported fields
}

Kinesis is the wrapper for the Kinesis library

func New

func New(conn kinesisiface.KinesisAPI) *Kinesis

New creates a new instance of Kinesis

func (*Kinesis) Send

func (r *Kinesis) Send(ctx context.Context, evt *outboxer.OutboxMessage) error

Send sends the message to the event stream

Jump to

Keyboard shortcuts

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