Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

model

package

Go to main page

Versions in this module

v0

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