eventbridge

Apr 10, 2024

Changes in this version

type Sink

+ Rule awsevents.Rule

Mar 23, 2024

Changes in this version

+ type Broker struct

+ Bus awsevents.IEventBus

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

+ func (broker *Broker) AddEventBus(eventBusName string) awsevents.IEventBus

+ func (broker *Broker) NewEventBus(props *awsevents.EventBusProps) awsevents.IEventBus

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

+ type BrokerProps struct

+ System string

Mar 11, 2024

Changes in this version

+ type Client struct

+ func NewEventBridge(bus string, opts ...swarm.Option) (*Client, error)

+ func (cli *Client) Enq(bag swarm.Bag) error

Nov 10, 2023

Changes in this version

type ServerlessStack

+ Bus awsevents.IEventBus

Nov 13, 2022

Changes in this version

+ func FromContext(app awscdk.App, key string) string

+ func FromContextVsn(app awscdk.App) string

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

+ type EventBridge interface

+ PutEvents func(context.Context, *eventbridge.PutEventsInput, ...func(*eventbridge.Options)) (*eventbridge.PutEventsOutput, error)

+ type ServerlessApp struct

+ func NewServerlessApp() *ServerlessApp

+ func (app *ServerlessApp) NewStack(name string) *ServerlessStack

+ type ServerlessStack struct

+ func NewServerlessStack(app awscdk.App, id *string, props *ServerlessStackProps) *ServerlessStack

+ func (stack *ServerlessStack) AddEventBus(eventBusName string) awsevents.IEventBus

+ func (stack *ServerlessStack) NewEventBus(eventBusName ...string) awsevents.IEventBus

+ func (stack *ServerlessStack) NewSink(props *SinkProps) *Sink

+ type ServerlessStackProps struct

+ System string

+ Version string

+ type Sink struct

+ Handler awslambda.IFunction

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

+ type SinkProps struct

+ Categories []string

+ Lambda *scud.FunctionGoProps

+ Pattern map[string]interface{}

+ Source []string

+ System awsevents.IEventBus