Versions in this module Expand all Collapse all v1 v1.2.0 Feb 29, 2024 Changes in this version + const DATANODE + const DefaultRetentionPolicyDuration + const DefaultRetentionPolicyName + const DefaultRetentionPolicyReplicaN + const DefaultRetentionPolicyWarmDuration + const HASH + const METANODE + const MinRetentionPolicyDuration + const MinRetentionPolicyWarmDuration + const NodeDefault + const NodeReader + const NodeWriter + const Normal + const QueryIDSpan + const RANGE + const Segregated + const Segregating + var DataLogger *zap.Logger + var DownSampleSupportAgg = map[string]bool + var ErrAuthenticate = errors.New("authentication failed") + var ErrClientClosed = errors.New("client already closed") + var ErrClientInited = errors.New("aready inited") + var ErrCommandTimeout = errors.New("execute command timeout") + var ErrConflictWithIo = errors.New("conflict with io") + var ErrContinuosQueryConflict = errors.New("continuous query conflicts with an existing continuous query") + var ErrContinuousQueryExists = errors.New("continuous query already exists") + var ErrContinuousQueryIsBeingDelete = errors.New("continuous query is being delete") + var ErrContinuousQueryNotFound = errors.New("continuous query not found") + var ErrDBPTClose = errors.New("DBPT is being closing") + var ErrDataViewBootStrap = errors.New("cluster is bootstrapping for initial data view") + var ErrDatabaseExists = errors.New("database already exists") + var ErrDatabaseNameRequired = errors.New("database name required") + var ErrDatabaseNotExists = errors.New("database does not exist") + var ErrDuplicateShardKey = errors.New("duplicate shard key") + var ErrFieldTypeConflict = errors.New("field type conflict") + var ErrGrantOrRevokeAdmin = errors.New(...) + var ErrHashedLength = errors.New("hashedSecret too short to be a hashed password") + var ErrIncompatibleDurations = errors.New("retention policy duration must be greater than the shard duration") + var ErrIncompatibleHotDurations = errors.New(...) + var ErrIncompatibleIndexGroupDuration = errors.New(...) + var ErrIncompatibleShardGroupDurations = errors.New(...) + var ErrIncompatibleWarmDurations = errors.New(...) + var ErrIndexGroupNotFound = errors.New("index group not found") + var ErrInvalidName = errors.New("invalid name") + var ErrInvalidPtView = errors.New("invalid ptView number") + var ErrInvalidShardKey = errors.New("invalid shard key") + var ErrMeasurementExists = errors.New("measurement already exists") + var ErrMeasurementIsBeingDelete = errors.New("measurement is being delete") + var ErrMeasurementNameRequired = errors.New("measurement name required") + var ErrMeasurementNotFound = errno.NewError(errno.ErrMeasurementNotFound) + var ErrMeasurementsNotFound = errno.NewError(errno.ErrMeasurementsNotFound) + var ErrMismatchedHashAndPwd = errors.New("hashedPassword is not the hash of the given password") + var ErrNodeExists = errors.New("node already exists") + var ErrNodeIDRequired = errors.New("node id must be greater than 0") + var ErrNodeNotFound = errors.New("node not found") + var ErrNodeUnableToDropFinalNode = errors.New("unable to drop the final node in a cluster") + var ErrNodesRequired = errors.New("at least one node required") + var ErrPwdUsed = errors.New("the password is the same as the old one, please enter a new password") + var ErrReplicaNConflict = errors.New("retention policy replicaN conflicts with database replicaN") + var ErrReplicationFactorTooLow = errors.New("replication factor must be greater than 0") + var ErrRetentionPolicyConflict = errors.New("retention policy conflicts with an existing policy") + var ErrRetentionPolicyDefault = errors.New("retention policy is default") + var ErrRetentionPolicyDurationTooLow = fmt.Errorf("retention policy duration must be at least %s", MinRetentionPolicyDuration) + var ErrRetentionPolicyExists = errors.New("retention policy already exists") + var ErrRetentionPolicyIsBeingDelete = errors.New("retention policy is being delete") + var ErrRetentionPolicyNameExists = errors.New("retention policy name already exists") + var ErrRetentionPolicyNameRequired = errors.New("retention policy name required") + var ErrRetentionPolicyRequired = errors.New("retention policy required") + var ErrSameContinuousQueryName = errors.New("continuous query name already exists") + var ErrShardGroupExists = errors.New("shard group already exists") + var ErrShardGroupNotFound = errors.New("shard group not found") + var ErrShardKeyRequired = errors.New("shard key required") + var ErrShardNotReplicated = errors.New("shard not replicated") + var ErrStorageNodeNotReady = errors.New("storage node has not open") + var ErrStoreClosed = errors.New("raft store already closed") + var ErrStoreOpen = errors.New("store already open") + var ErrSubscriptionExists = errors.New("subscription already exists") + var ErrSubscriptionNotFound = errors.New("subscription not found") + var ErrUnsupportCommand = errors.New("unsupported command") + var ErrUnsupportedVer = errors.New("do not support the hash version") + var ErrUserDropSelf = errors.New("forbidden to delete admin user") + var ErrUserExists = errors.New("user already exists") + var ErrUserForbidden = errors.New("admin user is existed, forbidden to create new admin user") + var ErrUserLocked = errors.New("user is locked") + var ErrUserNotFound = errors.New("user not found") + var ErrUsernameRequired = errors.New("username required") + func DecodeIndexOption(pb *proto2.IndexOption) *influxql.IndexOption + func DecodeIndexRelation(pb *proto2.IndexRelation) *influxql.IndexRelation + func EncodeIndexOption(o *influxql.IndexOption) *proto2.IndexOption + func EncodeIndexRelation(indexR *influxql.IndexRelation) *proto2.IndexRelation + func ErrInvalidSubscriptionURL(url string) error + func ErrInvalidTierType(tier, minTier, maxTier uint64) error + func ErrRetentionPolicyNotFound(name string) error + func ErrShardGroupAlreadyReSharding(id uint64) error + func ErrShardingTypeNotEqual(rp, existType, inputType string) error + func GetDuration(d *int64) *time.Duration + func GetInt64Duration(duration *time.Duration) *int64 + func GetNodeDBPts(pi DBPtInfos, nodeId uint64) []uint32 + func HashID(key []byte) uint64 + func IsNodeReader(role string) bool + func IsNodeWriter(role string) bool + func LoadDurationOrDefault(duration *time.Duration, existDuration *time.Duration) *time.Duration + func MarshalObsOptions(cro *obs.ObsOptions) *proto2.ObsOptions + func MarshalTime(t time.Time) int64 + func NewSchemaInfo(tags, fields map[string]int32) []*proto2.FieldSchema + func StringToTier(tier string) uint64 + func TierToString(tier uint64) string + func TransSplitChar(splitChar string) string + func UnmarshalObsOptions(pb *proto2.ObsOptions) *obs.ObsOptions + func UnmarshalTime(v int64) time.Time + func ValidMeasurementName(name string) bool + func ValidName(name string) bool + func ValidShardKey(shardKeys []string) error + type CardinalityInfo struct + Cardinality uint64 + TimeRange TimeRangeInfo + type CardinalityInfos []CardinalityInfo + func (cis *CardinalityInfos) Len() int + func (cis *CardinalityInfos) Less(i, j int) bool + func (cis *CardinalityInfos) SortAndMerge() + func (cis *CardinalityInfos) Swap(i, j int) + type CardinalityResponse struct + CardinalityInfos []MeasurementCardinalityInfo + Err error + func (r *CardinalityResponse) Error() error + func (r *CardinalityResponse) MarshalBinary() ([]byte, error) + func (r *CardinalityResponse) UnmarshalBinary(buf []byte) error + type ColStoreInfo struct + CompactionType config.CompactionType + PrimaryKey []string + PropertyKey []string + PropertyValue []string + SortKey []string + TimeClusterDuration time.Duration + func NewColStoreInfo(PrimaryKey []string, SortKey []string, Property [][]string, ...) *ColStoreInfo + func (h *ColStoreInfo) IsBlockCompact() bool + func (h *ColStoreInfo) Marshal() *proto2.ColStoreInfo + func (h *ColStoreInfo) Unmarshal(pb *proto2.ColStoreInfo) + type ContinuousQueryInfo struct + LastRunTime time.Time + Name string + Query string + func (cqi *ContinuousQueryInfo) Marshal() *proto2.ContinuousQueryInfo + func (cqi *ContinuousQueryInfo) UpdateContinuousQueryStat(lastRun int64) + func (cqi ContinuousQueryInfo) Clone() *ContinuousQueryInfo + type DBPtInfos []PtInfo + type Data struct + AdminUserExists bool + BalancerEnabled bool + ClusterID uint64 + ClusterPtNum uint32 + DataNodes []DataNode + Databases map[string]*DatabaseInfo + ExpandShardsEnable bool + Index uint64 + MaxCQChangeID uint64 + MaxConnID uint64 + MaxDownSampleID uint64 + MaxEventOpId uint64 + MaxIndexGroupID uint64 + MaxIndexID uint64 + MaxNodeID uint64 + MaxShardGroupID uint64 + MaxShardID uint64 + MaxStreamID uint64 + MaxSubscriptionID uint64 + MetaNodes []NodeInfo + MigrateEvents map[string]*MigrateEventInfo + PtNumPerNode uint32 + PtView map[string]DBPtInfos + QueryIDInit map[SQLHost]uint64 + ReplicaGroups map[string][]ReplicaGroup + Streams map[string]*StreamInfo + TakeOverEnabled bool + Term uint64 + Users []UserInfo + func (data *Data) AdminUserExist() bool + func (data *Data) AlterShardKey(database string, rpName string, mst string, shardKey *proto2.ShardKeyInfo) error + func (data *Data) BatchUpdateContinuousQueryStat(cqStates []*proto2.CQState) error + func (data *Data) CheckCanCreateDatabase(name string) error + func (data *Data) CheckCanCreateRetentionPolicy(dbi *DatabaseInfo, rpi *RetentionPolicyInfo, makeDefault bool) error + func (data *Data) CheckCanMoveDb(db string) error + func (data *Data) CheckDataNodeAlive(nodeId uint64) error + func (data *Data) CheckStreamExistInDatabase(database string) error + func (data *Data) CheckStreamExistInMst(database, rp, mst string) error + func (data *Data) CheckStreamExistInRetention(database, rp string) error + func (data *Data) Clone() *Data + func (data *Data) CloneDBPtView() map[string]DBPtInfos + func (data *Data) CloneDataNodes() []DataNode + func (data *Data) CloneDatabases() map[string]*DatabaseInfo + func (data *Data) CloneMetaNodes() []NodeInfo + func (data *Data) CloneMigrateEvents() map[string]*MigrateEventInfo + func (data *Data) CloneQueryIDInit() map[SQLHost]uint64 + func (data *Data) CloneStreams() map[string]*StreamInfo + func (data *Data) CloneUsers() []UserInfo + func (data *Data) ClusterChangeState(nodeID uint64, newState serf.MemberStatus) bool + func (data *Data) CreateContinuousQuery(dbName, cqName, cqQuery string) error + func (data *Data) CreateDBPtView(name string) error + func (data *Data) CreateDataNode(host, tcpHost, role string) (error, uint64) + func (data *Data) CreateDatabase(dbName string, rpi *RetentionPolicyInfo, shardKey *proto2.ShardKeyInfo, ...) error + func (data *Data) CreateDownSamplePolicy(database, rpName string, info *DownSamplePolicyInfo) error + func (data *Data) CreateIndexGroup(rpi *RetentionPolicyInfo, timestamp time.Time, engineType config.EngineType, ...) *IndexGroupInfo + func (data *Data) CreateMeasurement(database string, rpName string, mst string, shardKey *proto2.ShardKeyInfo, ...) error + func (data *Data) CreateMetaNode(httpAddr, rpcAddr, tcpAddr string) error + func (data *Data) CreateMigrateEvent(e *proto2.MigrateEventInfo) error + func (data *Data) CreateReplication(db string, replicaN uint32) error + func (data *Data) CreateRetentionPolicy(dbName string, rpi *RetentionPolicyInfo, makeDefault bool) error + func (data *Data) CreateShardGroup(database, policy string, timestamp time.Time, tier uint64, ...) error + func (data *Data) CreateShardGroupWithBounds(db string, rp *RetentionPolicyInfo, startTime time.Time, bounds []string, ...) error + func (data *Data) CreateStream(info *StreamInfo) error + func (data *Data) CreateSubscription(database, rp, name, mode string, destinations []string) error + func (data *Data) CreateUser(name, hash string, admin, rwuser bool) error + func (data *Data) DBPtView(name string) DBPtInfos + func (data *Data) DBRepGroups(name string) []ReplicaGroup + func (data *Data) DBReplicaN(db string) int + func (data *Data) DataNode(id uint64) *DataNode + func (data *Data) DataNodeByHttpHost(httpAddr string) *DataNode + func (data *Data) DataNodeByIp(nodeIp string) *DataNode + func (data *Data) DataNodeIDs() []int + func (data *Data) Database(name string) *DatabaseInfo + func (data *Data) DeleteDataNode(id uint64) error + func (data *Data) DeleteIndexGroup(database, policy string, id uint64) error + func (data *Data) DeleteMetaNode(id uint64) error + func (data *Data) DeleteShardGroup(database, policy string, id uint64) error + func (data *Data) DropContinuousQuery(cqName string, database string) (bool, error) + func (data *Data) DropDatabase(name string) + func (data *Data) DropDownSamplePolicy(database, rpName string, dropAll bool) + func (data *Data) DropMeasurement(database, policy, nameWithVer string) error + func (data *Data) DropRetentionPolicy(database, name string) error + func (data *Data) DropShard(id uint64) + func (data *Data) DropStream(name string) error + func (data *Data) DropSubscription(database, rp, name string) error + func (data *Data) DropUser(name string) error + func (data *Data) DurationInfos(dbPtIds map[string][]uint32) *ShardDurationResponse + func (data *Data) ExpandGroups() + func (data *Data) GetAliveDataNodeNum() int + func (data *Data) GetAliveWriteNode() []DataNode + func (data *Data) GetAllNodeSegregateStatus() []uint64 + func (data *Data) GetClusterPtNum() uint32 + func (data *Data) GetDBBriefInfo(name string) *DatabaseBriefInfo + func (data *Data) GetDatabase(name string) (*DatabaseInfo, error) + func (data *Data) GetDbPtOwners(database string, ptIds []uint32) []uint64 + func (data *Data) GetEffectivePtNum(db string) uint32 + func (data *Data) GetFailedPtInfos(id uint64, status PtStatus) []*DbPtInfo + func (data *Data) GetNodeIDs() []uint64 + func (data *Data) GetNodeIdsByNodeLst(nodeLst []string) ([]uint64, []string, error) + func (data *Data) GetNodeIndex(nodeId uint64) (uint64, error) + func (data *Data) GetNodeSegregateStatus(nodeIds []uint64) ([]uint64, error) + func (data *Data) GetPtInfo(name string, ptID uint32) *PtInfo + func (data *Data) GetPtInfosByDbname(name string, enableTagArray bool) ([]*DbPtInfo, error) + func (data *Data) GetPtInfosByNodeId(id uint64) []*DbPtInfo + func (data *Data) GetReplicaGroup(db string, groupID uint32) *ReplicaGroup + func (data *Data) GetSegregateStatusByNodeId(nodeId uint64) uint64 + func (data *Data) GetShardDurationsByDbPt(db string, pt uint32) map[uint64]*ShardDurationInfo + func (data *Data) GetTierOfShardGroup(database, policy string, timestamp time.Time, defaultTier uint64, ...) (*ShardGroupInfo, uint64, error) + func (data *Data) GetUser(username string) *UserInfo + func (data *Data) GetWriteNode() []DataNode + func (data *Data) GetWriteNodeNum() uint32 + func (data *Data) HasAdminUser() bool + func (data *Data) ImportData(other Data, backupDBName, restoreDBName, backupRPName, restoreRPName string) (map[uint64]uint64, []string, error) + func (data *Data) MarkBalancer(enable bool) + func (data *Data) MarkDatabaseDelete(name string) error + func (data *Data) MarkMeasurementDelete(database, policy, measurement string) error + func (data *Data) MarkRetentionPolicyDelete(database, name string) error + func (data *Data) MarkTakeover(enable bool) + func (data *Data) Marshal() *proto2.Data + func (data *Data) MarshalBinary() ([]byte, error) + func (data *Data) MarshalBinaryUser() ([]byte, error) + func (data *Data) MarshalUsers() *proto2.Data + func (data *Data) Measurement(database, retentionPolicy, mst string) (*MeasurementInfo, error) + func (data *Data) Measurements(database, retentionPolicy string) (*MeasurementsInfo, error) + func (data *Data) NewestShardGroup(database, retentionPolicy string) (sg *ShardGroupInfo) + func (data *Data) PruneGroups(shardGroup bool, id uint64) error + func (data *Data) ReSharding(info *ReShardingInfo) error + func (data *Data) RegisterQueryIDOffset(host SQLHost) error + func (data *Data) RemoveEventInfo(eventId string) error + func (data *Data) RemoveNode(nodeIds []uint64) + func (data *Data) RetentionPolicy(database, name string) (*RetentionPolicyInfo, error) + func (data *Data) SetAdminPrivilege(name string, admin bool) error + func (data *Data) SetClusterPtNum(ptNum uint32) + func (data *Data) SetDataNode(nodeID uint64, host, tcpHost string) error + func (data *Data) SetDatabase(dbi *DatabaseInfo) error + func (data *Data) SetDefaultRetentionPolicy(database, name string) error + func (data *Data) SetMetaNode(httpAddr, rpcAddr, tcpAddr string) error + func (data *Data) SetPrivilege(name, database string, p originql.Privilege) error + func (data *Data) SetRetentionPolicy(dbi *DatabaseInfo, rpi *RetentionPolicyInfo, makeDefault bool) + func (data *Data) SetSegregateNodeStatus(status []uint64, nodeIds []uint64) + func (data *Data) SetStream(info *StreamInfo) error + func (data *Data) ShardGroupByTimestampAndEngineType(database, policy string, timestamp time.Time, engineType config.EngineType) (*ShardGroupInfo, error) + func (data *Data) ShardGroups(database, policy string) ([]ShardGroupInfo, error) + func (data *Data) ShardGroupsByTimeRange(database, policy string, tmin, tmax time.Time) ([]ShardGroupInfo, error) + func (data *Data) ShowCluster() models.Rows + func (data *Data) ShowClusterWithCondition(nodeType string, ID uint64) (models.Rows, error) + func (data *Data) ShowContinuousQueries() (models.Rows, error) + func (data *Data) ShowDownSamplePolicies(database string) (models.Rows, error) + func (data *Data) ShowRetentionPolicies(database string) (models.Rows, error) + func (data *Data) ShowShardGroups() models.Rows + func (data *Data) ShowShards() models.Rows + func (data *Data) ShowStreams(database string, showAll bool) (models.Rows, error) + func (data *Data) ShowSubscriptions() models.Rows + func (data *Data) Unmarshal(pb *proto2.Data) + func (data *Data) UnmarshalBinary(buf []byte) error + func (data *Data) UpdateMeasurement(db, rp, mst string, options *proto2.Options) error + func (data *Data) UpdateMigrateEvent(e *proto2.MigrateEventInfo) error + func (data *Data) UpdateNodeStatus(id uint64, status int32, lTime uint64, gossipPort string) error + func (data *Data) UpdatePtInfo(db string, info *proto2.PtInfo, ownerId uint64, status uint32) error + func (data *Data) UpdatePtVersion(db string, ptId uint32) error + func (data *Data) UpdateReplication(database string, rgId, masterId uint32, peers []*proto2.Peer, status uint32) error + func (data *Data) UpdateRetentionPolicy(database, name string, rpu *RetentionPolicyUpdate, makeDefault bool) error + func (data *Data) UpdateSchema(database string, retentionPolicy string, mst string, ...) error + func (data *Data) UpdateShardDownSampleInfo(ident *ShardIdentifier) error + func (data *Data) UpdateShardInfoTier(shardID uint64, shardTier uint64, dbName, rpName string) error + func (data *Data) UpdateUser(name, hash string) error + func (data *Data) User(username string) User + func (data *Data) UserPrivilege(name, database string) (*originql.Privilege, error) + func (data *Data) UserPrivileges(name string) (map[string]originql.Privilege, error) + func (data *Data) WalkDataNodes(fn func(node *DataNode)) + func (data *Data) WalkDatabases(fn func(db *DatabaseInfo)) + func (data *Data) WalkDatabasesOrderly(fn func(db *DatabaseInfo)) + func (data *Data) WalkMetaNodes(fn func(node *NodeInfo)) + type DataNode struct + AliveConnID uint64 + ConnID uint64 + func (n *DataNode) MarshalBinary() ([]byte, error) + func (n *DataNode) UnmarshalBinary(buf []byte) error + type DataNodeInfos []DataNode + func (n DataNodeInfos) Len() int + func (n DataNodeInfos) Less(i, j int) bool + func (n DataNodeInfos) Swap(i, j int) + type DatabaseBriefInfo struct + EnableTagArray bool + Name string + func (di *DatabaseBriefInfo) Marshal() ([]byte, error) + type DatabaseInfo struct + ContinuousQueries map[string]*ContinuousQueryInfo + DefaultRetentionPolicy string + EnableTagArray bool + MarkDeleted bool + Name string + Options *obs.ObsOptions + ReplicaN int + RetentionPolicies map[string]*RetentionPolicyInfo + ShardKey ShardKeyInfo + func NewDatabase(name string) *DatabaseInfo + func (di *DatabaseInfo) GetRetentionPolicy(name string) (*RetentionPolicyInfo, error) + func (di *DatabaseInfo) RetentionPolicy(name string) *RetentionPolicyInfo + func (di *DatabaseInfo) WalkContinuousQuery(fn func(cq *ContinuousQueryInfo)) + func (di *DatabaseInfo) WalkRetentionPolicy(fn func(rp *RetentionPolicyInfo)) + func (di *DatabaseInfo) WalkRetentionPolicyOrderly(fn func(rp *RetentionPolicyInfo)) + func (di DatabaseInfo) ShardInfos() []ShardInfo + type DbPtInfo struct + DBBriefInfo *DatabaseBriefInfo + Db string + Pti *PtInfo + Shards map[uint64]*ShardDurationInfo + func (pt *DbPtInfo) Marshal() *proto2.DbPt + func (pt *DbPtInfo) String() string + func (pt *DbPtInfo) Unmarshal(pb *proto2.DbPt) + type DownSampleOperators struct + AggOps []string + DataType int64 + func NewDownSampleOperators(c *influxql.Call) (*DownSampleOperators, error) + func (d *DownSampleOperators) Equal(op *DownSampleOperators) bool + func (d *DownSampleOperators) RewriteOp() []string + func (d *DownSampleOperators) String() string + type DownSamplePoliciesInfoWithDbRp struct + Infos []*DownSamplePolicyInfoWithDbRp + func (d *DownSamplePoliciesInfoWithDbRp) Marshal() *proto2.DownSamplePoliciesInfoWithDbRp + func (d *DownSamplePoliciesInfoWithDbRp) MarshalBinary() ([]byte, error) + func (d *DownSamplePoliciesInfoWithDbRp) Unmarshal(pb *proto2.DownSamplePoliciesInfoWithDbRp) + func (d *DownSamplePoliciesInfoWithDbRp) UnmarshalBinary(buf []byte) error + type DownSamplePolicy struct + SampleInterval time.Duration + TimeInterval time.Duration + WaterMark time.Duration + func NewDownSamplePolicy(sampleInterval time.Duration, timeInterval time.Duration) *DownSamplePolicy + func (d *DownSamplePolicy) Equal(dp *DownSamplePolicy) bool + type DownSamplePolicyInfo struct + Calls []*DownSampleOperators + DownSamplePolicies []*DownSamplePolicy + Duration time.Duration + TaskID uint64 + func NewDownSamplePolicyInfo(Ops influxql.Fields, duration time.Duration, sampleIntervals []time.Duration, ...) (*DownSamplePolicyInfo, error) + func (d *DownSamplePolicyInfo) Calls2String() string + func (d *DownSamplePolicyInfo) Check(rpi *RetentionPolicyInfo) error + func (d *DownSamplePolicyInfo) Equal(info *DownSamplePolicyInfo, checkID bool) bool + func (d *DownSamplePolicyInfo) GetCalls() map[int64][]string + func (d *DownSamplePolicyInfo) GetTypes() []int64 + func (d *DownSamplePolicyInfo) IsNil() bool + func (d *DownSamplePolicyInfo) Marshal() *proto2.DownSamplePolicyInfo + func (d *DownSamplePolicyInfo) MarshalBinary() ([]byte, error) + func (d *DownSamplePolicyInfo) SampleInterval2String() string + func (d *DownSamplePolicyInfo) TimeInterval2String() string + func (d *DownSamplePolicyInfo) Unmarshal(pb *proto2.DownSamplePolicyInfo) + func (d *DownSamplePolicyInfo) UnmarshalBinary(buf []byte) error + func (d *DownSamplePolicyInfo) WaterMark2String() string + type DownSamplePolicyInfoWithDbRp struct + DbName string + Info *DownSamplePolicyInfo + RpName string + func (d *DownSamplePolicyInfoWithDbRp) Marshal() *proto2.DownSamplePolicyInfoWithDbRp + func (d *DownSamplePolicyInfoWithDbRp) Unmarshal(pb *proto2.DownSamplePolicyInfoWithDbRp) + type DurationDescriptor struct + Duration time.Duration + Tier uint64 + TierDuration time.Duration + type ErrAuthorize struct + Database string + Message string + Query *influxql.Query + User string + func (e ErrAuthorize) Error() string + type IndexDescriptor struct + IndexGroupID uint64 + IndexID uint64 + TimeRange TimeRangeInfo + type IndexGroupInfo struct + DeletedAt time.Time + EndTime time.Time + EngineType config.EngineType + ID uint64 + Indexes []IndexInfo + StartTime time.Time + func (igi *IndexGroupInfo) Contains(t time.Time) bool + func (igi *IndexGroupInfo) Deleted() bool + func (igi *IndexGroupInfo) Overlaps(min, max time.Time) bool + type IndexGroupInfos []IndexGroupInfo + func (igs IndexGroupInfos) Len() int + func (igs IndexGroupInfos) Less(i, j int) bool + func (igs IndexGroupInfos) Swap(i, j int) + type IndexIdentifier struct + Index *IndexDescriptor + OwnerDb string + OwnerPt uint32 + Policy string + type IndexInfo struct + ID uint64 + MarkDelete bool + Owners []uint32 + func (ii *IndexInfo) UnmarshalBinary(buf []byte) error + type MeasurementCardinalityInfo struct + CardinalityInfos []CardinalityInfo + Name string + type MeasurementFieldsInfo struct + MstName string + TypeFields []*MeasurementTypeFields + func (m *MeasurementFieldsInfo) Marshal() *proto2.MeasurementFieldsInfo + func (m *MeasurementFieldsInfo) Unmarshal(pb *proto2.MeasurementFieldsInfo) + type MeasurementInfo struct + ColStoreInfo *ColStoreInfo + EngineType config.EngineType + IndexRelation influxql.IndexRelation + MarkDeleted bool + Name string + ObsOptions *obs.ObsOptions + Options *Options + Schema map[string]int32 + ShardKeys []ShardKeyInfo + func NewMeasurementInfo(nameWithVer string) *MeasurementInfo + func (msti *MeasurementInfo) CompatibleForLogkeeper() + func (msti *MeasurementInfo) CompatibleForLogkeeperColstore() + func (msti *MeasurementInfo) CompatibleForLogkeeperRowstore() + func (msti *MeasurementInfo) ContainIndexRelation(ID uint64) bool + func (msti *MeasurementInfo) FindMstInfos(dataTypes []int64) []*MeasurementTypeFields + func (msti *MeasurementInfo) GetIndexRelation() influxql.IndexRelation + func (msti *MeasurementInfo) GetShardKey(ID uint64) *ShardKeyInfo + func (msti *MeasurementInfo) IsBlockCompact() bool + func (msti *MeasurementInfo) IsDetachedWrite() bool + func (msti *MeasurementInfo) IsTimeSorted() bool + func (msti *MeasurementInfo) MarshalBinary() ([]byte, error) + func (msti *MeasurementInfo) OriginName() string + func (msti *MeasurementInfo) SetoriginName(originName string) + func (msti *MeasurementInfo) TagKeysTotal() int + func (msti *MeasurementInfo) UnmarshalBinary(buf []byte) error + func (msti MeasurementInfo) FieldKeys(ret map[string]map[string]int32) + func (msti MeasurementInfo) MatchTagKeys(cond influxql.Expr, ret map[string]map[string]struct{}) + type MeasurementTypeFields struct + Fields []string + Type int64 + type MeasurementVer struct + NameWithVersion string + Version uint32 + type MeasurementsInfo struct + MstsInfo []*MeasurementInfo + func (mstsi *MeasurementsInfo) MarshalBinary() ([]byte, error) + func (mstsi *MeasurementsInfo) UnmarshalBinary(buf []byte) error + type MigrateEventInfo struct + func NewMigrateEventInfo(eventId string, eventType int, pt *DbPtInfo, dest uint64, aliveConnId uint64) *MigrateEventInfo + func (m *MigrateEventInfo) Clone() *MigrateEventInfo + func (m *MigrateEventInfo) GetAliveConnId() uint64 + func (m *MigrateEventInfo) GetCurrentState() int + func (m *MigrateEventInfo) GetDst() uint64 + func (m *MigrateEventInfo) GetEventType() int + func (m *MigrateEventInfo) GetOpId() uint64 + func (m *MigrateEventInfo) GetPreState() int + func (m *MigrateEventInfo) GetPtInfo() *DbPtInfo + func (m *MigrateEventInfo) GetSrc() uint64 + func (m *MigrateEventInfo) SetCurrentState(state int) + func (m *MigrateEventInfo) SetDest(dst uint64) + func (m *MigrateEventInfo) SetPreState(state int) + func (m *MigrateEventInfo) SetSrc(src uint64) + type NodeInfo struct + GossipAddr string + Host string + ID uint64 + LTime uint64 + RPCAddr string + Role string + SegregateStatus uint64 + Status serf.MemberStatus + TCPHost string + type NodeInfos []NodeInfo + func (n NodeInfos) Len() int + func (n NodeInfos) Less(i, j int) bool + func (n NodeInfos) Swap(i, j int) + type NodeStartInfo struct + ConnId uint64 + DBBriefInfo map[string]*DatabaseBriefInfo + DataIndex uint64 + LTime uint64 + NodeId uint64 + PtIds []uint32 + ShardDurationInfos map[uint64]*ShardDurationInfo + func (nsi *NodeStartInfo) UnMarshalBinary(buf []byte) error + func (nsi NodeStartInfo) MarshalBinary() ([]byte, error) + type NodeStatus int64 + const StatusAlive + const StatusFailed + const StatusLeaving + const StatusLeft + const StatusNone + const StatusRestart + type Options struct + AppendMeta bool + CaseInSensitive bool + ReadThreshold int + SplitChar string + StorageCapacity int + TagsSplit string + Ttl int64 + WriteThreshold int + func (mo *Options) GetSplitChar() string + func (mo *Options) GetTagSplitChar() string + func (mo *Options) InitDefault() + func (mo *Options) Marshal() *proto2.Options + func (mo *Options) Unmarshal(pb *proto2.Options) + type Peer struct + ID uint32 + PtRole Role + type PtInfo struct + Owner PtOwner + PtId uint32 + RGID uint32 + Status PtStatus + Ver uint64 + func (pi *PtInfo) Marshal() *proto2.PtInfo + type PtOwner struct + NodeID uint64 + type PtStatus uint32 + const Disabled + const Offline + const Online + const PrepareAssign + const PrepareOffload + const RollbackPrepareAssign + const RollbackPrepareOffload + type RGStatus uint8 + const Health + const SubHealth + type ReShardingInfo struct + Bounds []string + Database string + Rp string + ShardGroupID uint64 + SplitTime int64 + type ReplicaGroup struct + ID uint32 + MasterPtID uint32 + Peers []Peer + Status RGStatus + Term uint64 + func (rg *ReplicaGroup) GetPtRole(ptID uint32) Role + func (rg *ReplicaGroup) IsMasterPt(ptID uint32) bool + type RetentionPolicyInfo struct + DownSamplePolicyInfo *DownSamplePolicyInfo + Duration time.Duration + HotDuration time.Duration + IndexGroupDuration time.Duration + IndexGroups []IndexGroupInfo + MarkDeleted bool + Measurements map[string]*MeasurementInfo + MstVersions map[string]MeasurementVer + Name string + ReplicaN int + ShardGroupDuration time.Duration + ShardGroups []ShardGroupInfo + Subscriptions []SubscriptionInfo + WarmDuration time.Duration + func DefaultRetentionPolicyInfo() *RetentionPolicyInfo + func NewRetentionPolicyInfo(name string) *RetentionPolicyInfo + func (rpi *RetentionPolicyInfo) Apply(spec *RetentionPolicySpec) *RetentionPolicyInfo + func (rpi *RetentionPolicyInfo) CheckSpecValid() error + func (rpi *RetentionPolicyInfo) DeletedShardGroups() []*ShardGroupInfo + func (rpi *RetentionPolicyInfo) EachMeasurements(fn func(m *MeasurementInfo)) + func (rpi *RetentionPolicyInfo) EqualsAnotherRp(other *RetentionPolicyInfo) bool + func (rpi *RetentionPolicyInfo) ExpiredShardGroups(t time.Time) []*ShardGroupInfo + func (rpi *RetentionPolicyInfo) GetMeasurement(name string) (*MeasurementInfo, error) + func (rpi *RetentionPolicyInfo) HasDownSamplePolicy() bool + func (rpi *RetentionPolicyInfo) Marshal() *proto2.RetentionPolicyInfo + func (rpi *RetentionPolicyInfo) MarshalBinary() ([]byte, error) + func (rpi *RetentionPolicyInfo) MatchMeasurements(ms influxql.Measurements, ret map[string]*MeasurementInfo) + func (rpi *RetentionPolicyInfo) Measurement(name string) *MeasurementInfo + func (rpi *RetentionPolicyInfo) ShardGroupByTimestampAndEngineType(timestamp time.Time, engineType config.EngineType) *ShardGroupInfo + func (rpi *RetentionPolicyInfo) ShardGroupsByTimeRange(tmin, tmax time.Time) []*ShardGroupInfo + func (rpi *RetentionPolicyInfo) TierDuration(tier uint64) time.Duration + func (rpi *RetentionPolicyInfo) TimeRangeInfo(shardID uint64) *ShardTimeRangeInfo + func (rpi *RetentionPolicyInfo) UnmarshalBinary(data []byte) error + func (rpi *RetentionPolicyInfo) WalkShardGroups(fn func(sg *ShardGroupInfo)) + func (rpi RetentionPolicyInfo) Clone() *RetentionPolicyInfo + type RetentionPolicySpec struct + Duration *time.Duration + HotDuration *time.Duration + IndexGroupDuration time.Duration + Name string + ReplicaN *int + ShardGroupDuration time.Duration + WarmDuration *time.Duration + func (s *RetentionPolicySpec) MarshalBinary() ([]byte, error) + func (s *RetentionPolicySpec) Matches(rpi *RetentionPolicyInfo) bool + func (s *RetentionPolicySpec) NewRetentionPolicyInfo() *RetentionPolicyInfo + func (s *RetentionPolicySpec) UnmarshalBinary(data []byte) error + type RetentionPolicyUpdate struct + Duration *time.Duration + HotDuration *time.Duration + IndexGroupDuration *time.Duration + Name *string + ReplicaN *int + ShardGroupDuration *time.Duration + WarmDuration *time.Duration + func (rpu *RetentionPolicyUpdate) SetDuration(v time.Duration) + func (rpu *RetentionPolicyUpdate) SetName(v string) + func (rpu *RetentionPolicyUpdate) SetReplicaN(v int) + func (rpu *RetentionPolicyUpdate) SetShardGroupDuration(v time.Duration) + func (rpu *RetentionPolicyUpdate) SetWarmDuration(v time.Duration) + type Role uint8 + const Catcher + const Master + const Slave + type RpMeasurementsFieldsInfo struct + MeasurementInfos []*MeasurementFieldsInfo + func (r *RpMeasurementsFieldsInfo) Marshal() *proto2.RpMeasurementsFieldsInfo + func (r *RpMeasurementsFieldsInfo) MarshalBinary() ([]byte, error) + func (r *RpMeasurementsFieldsInfo) Unmarshal(pb *proto2.RpMeasurementsFieldsInfo) + func (r *RpMeasurementsFieldsInfo) UnmarshalBinary(buf []byte) error + type SQLHost string + type ShardDownSamplePolicyInfo struct + DbName string + DownSamplePolicyLevel int + Ident *ShardIdentifier + PtId uint32 + RpName string + ShardId uint64 + TaskID uint64 + type ShardDownSampleUpdateInfo struct + DownSampleLvl int + Ident *ShardIdentifier + func NewShardDownSampleUpdateInfo(ident *ShardIdentifier, downSampleLvl int) *ShardDownSampleUpdateInfo + type ShardDownSampleUpdateInfos struct + Infos []*ShardDownSampleUpdateInfo + func (s *ShardDownSampleUpdateInfos) Marshal() *proto2.ShardDownSampleUpdateInfos + func (s *ShardDownSampleUpdateInfos) MarshalBinary() ([]byte, error) + func (s *ShardDownSampleUpdateInfos) Unmarshal(pb *proto2.ShardDownSampleUpdateInfos) + func (s *ShardDownSampleUpdateInfos) UnmarshalBinary(buf []byte) error + type ShardDurationInfo struct + DurationInfo DurationDescriptor + Ident ShardIdentifier + func (d *ShardDurationInfo) MarshalBinary() ([]byte, error) + func (d *ShardDurationInfo) UnmarshalBinary(buf []byte) error + type ShardDurationResponse struct + DataIndex uint64 + Durations []ShardDurationInfo + func (r *ShardDurationResponse) MarshalBinary() ([]byte, error) + func (r *ShardDurationResponse) UnmarshalBinary(buf []byte) error + type ShardGroupInfo struct + DeletedAt time.Time + EndTime time.Time + EngineType config.EngineType + ID uint64 + Shards []ShardInfo + StartTime time.Time + TruncatedAt time.Time + Version uint32 + func (sgi *ShardGroupInfo) Contains(t time.Time) bool + func (sgi *ShardGroupInfo) Deleted() bool + func (sgi *ShardGroupInfo) DestShard(shardKey string) *ShardInfo + func (sgi *ShardGroupInfo) Overlaps(min, max time.Time) bool + func (sgi *ShardGroupInfo) Shard(id uint64) *ShardInfo + func (sgi *ShardGroupInfo) ShardFor(hash uint64, aliveShardIdxes []int) *ShardInfo + func (sgi *ShardGroupInfo) Truncated() bool + func (sgi ShardGroupInfo) EachShards(fn func(s *ShardInfo)) + func (sgi ShardGroupInfo) TargetShards(mst *MeasurementInfo, ski *ShardKeyInfo, condition influxql.Expr, ...) []ShardInfo + func (sgi ShardGroupInfo) TargetShardsHintQuery(mst *MeasurementInfo, ski *ShardKeyInfo, condition influxql.Expr, ...) ([]ShardInfo, []byte) + type ShardGroupInfos []ShardGroupInfo + func (a ShardGroupInfos) Len() int + func (a ShardGroupInfos) Less(i, j int) bool + func (a ShardGroupInfos) Swap(i, j int) + type ShardIdentifier struct + DownSampleID uint64 + DownSampleLevel int + EngineType uint32 + OwnerDb string + OwnerPt uint32 + Policy string + ReadOnly bool + ShardGroupID uint64 + ShardID uint64 + ShardType string + func (i *ShardIdentifier) Marshal() *proto2.ShardIdentifier + func (i *ShardIdentifier) Unmarshal(ident *proto2.ShardIdentifier) + type ShardInfo struct + DownSampleID uint64 + DownSampleLevel int64 + ID uint64 + IndexID uint64 + MarkDelete bool + Max string + Min string + Owners []uint32 + ReadOnly bool + Tier uint64 + func (si *ShardInfo) UnmarshalBinary(buf []byte) error + func (si ShardInfo) Contain(shardKey string) bool + func (si ShardInfo) ContainPrefix(prefix string) bool + type ShardKeyInfo struct + ShardGroup uint64 + ShardKey []string + Type string + func (ski *ShardKeyInfo) EqualsToAnother(other *ShardKeyInfo) bool + func (ski *ShardKeyInfo) Marshal() *proto2.ShardKeyInfo + type ShardOwner struct + NodeID uint64 + type ShardTimeRangeInfo struct + OwnerIndex IndexDescriptor + ShardDuration *ShardDurationInfo + ShardType string + TimeRange TimeRangeInfo + func (t *ShardTimeRangeInfo) MarshalBinary() ([]byte, error) + func (t *ShardTimeRangeInfo) UnmarshalBinary(buf []byte) error + type StoreDownSamplePolicy struct + Alive bool + Info *DownSamplePolicyInfo + Schemas [][]hybridqp.Catalog + type StreamCall struct + Alias string + Call string + Field string + func (c *StreamCall) String() string + func (c StreamCall) Clone() *StreamCall + type StreamInfo struct + Calls []*StreamCall + Delay time.Duration + DesMst *StreamMeasurementInfo + Dims []string + ID uint64 + Interval time.Duration + Name string + SrcMst *StreamMeasurementInfo + func NewStreamInfo(stmt *influxql.CreateStreamStatement, selectStmt *influxql.SelectStatement) *StreamInfo + func (s *StreamInfo) CallsName() string + func (s *StreamInfo) Dimensions() string + func (s *StreamInfo) Equal(d *StreamInfo) bool + func (s *StreamInfo) Marshal() *proto2.StreamInfo + func (s *StreamInfo) Unmarshal(pb *proto2.StreamInfo) + type StreamInfos []*StreamInfo + type StreamMeasurementInfo struct + Database string + Name string + RetentionPolicy string + func (m *StreamMeasurementInfo) Equal(s *StreamMeasurementInfo) bool + func (m StreamMeasurementInfo) Clone() *StreamMeasurementInfo + type SubscriptionInfo struct + Destinations []string + Mode string + Name string + type TimeRangeInfo struct + EndTime time.Time + StartTime time.Time + type User interface + AuthorizeDatabase func(p originql.Privilege, name string) bool + AuthorizeQuery func(database string, query *influxql.Query) error + AuthorizeUnrestricted func() bool + ID func() string + type UserInfo struct + Admin bool + Hash string + Name string + Privileges map[string]originql.Privilege + Rwuser bool + func (u *UserInfo) AuthorizeDatabase(privilege originql.Privilege, database string) bool + func (u *UserInfo) AuthorizeQuery(database string, query *influxql.Query) error + func (u *UserInfo) AuthorizeQueryForRwUser(database string, query *influxql.Query) error + func (u *UserInfo) AuthorizeSeriesRead(database string, measurement []byte, tags models.Tags) bool + func (u *UserInfo) AuthorizeSeriesWrite(database string, measurement []byte, tags models.Tags) bool + func (u *UserInfo) AuthorizeUnrestricted() bool + func (u *UserInfo) ID() string + func (u *UserInfo) IsOpen() bool