model

package

Go to main page

Versions in this module

v0

v0.5.0

Feb 5, 2025

Changes in this version

+ const Map

+ const Object

type Batch

+ GroupId string

+ Wg *sync.WaitGroup

+ type BatchRange struct

+ Begin int64

+ End int64

type Metric

+ GetMap func(key string, typeinfo *TypeInfo) interface{}

+ GetObject func(key string, nullable bool) interface{}

+ type OrderedMap struct

+ func NewOrderedMap() *OrderedMap

+ func (om *OrderedMap) Get(key interface{}) (interface{}, bool)

+ func (om *OrderedMap) GetValues() map[interface{}]interface{}

+ func (om *OrderedMap) Keys() <-chan interface{}

+ func (om *OrderedMap) Put(key interface{}, value interface{})

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

+ type SeriesQuota struct

+ Birth time.Time

+ BmSeries map[int64]int64

+ NextResetQuota time.Time

+ WrSeries int

type TypeInfo

+ MapKey *TypeInfo

+ MapValue *TypeInfo

v0.5.0-rc1

Jan 31, 2025

v0.4.1

Jul 18, 2023

v0.4.0

Dec 12, 2022

Changes in this version

+ const IPv4

+ const IPv6

type Metric

+ GetIPv4 func(key string, nullable bool) interface{}

+ GetIPv6 func(key string, nullable bool) interface{}

v0.3.0

Nov 4, 2022

v0.2.1

Oct 24, 2022

v0.2.0

Oct 20, 2022

Changes in this version

+ const UUID

type ColumnWithType

+ Const string

type Metric

+ GetUUID func(key string, nullable bool) (val interface{})

v0.1.0

Oct 12, 2022

Changes in this version

+ const Bool

+ const DateTime

+ const Decimal

+ const Float32

+ const Float64

+ const Int16

+ const Int32

+ const Int64

+ const Int8

+ const String

+ const UInt16

+ const UInt32

+ const UInt64

+ const UInt8

+ const Unknown

+ func GetTypeName(typ int) (name string)

+ func GetValueByType(metric Metric, cwt *ColumnWithType) (val interface{})

+ func PutRow(r *Row)

+ func PutRows(rs *Rows)

+ func WhichType(typ string) (dataType int, nullable bool, array bool)

+ type Batch struct

+ BatchIdx int64

+ Group *BatchGroup

+ RealSize int

+ Rows *Rows

+ func NewBatch() (b *Batch)

+ func (b *Batch) Commit() error

+ func (b *Batch) Size() int

+ type BatchGroup struct

+ Batchs []*Batch

+ Offsets map[int]int64

+ PendWrite int32

+ Sys *BatchSys

+ type BatchSys struct

+ func NewBatchSys(taskCfg *config.TaskConfig, fnCommit func(partition int, offset int64) error) *BatchSys

+ func (bs *BatchSys) CreateBatchGroupMulti(batches []*Batch, offsets map[int]int64)

+ func (bs *BatchSys) CreateBatchGroupSingle(batch *Batch, partition int, offset int64)

+ func (bs *BatchSys) TryCommit() error

+ type ColumnWithType struct

+ Array bool

+ Name string

+ Nullable bool

+ SourceName string

+ Type int

+ type DimMetrics struct

+ Dims []*ColumnWithType

+ Fields []*ColumnWithType

+ type InputMessage struct

+ Key []byte

+ Offset int64

+ Partition int

+ Timestamp *time.Time

+ Topic string

+ Value []byte

+ type Metric interface

+ GetArray func(key string, t int) (val interface{})

+ GetBool func(key string, nullable bool) (val interface{})

+ GetDateTime func(key string, nullable bool) (val interface{})

+ GetDecimal func(key string, nullable bool) (val interface{})

+ GetFloat32 func(key string, nullable bool) (val interface{})

+ GetFloat64 func(key string, nullable bool) (val interface{})

+ GetInt16 func(key string, nullable bool) (val interface{})

+ GetInt32 func(key string, nullable bool) (val interface{})

+ GetInt64 func(key string, nullable bool) (val interface{})

+ GetInt8 func(key string, nullable bool) (val interface{})

+ GetNewKeys func(knownKeys, newKeys, warnKeys *sync.Map, white, black *regexp.Regexp, ...) bool

+ GetString func(key string, nullable bool) (val interface{})

+ GetUint16 func(key string, nullable bool) (val interface{})

+ GetUint32 func(key string, nullable bool) (val interface{})

+ GetUint64 func(key string, nullable bool) (val interface{})

+ GetUint8 func(key string, nullable bool) (val interface{})

+ type MsgRow struct

+ Msg *InputMessage

+ Row *Row

+ Shard int

+ type Row []interface

+ var FakedRow Row = make([]interface{}, 0)

+ func GetRow() *Row

+ func MetricToRow(metric Metric, msg *InputMessage, dims []*ColumnWithType, idxSeriesID int, ...) (row *Row)

+ type Rows []*Row

+ func GetRows() (rs *Rows)

+ type TypeInfo struct

+ Array bool

+ Nullable bool

+ Type int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL