Versions in this module Expand all Collapse all v1 v1.6.65 Sep 23, 2024 v1.6.64 Sep 13, 2024 v1.6.4 Sep 13, 2024 Changes in this version + const AggregatingMergeTree + const CKDBTypeByconity + const CKDBTypeClickhouse + const CnchAggregatingMergeTree + const CnchMergeTree + const CnchReplacingMergeTree + const CnchSummingMergeTree + const DEFAULT_COLUMN_COUNT + const DEFAULT_ORG_ID + const DEFAULT_TEAM_ID + const DF_CLUSTER + const DF_REPLICATED_CLUSTER + const DF_STORAGE_POLICY + const DF_TIMEZONE + const Distributed + const EngineByconityOffset + const INVALID_ORG_ID + const INVALID_TEAM_ID + const LOCAL_SUBFFIX + const MAX_ORG_ID + const METRICS_DB + const MergeTree + const ORG_ID_LEN + const ORG_ID_PREFIX_LEN + const ReplacingMergeTree + const ReplicatedAggregatingMergeTree + const ReplicatedMergeTree + const SummingMergeTree + func IsDefaultOrgID(orgID uint16) bool + func IsValidOrgID(orgID uint16) bool + func OrgDatabasePrefix(orgID uint16) string + type Block struct + func NewBlock(batch driver.Batch) *Block + func (b *Block) Send() error + func (b *Block) Write(v ...interface{}) + func (b *Block) WriteAll() error + func (b *Block) WriteBool(v bool) + func (b *Block) WriteDateTime(v uint32) + func (b *Block) WriteIPv4(v uint32) + func (b *Block) WriteIPv6(v net.IP) + type CodecType uint8 + const CodecDefault + const CodecDelta + const CodecDoubleDelta + const CodecGorilla + const CodecLZ4 + const CodecLZ4HC + const CodecNone + const CodecT64 + const CodecZSTD + func (t CodecType) String() string + type ColdStorage struct + Enabled bool + Name string + TTLToMove int + Type DiskType + func GetColdStorage(coldStorages map[string]*ColdStorage, db, table string) *ColdStorage + type Column struct + Codec CodecType + Comment string + GroupBy bool + Index IndexType + Name string + Type ColumnType + TypeArgs string + func NewColumn(name string, t ColumnType) *Column + func NewColumnWithGroupBy(name string, t ColumnType) *Column + func NewColumns(names []string, t ColumnType) []*Column + func NewColumnsWithComment(nameComments [][2]string, t ColumnType) []*Column + func (c *Column) MakeModifyTimeZoneSQL(database, table, timeZone string) string + func (c *Column) SetCodec(ct CodecType) *Column + func (c *Column) SetComment(comment string) *Column + func (c *Column) SetGroupBy() *Column + func (c *Column) SetIndex(i IndexType) *Column + func (c *Column) SetTypeArgs(args string) *Column + type ColumnType uint8 + const ArrayFloat64 + const ArrayInt64 + const ArrayLowCardinalityString + const ArrayString + const ArrayUInt16 + const ArrayUInt32 + const ArrayUInt8 + const DateTime + const DateTime64 + const DateTime64ms + const DateTime64us + const ENUM8 + const FixString8 + const Float64 + const Float64Nullable + const IPv4 + const IPv6 + const Int16 + const Int16Nullable + const Int32 + const Int32Nullable + const Int64 + const Int64Nullable + const Int8 + const Int8Nullable + const LowCardinalityString + const String + const UInt16 + const UInt16Nullable + const UInt32 + const UInt32Nullable + const UInt64 + const UInt64Nullable + const UInt8 + const UInt8Nullable + func (t ColumnType) HasDFTimeZone() bool + func (t ColumnType) String() string + type DiskType uint8 + const Disk + const Volume + func (t DiskType) String() string + type EngineType uint8 + func (t EngineType) String() string + type IndexType uint8 + const IndexBloomfilter + const IndexMinmax + const IndexNone + const IndexSet + const IndexTokenbf + func (t IndexType) String() string + type Table struct + Cluster string + ColdStorage ColdStorage + Columns []*Column + DBType string + Database string + Engine EngineType + GlobalName string + ID uint8 + LocalName string + OrderKeys []string + PartitionFunc TimeFuncType + PrimaryKeyCount int + StoragePolicy string + SummingKey string + TTL int + TimeKey string + Version string + func (t *Table) MakeGlobalTableCreateSQL() string + func (t *Table) MakeLocalTableCreateSQL() string + func (t *Table) MakeOrgGlobalTableCreateSQL(orgID uint16) string + func (t *Table) MakeOrgLocalTableCreateSQL(orgID uint16) string + func (t *Table) MakeOrgPrepareTableInsertSQL(orgID uint16) string + func (t *Table) MakePrepareTableInsertSQL() string + func (t *Table) MakeViewsCreateSQLForDeepflowSystem(orgID uint16) []string + func (t *Table) OrgDatabase(orgID uint16) string + type TimeFuncType uint8 + const TimeFuncDay + const TimeFuncFourHour + const TimeFuncHour + const TimeFuncMinute + const TimeFuncMonth + const TimeFuncNone + const TimeFuncTenMinute + const TimeFuncTwelveHour + const TimeFuncTwoHour + const TimeFuncWeek + const TimeFuncYYYYMM + const TimeFuncYYYYMMDD + func (t TimeFuncType) String(timeKey string) string
Go to main page