eventbridge

Documentation

Index

• func Must(q swarm.Queue, err error) swarm.Queue
• func New(sys swarm.System, queue string, opts ...*swarm.Policy) (swarm.Queue, error)
• func NewSystem(id string) swarm.System
• type ServerlessApp
  • func NewServerlessApp(sys string) ServerlessApp
• type Sink
  • func NewSink(scope constructs.Construct, id *string, props *SinkProps) Sink
• type SinkProps

Functions

func Must

func Must(q swarm.Queue, err error) swarm.Queue

Must ensures successful creation of queue

func New

func New(sys swarm.System, queue string, opts ...*swarm.Policy) (swarm.Queue, error)

New create a logical queue (topic) over eventbridge

func NewSystem

func NewSystem(id string) swarm.System

NewSystem creates new queueing system

Types

type ServerlessApp

type ServerlessApp interface {
	awscdk.App
	CreateEventBus() ServerlessApp
	AttachEventBus(string) ServerlessApp
	CreateSink(*SinkProps) ServerlessApp
}

func NewServerlessApp

func NewServerlessApp(sys string) ServerlessApp

NewApp ...

type Sink

type Sink interface {
	constructs.Construct
}

Sink ...

func NewSink

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

NewSink ...

type SinkProps

type SinkProps struct {
	System   awsevents.IEventBus
	Queue    string
	Category string
	Lambda   *scud.FunctionGoProps
}

SinkProps ...