eventbridge

Dec 23, 2024

Changes in this version

+ func Like(seq ...Expr) *awsevents.EventPattern

+ type Expr func(*awsevents.EventPattern)

+ func Category(cats ...string) Expr

+ func EventData(key string, values ...any) Expr

+ func EventMeta(key string, values ...any) Expr

+ func Has(key string, values ...any) Expr

+ func Source(sources ...string) Expr

+ func Type[T any]() Expr

type SinkProps

+ EventPattern *awsevents.EventPattern

Sep 30, 2024

Changes in this version

+ const EnvConfigSourceEventBridge

Sep 30, 2024

Changes in this version

+ func NewDequeuer(queue string, opts ...Option) (*kernel.Dequeuer, error)

+ func NewEnqueuer(queue string, opts ...Option) (*kernel.Enqueuer, error)

Sep 29, 2024

Changes in this version

+ const EnvEventBridge

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

+ func NewWriter(queue string, opts ...Option) (*kernel.Enqueuer, error)

+ type Option func(*Client)

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

+ func WithEnv() Option

+ func WithService(service EventBridge) Option

Sep 25, 2024

Changes in this version

+ const Version

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

+ 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

+ type Client struct

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

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

+ type EventBridge interface

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

+ type Sink struct

+ Handler awslambda.IFunction

+ Rule awsevents.Rule

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

+ type SinkProps struct

+ Categories []string

+ Function scud.FunctionProps

+ Pattern map[string]interface{}

+ Source []string

+ System awsevents.IEventBus