sources

Documentation

Index

• func ConfirmSubscription(notification *SnsNotification) (err error)
• func ReadSnsMessages(messages []string) (result []*common.DataStream, err error)
• type ErrUnsupportedFileType
  • func (e *ErrUnsupportedFileType) Error() string
• type MessageForwarderReader
  • func NewMessageForwarderReader(input io.Reader) *MessageForwarderReader
  • func (r *MessageForwarderReader) Read(p []byte) (n int, 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 ReadSnsMessages

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 ErrUnsupportedFileType

type ErrUnsupportedFileType struct {
	Type string
}

ErrUnsupportedFileType is returned when the log processor encounters a file type that is not supported and cannot process

func (*ErrUnsupportedFileType) Error

func (e *ErrUnsupportedFileType) Error() string

type MessageForwarderReader

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

func NewMessageForwarderReader

func NewMessageForwarderReader(input io.Reader) *MessageForwarderReader

Reader for messages sent by the Message Forwarder Lambda

func (*MessageForwarderReader) Read

func (r *MessageForwarderReader) Read(p []byte) (n int, err error)

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.