awstrigger

package
v0.229.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 14, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Package awstrigger delivers trigger events over AWS messaging: an SQS queue (a worker consumes and rebuilds) or an EventBridge bus (fan-out to CodeBuild/Step Functions). Callers construct and own the clients.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventBridge 

type EventBridge struct {
	Client *eventbridge.Client
	Bus    string
	Source string // e.g. "lcatd"
}

EventBridge puts each event on a bus.

func NewEventBridge 

func NewEventBridge(ctx context.Context, bus, source, endpoint string) (EventBridge, error)

NewEventBridge builds an EventBridge notifier from the standard AWS environment; a non-empty endpoint overrides the service endpoint.

func (EventBridge) Notify 

func (e EventBridge) Notify(ctx context.Context, ev trigger.Event) error

Notify implements trigger.Notifier.

type SQS 

type SQS struct {
	Client   *sqs.Client
	QueueURL string
}

SQS sends each event as one message.

func NewSQS 

func NewSQS(ctx context.Context, queueURL, endpoint string) (SQS, error)

NewSQS builds an SQS notifier from the standard AWS environment; a non-empty endpoint overrides the service endpoint (LocalStack in dev).

func (SQS) Notify 

func (s SQS) Notify(ctx context.Context, e trigger.Event) error

Notify implements trigger.Notifier.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.