eventddb

Documentation

Index

• Constants
• func NewReader(opts ...Option) (*kernel.Dequeuer, error)
• func Source(q *kernel.Dequeuer) (<-chan swarm.Msg[*events.DynamoDBEventRecord], ...)
• type Broker
  • func NewBroker(scope constructs.Construct, id *string, props *BrokerProps) *Broker
  • func (broker *Broker) AddTable(tableName string) awsdynamodb.ITable
  • func (broker *Broker) NewSink(props *SinkProps) *Sink
  • func (broker *Broker) NewTable(props *awsdynamodb.TablePropsV2) awsdynamodb.ITable
• type BrokerProps
• type Client
• type DynamoDBEvent
• type Option
  • func WithConfig(opts ...swarm.Option) Option
• type Sink
  • func NewSink(scope constructs.Construct, id *string, props *SinkProps) *Sink
• type SinkProps

Constants

const Category = "DynamoDBEventRecord"

const EnvConfigSourceDynamoDB = "CONFIG_SWARM_SOURCE_DYNAMODB"

Environment variable to config event source

const Version = "broker/eventddb/v0.20.2"

Functions

func NewReader

func NewReader(opts ...Option) (*kernel.Dequeuer, error)

New creates broker for AWS EventBridge

func Source

func Source(q *kernel.Dequeuer) (
	<-chan swarm.Msg[*events.DynamoDBEventRecord],
	chan<- swarm.Msg[*events.DynamoDBEventRecord],
)

The broker produces only events.DynamoDBEventRecord, the function is helper.

Types

type Broker

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

func NewBroker

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

func (*Broker) AddTable

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

func (*Broker) NewSink

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

func (*Broker) NewTable

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

type BrokerProps

type BrokerProps struct {
	System string
}

type Client

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

type DynamoDBEvent

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

Note: events.DynamoDBEvent decodes all records, the swarm kernel protocol requires bytes.

type Option

type Option func(*Client)

func WithConfig

func WithConfig(opts ...swarm.Option) Option

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
	Function    scud.FunctionProps
	EventSource *awslambdaeventsources.DynamoEventSourceProps
}