serializer

type ExtraMaskInfo struct {
	Masked     bool
	ColumnType string
	DefaultVal string
}

type MaskInfo struct {
	Masked bool

	SortCol bool
	DistCol bool

	LengthCol              bool
	MobileCol              bool
	MappingPIICol          bool
	ConditionalNonPIICol   bool
	DependentNonPIICol     bool
	RegexPatternBooleanCol bool
}

type Message struct {
	SchemaId  int
	Topic     string
	Partition int32
	Offset    int64
	Key       string
	Value     interface{}
	Bytes     int64

	Operation       string
	MaskSchema      map[string]MaskInfo
	ExtraMaskSchema map[string]ExtraMaskInfo
}

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

type MessageBatchAsyncProcessor interface {
	Process(
		wg *sync.WaitGroup,
		session sarama.ConsumerGroupSession,
		processChan <-chan []*Message,
		errChan chan<- error,
	)
}

type MessageBatchSyncProcessor interface {
	Process(session sarama.ConsumerGroupSession, msgBuf []*Message) error
}

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

type Serializer interface {
	Deserialize(message *sarama.ConsumerMessage) (*Message, error)
}