firehose

Documentation

Index

• func New(cfg iaws.Config) *firehose.Firehose
• type API
  • func (a *API) IsEnabled() bool
  • func (a *API) PutRecord(ctx aws.Context, data []byte, stream string) (*firehose.PutRecordOutput, error)
  • func (a *API) PutRecordBatch(ctx aws.Context, stream string, data [][]byte) (*firehose.PutRecordBatchOutput, error)
  • func (a *API) Setup(cfg iaws.Config)

Functions

func New

func New(cfg iaws.Config) *firehose.Firehose

New creates a new session for Kinesis Firehose

Types

type API

type API struct {
	Client firehoseiface.FirehoseAPI
}

API wraps a Kinesis Firehose client interface

func (*API) IsEnabled

func (a *API) IsEnabled() bool

IsEnabled checks whether a new client has been set

func (*API) PutRecord

func (a *API) PutRecord(ctx aws.Context, data []byte, stream string) (*firehose.PutRecordOutput, error)

PutRecord is a convenience wrapper for putting a record into a Kinesis Firehose stream.

func (*API) PutRecordBatch

func (a *API) PutRecordBatch(ctx aws.Context, stream string, data [][]byte) (*firehose.PutRecordBatchOutput, error)

PutRecordBatch is a convenience wrapper for putting multiple records into a Kinesis Firehose stream. This function becomes recursive for any records that failed the PutRecord operation.

func (*API) Setup

func (a *API) Setup(cfg iaws.Config)

Setup creates a Kinesis Firehose client