model

type Batch struct {
	Rows     *Rows
	BatchIdx int64
	GroupId  string
	RealSize int

	Wg *sync.WaitGroup
}

type BatchRange struct {
	Begin int64
	End   int64
}

type ColumnWithType struct {
	Name        string
	Type        *TypeInfo
	SourceName  string
	NotNullable bool

	// Const is used to set column value to some constant from config.
	Const string
}

type DimMetrics struct {
	Dims   []*ColumnWithType
	Fields []*ColumnWithType
}

type InputMessage struct {
	Topic     string
	Partition int
	Key       []byte
	Value     []byte
	Offset    int64
	Timestamp *time.Time
}

type Metric interface {
	GetBool(key string, nullable bool) interface{}
	GetInt8(key string, nullable bool) interface{}
	GetInt16(key string, nullable bool) interface{}
	GetInt32(key string, nullable bool) interface{}
	GetInt64(key string, nullable bool) interface{}
	GetUint8(key string, nullable bool) interface{}
	GetUint16(key string, nullable bool) interface{}
	GetUint32(key string, nullable bool) interface{}
	GetUint64(key string, nullable bool) interface{}
	GetFloat32(key string, nullable bool) interface{}
	GetFloat64(key string, nullable bool) interface{}
	GetDecimal(key string, nullable bool) interface{}
	GetDateTime(key string, nullable bool) interface{}
	GetString(key string, nullable bool) interface{}
	GetUUID(key string, nullable bool) interface{}
	GetObject(key string, nullable bool) interface{}
	GetMap(key string, typeinfo *TypeInfo) interface{}
	GetArray(key string, t int) interface{}
	GetIPv4(key string, nullable bool) interface{}
	GetIPv6(key string, nullable bool) interface{}
	GetNewKeys(knownKeys, newKeys, warnKeys *sync.Map, white, black *regexp.Regexp, partition int, offset int64) bool
}

type MsgRow struct {
	Msg   *InputMessage
	Row   *Row
	Shard int
}

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

type RecordMap = map[string]map[int32]*BatchRange

type Row []interface{}

type Rows []*Row

type SeriesQuota struct {
	sync.RWMutex   `json:"-"`
	NextResetQuota time.Time
	BmSeries       map[int64]int64
	WrSeries       int
	Birth          time.Time
}

type TypeInfo struct {
	Type     int
	Nullable bool
	Array    bool
	MapKey   *TypeInfo
	MapValue *TypeInfo
}