Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfirmSubscription ¶
func ConfirmSubscription(notification *SnsNotification) (err error)
ConfirmSubscription will confirm the SNS->SQS subscription
func ReadSnsMessages ¶ added in v1.1.0
func ReadSnsMessages(messages []string) (result []*common.DataStream, err error)
ReadSnsMessages reads incoming messages containing SNS notifications and returns a slice of DataStream items
Types ¶
type S3ObjectInfo ¶
S3ObjectInfo contains information about the S3 object
func ParseNotification ¶
func ParseNotification(message string) ([]*S3ObjectInfo, error)
ParseNotification parses a message received
type SnsNotification ¶
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.
Click to show internal directories.
Click to hide internal directories.