types

type CqnData struct {
	SchemaTableName string
	TableOperation  CqnOpCode
	RowChanges      RowChanges
}

type CqnOpCode uint32

type RowChanges map[RowId]CqnOpCode

type RowId string

type SubscriptionHandler interface {
	ProcessCqnData(d []CqnData)
}