kinesis

Documentation

Index

• type Config
  • func NewFirehose(opts ...func(*Config)) *Config
  • func (config *Config) PutRecord(data []byte) (*firehose.PutRecordOutput, error)
• type Option
  • func SetDeliveryStream(deliveryStream string) Option
  • func SetLogger(log *logrus.Logger) Option
  • func SetProfile(profile string) Option
  • func SetRegion(region string) Option

Types

type Config

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

Configuration structure.

func NewFirehose

func NewFirehose(opts ...func(*Config)) *Config

func (*Config) PutRecord

func (config *Config) PutRecord(data []byte) (*firehose.PutRecordOutput, error)

type Option

type Option func(config *Config)

func SetDeliveryStream

func SetDeliveryStream(deliveryStream string) Option

func SetLogger

func SetLogger(log *logrus.Logger) Option

func SetProfile

func SetProfile(profile string) Option

func SetRegion

func SetRegion(region string) Option