senders

package

v0.0.0-...-25bc77e Latest Latest Go to latest Published: Nov 10, 2025 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SQSSender struct {
	// contains filtered or unexported fields
}

SQSSender pushes envelopes to an SQS queue (works with LocalStack).

func NewSQS(ctx context.Context, endpointURL, queueURL string) (*SQSSender, error)

NewSQS creates an SQS client targeting the given endpoint and queue.

func (s *SQSSender) Send(ctx context.Context, msg txoutbox.Envelope) error

Send implements txoutbox.Sender by posting the raw JSON payload to SQS.

type WebhookSender struct {
	// contains filtered or unexported fields
}

WebhookSender posts envelopes to an HTTP endpoint.

func NewWebhook(target string) *WebhookSender

func (s *WebhookSender) Send(ctx context.Context, msg txoutbox.Envelope) error