eventsqs

Documentation

Index

• Constants
• func NewDequeuer(opts ...Option) (*kernel.Dequeuer, error)
• type Broker
  • func NewBroker(scope constructs.Construct, id *string, props *BrokerProps) *Broker
  • func (broker *Broker) AddQueue(queueArn *string) awssqs.IQueue
  • func (broker *Broker) NewQueue(props *awssqs.QueueProps) awssqs.IQueue
  • func (broker *Broker) NewSink(props *SinkProps) *Sink
• type BrokerProps
• type Client
• type Option
  • func WithConfig(opts ...swarm.Option) Option
• type Sink
  • func NewSink(scope constructs.Construct, id *string, props *SinkProps) *Sink
• type SinkProps

Constants

const Version = "broker/eventsqs/v0.20.0"

Functions

func NewDequeuer

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

New creates broker for AWS SQS (serverless events)

Types

type Broker

type Broker struct {
	constructs.Construct
	Queue awssqs.IQueue
	// contains filtered or unexported fields
}

func NewBroker

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

func (*Broker) AddQueue

func (broker *Broker) AddQueue(queueArn *string) awssqs.IQueue

func (*Broker) NewQueue

func (broker *Broker) NewQueue(props *awssqs.QueueProps) awssqs.IQueue

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
}

type Option

type Option func(*Client)

func WithConfig

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

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 {
	Queue    awssqs.IQueue
	Function scud.FunctionProps
}