awsfirehose

Documentation

Index

• Constants
• type AWSFirehose
  • func (a AWSFirehose) Call(payload []byte) ([]byte, error)
  • func (a AWSFirehose) MarshalLogObject(enc zapcore.ObjectEncoder) error
• type ProviderLoader
  • func (p ProviderLoader) Load(data []byte) (function.Provider, error)

Constants

const Type = function.ProviderType("awsfirehose")

Type of provider.

Types

type AWSFirehose

type AWSFirehose struct {
	Service firehoseiface.FirehoseAPI `json:"-" validate:"-"`

	DeliveryStreamName string `json:"deliveryStreamName" validate:"required"`
	Region             string `json:"region" validate:"required"`
	AWSAccessKeyID     string `json:"awsAccessKeyId,omitempty"`
	AWSSecretAccessKey string `json:"awsSecretAccessKey,omitempty"`
	AWSSessionToken    string `json:"awsSessionToken,omitempty"`
}

AWSFirehose function implementation

func (AWSFirehose) Call

func (a AWSFirehose) Call(payload []byte) ([]byte, error)

Call puts record into AWS Firehose stream.

func (AWSFirehose) MarshalLogObject

func (a AWSFirehose) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject is a part of zapcore.ObjectMarshaler interface.

type ProviderLoader

type ProviderLoader struct{}

ProviderLoader implementation

func (ProviderLoader) Load

func (p ProviderLoader) Load(data []byte) (function.Provider, error)

Load decode JSON data as Config and return initialized Provider instance.