eventbridge

Documentation

Index

• func FromContext(app awscdk.App, key string) string
• func FromContextVsn(app awscdk.App) string
• func New(queue string, opts ...swarm.Option) (swarm.Broker, error)
• type Client
  • func NewEventBridge(bus string, opts ...swarm.Option) (*Client, error)
  • func (cli *Client) Enq(bag swarm.Bag) error
• type EventBridge
• type ServerlessApp
  • func NewServerlessApp() *ServerlessApp
  • func (app *ServerlessApp) NewStack(name string, props ...*awscdk.StackProps) *ServerlessStack
• type ServerlessStack
  • 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
• type Sink
  • func NewSink(scope constructs.Construct, id *string, props *SinkProps) *Sink
• type SinkProps

Functions

func FromContext

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

func FromContextVsn

func FromContextVsn(app awscdk.App) string

func New

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

Types

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 ServerlessApp

type ServerlessApp struct {
	awscdk.App
}

func NewServerlessApp

func NewServerlessApp() *ServerlessApp

func (*ServerlessApp) NewStack

func (app *ServerlessApp) NewStack(name string, props ...*awscdk.StackProps) *ServerlessStack

type ServerlessStack

type ServerlessStack struct {
	awscdk.Stack

	Bus awsevents.IEventBus
	// contains filtered or unexported fields
}

func NewServerlessStack

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

func (*ServerlessStack) AddEventBus

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

func (*ServerlessStack) NewEventBus

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

func (*ServerlessStack) NewSink

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

type ServerlessStackProps

type ServerlessStackProps struct {
	*awscdk.StackProps
	Version string
	System  string
}

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 {
	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