sources

Documentation

Index

• func ConfirmSubscription(notification *SnsNotification) (err error)
• func ReadSQSMessages(messages []events.SQSMessage) (result []*common.DataStream, err error)
• type S3ObjectInfo
  • func ParseNotification(message string) ([]*S3ObjectInfo, error)
• type SnsNotification

Functions

func ConfirmSubscription

func ConfirmSubscription(notification *SnsNotification) (err error)

ConfirmSubscription will confirm the SNS->SQS subscription

func ReadSQSMessages

func ReadSQSMessages(messages []events.SQSMessage) (result []*common.DataStream, err error)

ReadSQSMessages reads incoming messages containing SNS notifications and returns a slice of DataStream items

Types

type S3ObjectInfo

type S3ObjectInfo struct {
	S3Bucket    string
	S3ObjectKey string
}

S3ObjectInfo contains information about the S3 object

func ParseNotification

func ParseNotification(message string) ([]*S3ObjectInfo, error)

ParseNotification parses a message received

type SnsNotification

type SnsNotification struct {
	events.SNSEntity
	Token *string `json:"Token"`
}

SnsNotification struct represents an SNS message arriving to Panther SQS from a customer account. The message can either be of type 'Notification' or 'SubscriptionConfirmation' Since there is no AWS SDK-provided struct to represent both types we had to create this custom type to include fields from both types.