eventbridge

Documentation

Index

• func New(queue string, opts ...swarm.Option) (swarm.Broker, error)
• type Broker
  • 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
• type Client
  • func NewEventBridge(bus string, opts ...swarm.Option) (*Client, error)
  • func (cli *Client) Enq(bag swarm.Bag) error
• type EventBridge
• type Sink
  • func NewSink(scope constructs.Construct, id *string, props *SinkProps) *Sink
• type SinkProps

Functions

func New

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

Types

type Broker

type Broker struct {
	constructs.Construct
	Bus awsevents.IEventBus
	// contains filtered or unexported fields
}

func NewBroker

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

func (*Broker) AddEventBus

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

func (*Broker) NewEventBus

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

func (*Broker) NewSink

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

type BrokerProps

type BrokerProps struct {
	System string
}

type Client

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

func NewEventBridge

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

func (*Client) Enq

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

Enq enqueues message to broker

type EventBridge

type EventBridge interface {
	PutEvents(context.Context, *eventbridge.PutEventsInput, ...func(*eventbridge.Options)) (*eventbridge.PutEventsOutput, error)
}

EventBridge declares the subset of interface from AWS SDK used by the lib.

type Sink

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

func NewSink

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

type SinkProps

type SinkProps struct {
	System     awsevents.IEventBus
	Source     []string
	Categories []string
	Pattern    map[string]interface{}
	Lambda     *scud.FunctionGoProps
}

See https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-event-patterns.html