netstorage

type BaseMessage struct {
	Typ  uint8
	Data codec.BinaryCodec
}

type ColumnKeys struct {
	Name string
	Keys []metaclient.FieldKey
}

type CreateDataBaseRequest struct {
	internal2.CreateDataBaseRequest
}

type CreateDataBaseResponse struct {
	internal2.CreateDataBaseResponse
}

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

type DDLMessage struct {
	BaseMessage
}

type DeleteRequest struct {
	Database    string
	Rp          string
	Measurement string
	ShardIds    []uint64
	Type        DeleteType
	PtId        uint32
}

type DeleteResponse struct {
	Err error
}

type DeleteType int

type Engine interface {
	Open(ptIds []uint32, durationInfos map[uint64]*meta.ShardDurationInfo) error
	Close() error
	ForceFlush()
	SetReadOnly(readonly bool)

	DeleteShard(db string, ptId uint32, shardID uint64) error
	DeleteIndex(db string, pt uint32, shardID uint64) error
	ExpiredShards() []*meta.ShardIdentifier
	ExpiredIndexes() []*meta.IndexIdentifier

	FetchShardsNeedChangeStore() ([]*meta.ShardIdentifier, []*meta.ShardIdentifier)
	ChangeShardTierToWarm(db string, ptId uint32, shardID uint64) error

	CreateShard(db, rp string, ptId uint32, shardID uint64, timeRangeInfo *meta.ShardTimeRangeInfo) error
	WriteRows(db, rp string, ptId uint32, shardID uint64, points []influx.Row, binaryRows []byte) error
	CreateDBPT(db string, pt uint32)

	GetShardSplitPoints(db string, ptId uint32, shardID uint64, idxes []int64) ([]string, error)

	DeleteDatabase(db string, ptId uint32) error

	DropRetentionPolicy(db string, rp string, ptId uint32) error

	DropMeasurement(db string, rp string, name string, shardIds []uint64) error

	SeriesKeys(db string, ptIDs []uint32, measurements [][]byte, condition influxql.Expr) ([]string, error)
	SeriesCardinality(db string, ptIDs []uint32, measurements [][]byte, condition influxql.Expr) ([]meta.MeasurementCardinalityInfo, error)
	SeriesExactCardinality(db string, ptIDs []uint32, measurements [][]byte, condition influxql.Expr) (map[string]uint64, error)

	TagValues(db string, ptId []uint32, tagKeys map[string][][]byte, condition influxql.Expr) (TablesTagSets, error)
	TagValuesCardinality(db string, ptIDs []uint32, tagKeys map[string][][]byte, condition influxql.Expr) (map[string]uint64, error)
	DropSeries(database string, sources []influxql.Source, ptId []uint32, condition influxql.Expr) (int, error)

	DbPTRef(db string, ptId uint32) error
	DbPTUnref(db string, ptId uint32)
	CreateLogicalPlan(ctx context.Context, db string, ptId uint32, shardID uint64, sources influxql.Sources, schema *executor.QuerySchema) (hybridqp.QueryNode, error)
	LogicalPlanCost(db string, ptId uint32, sources influxql.Sources, opt query.ProcessorOptions) (hybridqp.LogicalPlanCost, error)

	UpdateShardDurationInfo(info *meta.ShardDurationInfo) error

	SysCtrl(req *SysCtrlRequest) error
	Statistics(buffer []byte) ([]byte, error)
}

type EngineOptions struct {
	Version string
	// Limits the concurrent number of TSM files that can be loaded at once.
	OpenLimiter limiter.Fixed

	ImmTableMaxMemoryPercentage int

	// WriteColdDuration is the length of time at which the engine will snapshot the mutable
	WriteColdDuration time.Duration

	// ShardMutableSizeLimit is the maximum size a shard's cache can reach before it starts rejecting writes.
	ShardMutableSizeLimit int64

	// NodeMutableSizeLimit is the maximum size a node's cache can reach before it starts rejecting writes.
	NodeMutableSizeLimit int64

	// MaxWriteHangTime is the maximum time to hang for data write to store if node mem of mem is not enough
	MaxWriteHangTime time.Duration

	FullCompactColdDuration  time.Duration
	MaxConcurrentCompactions int
	MaxFullCompactions       int
	CompactThroughput        int64
	CompactThroughputBurst   int64
	CompactRecovery          bool
	SnapshotThroughput       int64
	SnapshotThroughputBurst  int64

	// WalSyncInterval is the interval of wal file sync
	WalEnabled        bool
	WalSyncInterval   time.Duration
	WalReplayParallel bool

	// Immutable config
	ReadCacheLimit   int
	CacheDataBlock   bool
	CacheMetaBlock   bool
	EnableMmapRead   bool
	CompactionMethod int // 0:auto, 1:stream, 2: non-stream
}

