stream

Documentation

Index

• Constants
• type Emitter
  • func New(region string) (*Emitter, error)
  • func (e *Emitter) PutRecord(record []byte, stream string) (*kinesis.PutRecordOutput, error)

Constants

const (
	MAX = "340282366920938463463374607431768211456"
)

Types

type Emitter

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

Emitter ...

awsSession AWS session client Kinesis client

func New

func New(region string) (*Emitter, error)

New ...

Creates an instance of Emitter that can be reused

func (*Emitter) PutRecord

func (e *Emitter) PutRecord(record []byte, stream string) (*kinesis.PutRecordOutput, error)

PutRecord ...

Puts a record into the specified stream and returns and error