kinesis

Documentation

Overview

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

Index

• Constants
• type Kinesis
  • func New(conn kinesisiface.KinesisAPI) *Kinesis
  • func (r *Kinesis) Send(ctx context.Context, evt *outboxer.OutboxMessage) error

Constants

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"
)

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.