queue

Documentation

Index

• Constants
• func ProcessMessages(sqsService *sqs.SQS, sqsQueueUrl string, ...)
• func SendNotification(snsService *sns.SNS, snsTopicArn string, json []byte) error

Constants

const (
	SNS_CONTENT_TYPE_KEY              = "CLAIR.CONTENTTYPE"
	SNS_CONTENT_TYPE_VALUE_JSON       = "application/json"
	SNS_CONTENT_TYPE_VALUE_BASE64GZIP = "application/base64gzip"
	MAX_MESSAGE_SIZE                  = 250 * 1024 // some metadata overhead to 256k
)

Functions

func ProcessMessages

func ProcessMessages(sqsService *sqs.SQS, sqsQueueUrl string, messageProcessor func(msgid, msg string) error)

func SendNotification

func SendNotification(snsService *sns.SNS, snsTopicArn string, json []byte) error