sqs

Documentation

Index

• type Body
• type Client
  • func NewClient(awsRegion, queueURL, endpoint string, ...) (Client, error)
• type ConceptUpdate
• type Message
• type NotificationClient
  • func (c *NotificationClient) Healthcheck() fthealth.Check
  • func (c *NotificationClient) ListenAndServeQueue(ctx context.Context) []ConceptUpdate
  • func (c *NotificationClient) RemoveMessageFromQueue(ctx context.Context, receiptHandle *string) error
• type Record

Types

type Body

type Body struct {
	Message string `json:"Message"`
}

SQS Message Format

type Client

type Client interface {
	ListenAndServeQueue(ctx context.Context) []ConceptUpdate
	RemoveMessageFromQueue(ctx context.Context, receiptHandle *string) error
	Healthcheck() fthealth.Check
}

func NewClient

func NewClient(awsRegion, queueURL, endpoint string, messagesToProcess, visibilityTimeout, waitTime int) (Client, error)

type ConceptUpdate

type ConceptUpdate struct {
	UUID          string
	Bookmark      string
	ReceiptHandle *string
}

type Message

type Message struct {
	Records []Record `json:"Records"`
}

type NotificationClient

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

func (*NotificationClient) Healthcheck

func (c *NotificationClient) Healthcheck() fthealth.Check

func (*NotificationClient) ListenAndServeQueue

func (c *NotificationClient) ListenAndServeQueue(ctx context.Context) []ConceptUpdate

func (*NotificationClient) RemoveMessageFromQueue

func (c *NotificationClient) RemoveMessageFromQueue(ctx context.Context, receiptHandle *string) error

type Record

type Record struct {
	S3       s3     `json:"s3"`
	Bookmark string `json:"bookmark"`
}