eventddb

package
v0.15.5 Latest Latest
Warning

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

Go to latest
Published: Apr 21, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const Category = "DynamoDBEventRecord"

Variables

This section is empty.

Functions

func New

func New(queue string, opts ...swarm.Option) (swarm.Broker, error)

New creates broker for AWS EventBridge

Types

type Broker added in v0.15.0

type Broker struct {
	constructs.Construct
	Table awsdynamodb.ITable
	// contains filtered or unexported fields
}

func NewBroker added in v0.15.0

func NewBroker(scope constructs.Construct, id *string, props *BrokerProps) *Broker

func (*Broker) AddTable added in v0.15.0

func (broker *Broker) AddTable(tableName string) awsdynamodb.ITable

func (*Broker) NewSink added in v0.15.0

func (broker *Broker) NewSink(props *SinkProps) *Sink

func (*Broker) NewTable added in v0.15.0

func (broker *Broker) NewTable(props *awsdynamodb.TablePropsV2) awsdynamodb.ITable

type BrokerProps added in v0.15.0

type BrokerProps struct {
	System string
}

type DynamoDBEvent added in v0.13.3

type DynamoDBEvent struct {
	Records []json.RawMessage `json:"Records"`
}

type Sink

type Sink struct {
	constructs.Construct
	Handler awslambda.IFunction
}

func NewSink

func NewSink(scope constructs.Construct, id *string, props *SinkProps) *Sink

type SinkProps

type SinkProps struct {
	Table       awsdynamodb.ITable
	Lambda      *scud.FunctionGoProps
	EventSource *awslambdaeventsources.DynamoEventSourceProps
}

Jump to

Keyboard shortcuts

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