"""Constants for kinesis and maxwell."""

# kinesis record's fields
EVENT_RECORDS = 'Records'
RECORD_KINESIS = 'kinesis'
KINESIS_DATA = 'data'

# maxwell record structure
MAXWELL_TABLE = 'table'
MAXWELL_TYPE = 'type'
MAXWELL_DATA = 'data'

# sql operation types from maxwell
TYPE_INSERT = 'insert'
TYPE_UPDATE = 'update'

# sql tables
TABLE_ENCODING_QUEUE = 'encoding_queue'
TABLE_ENCODING_QUEUE_DETAIL = 'encoding_queue_detail'
TABLE_DMS_DELIVERY_SPEC = 'dms_delivery_spec'

# should process only these tables and operations
PROCESSING_RECORDS = {
    TABLE_ENCODING_QUEUE: [TYPE_UPDATE],
    TABLE_DMS_DELIVERY_SPEC: [TYPE_UPDATE],
    TABLE_ENCODING_QUEUE_DETAIL: [TYPE_INSERT, TYPE_UPDATE]
}