firehose

package
v0.0.0-...-fee140a Latest Latest
Warning

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

Go to latest
Published: Mar 5, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New() *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, data [][]byte, stream string) (*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()

Setup creates a Kinesis Firehose client

Jump to

Keyboard shortcuts

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