process

Nov 12, 2020

Changes in this version

type CreateTablesMessage

+ Sync bool

Oct 28, 2020

Changes in this version

+ const PantherMessageType

+ var CreateTableMessageAttribute = sqs.MessageAttributeValue

+ func Handle(ctx context.Context, event *DataCatalogEvent) (err error)

+ func HandleCreateTablesMessage(ctx context.Context, msg *CreateTablesMessage) error

+ func HandleS3Notification(notification S3Notification) error

+ type CreateTablesMessage struct

+ LogTypes []string

+ func (m CreateTablesMessage) Send(sqsClient sqsiface.SQSAPI, queueURL string) error

+ type S3Notification struct

+ Records []events.S3EventRecord

+ func NewS3ObjectPutNotification(bucket, key string, nbytes int) *S3Notification

Oct 14, 2020

Changes in this version

+ func HandleSyncEvent(ctx context.Context, event *SyncEvent) error

+ func HandleSyncTableEvent(ctx context.Context, event *SyncTableEvent) error

+ func InvokeBackgroundSync(ctx context.Context, lambdaAPI lambdaiface.LambdaAPI, event *SyncEvent) (err error)

+ type DataCatalogEvent struct

+ SyncDatabaseEvent *SyncEvent

+ SyncTablePartitions *SyncTableEvent

type SyncEvent

+ DatabaseNames []string

+ DryRun bool

+ TraceID string

+ type SyncTableEvent struct

+ NumCalls int

+ NumTimeouts int

+ TraceID string

Jun 24, 2020

Changes in this version

+ func InvokeSyncGluePartitions(lambdaClient lambdaiface.LambdaAPI, logTypes []string) error

+ func Sync(event *SyncEvent, deadline time.Time) error

+ type Continuation struct

+ DataType models.DataType

+ LogType string

+ NextPartitionTime time.Time

+ type SyncEvent struct

+ Continuation *Continuation

+ LogTypes []string

+ Sync bool

May 6, 2020

Changes in this version

+ func SQS(event events.SQSEvent) error

+ func Setup()