sqs

Documentation

Index

• type Body
• type Client
  • func NewClient(awsRegion string, queueUrl string, messagesToProcess int, ...) (Client, error)
• type ConceptChanges
• type ConceptEvent
• type ConceptUpdate
• type ConcordanceEvent
• type Event
• 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
  • func (c *NotificationClient) SendEvents(ctx context.Context, messages []Event) 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
	SendEvents(ctx context.Context, messages []Event) error
	RemoveMessageFromQueue(ctx context.Context, receiptHandle *string) error
	Healthcheck() fthealth.Check
}

func NewClient

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

type ConceptChanges

type ConceptChanges struct {
	ChangedRecords []Event  `json:"events"`
	UpdatedIds     []string `json:"updatedIDs"`
}

Events

type ConceptEvent

type ConceptEvent struct {
	Type string `json:"eventType"`
}

type ConceptUpdate

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

type ConcordanceEvent

type ConcordanceEvent struct {
	Type  string `json:"eventType"`
	OldID string `json:"oldID"`
	NewID string `json:"newID"`
}

type Event

type Event struct {
	ConceptType   string      `json:"type"`
	ConceptUUID   string      `json:"uuid"`
	AggregateHash string      `json:"aggregateHash"`
	TransactionID string      `json:"transactionID"`
	EventDetails  interface{} `json:"eventDetails"`
}

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

func (*NotificationClient) SendEvents

func (c *NotificationClient) SendEvents(ctx context.Context, messages []Event) error

type Record

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