eventbridge

Documentation

Index

• 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
• type ServerlessApp
  • func NewServerlessApp() *ServerlessApp
  • func (app *ServerlessApp) NewStack(name string) *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(bus string, opts ...swarm.Option) (swarm.Broker, error)

New create broker for AWS EventBridge service

Types

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
}

ServerlessApp ...

func NewServerlessApp

func NewServerlessApp() *ServerlessApp

NewServerlessApp ...

func (*ServerlessApp) NewStack

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

type ServerlessStack

type ServerlessStack struct {
	awscdk.Stack
	// 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

NewSink ...

type SinkProps

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

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