type ExactCardinalityResponse struct {
	internal2.ExactCardinalityResponse
}

type ExecuteStatementMessage struct {
	StatementType string
	Result        []byte
	Filtered      []byte
}

type GetShardSplitPointsRequest struct {
	internal2.GetShardSplitPointsRequest
}

type GetShardSplitPointsResponse struct {
	internal2.GetShardSplitPointsResponse
}

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

type NewEngineFun func(dataPath, walPath string, options EngineOptions, ctx *metaclient.LoadCtx) (Engine, error)

type PartialWriteError struct {
	Reason  error
	Dropped int

	// A sorted slice of series keys that were dropped.
	DroppedKeys [][]byte
}

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

type SeriesCardinalityRequest struct {
	SeriesKeysRequest
}

type SeriesCardinalityResponse struct {
	meta.CardinalityResponse
}

type SeriesExactCardinalityRequest struct {
	SeriesKeysRequest
}

type SeriesExactCardinalityResponse struct {
	ExactCardinalityResponse
}

type SeriesKeysRequest struct {
	internal2.SeriesKeysRequest
}

type SeriesKeysResponse struct {
	internal2.SeriesKeysResponse
}

type ShowTagValuesCardinalityRequest struct {
	ShowTagValuesRequest
}

type ShowTagValuesCardinalityResponse struct {
	ExactCardinalityResponse
}

type ShowTagValuesRequest struct {
	internal2.ShowTagValuesRequest
}

type ShowTagValuesResponse struct {
	internal2.ShowTagValuesResponse
}

type Storage interface {
	Open() error
	Close() error

	WriteRows(nodeID uint64, database string, rp string, pt uint32, shard uint64, rows *[]influx.Row, timeout time.Duration) error
	DropShard(nodeID uint64, database, rpName string, dbPts []uint32, shardID uint64) error

	TagValues(nodeID uint64, db string, ptIDs []uint32, tagKeys map[string]map[string]struct{}, cond influxql.Expr) (TablesTagSets, error)
	TagValuesCardinality(nodeID uint64, db string, ptIDs []uint32, tagKeys map[string]map[string]struct{}, cond influxql.Expr) (map[string]uint64, error)

	ShowSeries(nodeID uint64, db string, ptId []uint32, measurements []string, condition influxql.Expr) ([]string, error)
	SeriesCardinality(nodeID uint64, db string, dbPts []uint32, measurements []string, condition influxql.Expr) ([]meta2.MeasurementCardinalityInfo, error)
	SeriesExactCardinality(nodeID uint64, db string, dbPts []uint32, measurements []string, condition influxql.Expr) (map[string]uint64, error)

	SendSysCtrlOnNode(nodID uint64, req SysCtrlRequest) (map[string]string, error)

	GetShardSplitPoints(node *meta2.DataNode, database string, pt uint32,
		shardId uint64, idxes []int64) ([]string, error)
	DeleteDatabase(node *meta2.DataNode, database string, pt uint32) error
	DeleteRetentionPolicy(node *meta2.DataNode, db string, rp string, pt uint32) error
	DeleteMeasurement(node *meta2.DataNode, db string, rp string, name string, shardIds []uint64) error
}

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

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

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

type TableColumnKeys []ColumnKeys

type TableTagKeys []TagKeys

type TableTagSets struct {
	Name   string
	Values TagSets
}

type TablesTagSets []TableTagSets

type TagKeys struct {
	Name string
	Keys []string
}

type TagSet struct {
	Key, Value string
}

type TagSets []TagSet

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

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

type WritePointsResponse struct {
	Code    uint8
	Message string
}