types

type AggFunction struct {
	Function    string `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	Field       string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	WindowNanos int64  `protobuf:"varint,3,opt,name=window_nanos,json=windowNanos,proto3" json:"window_nanos,omitempty"`
	// contains filtered or unexported fields
}

type AggregateSpec struct {
	Functions []*AggFunction `protobuf:"bytes,1,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

type CompactionConfig struct {

	// 最大 SSTable 数量，超过此值触发 compaction
	MaxSstableCount int32 `protobuf:"varint,1,opt,name=max_sstable_count,json=maxSstableCount,proto3" json:"max_sstable_count,omitempty"`
	// 单次 compaction 最大文件数（0 表示不限制）
	MaxCompactionBatch int32 `protobuf:"varint,2,opt,name=max_compaction_batch,json=maxCompactionBatch,proto3" json:"max_compaction_batch,omitempty"`
	// 单个 Shard 数据大小上限（字节），超过后不参与 compaction
	ShardSizeLimit int64 `protobuf:"varint,3,opt,name=shard_size_limit,json=shardSizeLimit,proto3" json:"shard_size_limit,omitempty"`
	// 定时触发间隔（纳秒），0 表示禁用定时触发
	CheckIntervalNanos int64 `protobuf:"varint,4,opt,name=check_interval_nanos,json=checkIntervalNanos,proto3" json:"check_interval_nanos,omitempty"`
	// Compaction 超时时间（纳秒）
	TimeoutNanos int64 `protobuf:"varint,5,opt,name=timeout_nanos,json=timeoutNanos,proto3" json:"timeout_nanos,omitempty"`
	// contains filtered or unexported fields
}

type CompressionAlgorithm int32

type Config struct {

	// 数据目录
	DataDir string `protobuf:"bytes,1,opt,name=data_dir,json=dataDir,proto3" json:"data_dir,omitempty"`
	// Shard 时间窗口（纳秒）
	ShardDurationNanos int64 `protobuf:"varint,2,opt,name=shard_duration_nanos,json=shardDurationNanos,proto3" json:"shard_duration_nanos,omitempty"`
	// 内存表配置
	MemTableCfg *MemTableConfig `protobuf:"bytes,3,opt,name=mem_table_cfg,json=memTableCfg,proto3" json:"mem_table_cfg,omitempty"`
	// Compaction 配置
	CompactionCfg *CompactionConfig `protobuf:"bytes,4,opt,name=compaction_cfg,json=compactionCfg,proto3" json:"compaction_cfg,omitempty"`
	// 压缩算法
	CompressionAlgorithm CompressionAlgorithm `` /* 155-byte string literal not displayed */
	// 数据保留期（纳秒），0 表示不自动删除过期数据
	RetentionPeriodNanos int64 `protobuf:"varint,6,opt,name=retention_period_nanos,json=retentionPeriodNanos,proto3" json:"retention_period_nanos,omitempty"`
	// Retention 检查间隔（纳秒）
	RetentionCheckIntervalNanos int64 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateDatabaseRequest struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// 数据保留期（纳秒），0 表示不自动删除过期数据
	RetentionPeriodNanos int64 `protobuf:"varint,2,opt,name=retention_period_nanos,json=retentionPeriodNanos,proto3" json:"retention_period_nanos,omitempty"`
	// 降采样配置（可选）
	DownsampleConfig *DownsampleConfig `protobuf:"bytes,3,opt,name=downsample_config,json=downsampleConfig,proto3" json:"downsample_config,omitempty"`
	// contains filtered or unexported fields
}

type CreateDatabaseResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type CreateMeasurementRequest struct {
	Database    string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Measurement string `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	// contains filtered or unexported fields
}

type CreateMeasurementResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type DownsampleConfig struct {
	Enabled            bool              `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	CheckIntervalNanos int64             `protobuf:"varint,2,opt,name=check_interval_nanos,json=checkIntervalNanos,proto3" json:"check_interval_nanos,omitempty"`
	Rules              []*DownsampleRule `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

type DownsampleRule struct {
	WindowNanos    int64    `protobuf:"varint,1,opt,name=window_nanos,json=windowNanos,proto3" json:"window_nanos,omitempty"`
	Functions      []string `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"`
	RetentionNanos int64    `protobuf:"varint,3,opt,name=retention_nanos,json=retentionNanos,proto3" json:"retention_nanos,omitempty"`
	// contains filtered or unexported fields
}

type DropDatabaseRequest struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

type DropDatabaseResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type DropMeasurementRequest struct {
	Database    string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Measurement string `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	// contains filtered or unexported fields
}

type DropMeasurementResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type FieldEntry struct {
	Key   string      `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FieldValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type FieldValue struct {

	// Types that are valid to be assigned to Value:
	//
	//	*FieldValue_IntValue
	//	*FieldValue_FloatValue
	//	*FieldValue_StringValue
	//	*FieldValue_BoolValue
	Value isFieldValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type FieldValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type FieldValue_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,2,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type FieldValue_IntValue struct {
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}

type FieldValue_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type FilterCondition struct {
	Tag   string      `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Field string      `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	Op    FilterOp    `protobuf:"varint,3,opt,name=op,proto3,enum=mts.v1.FilterOp" json:"op,omitempty"`
	Value *FieldValue `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type FilterOp int32

type FilterSpec struct {
	Conditions []*FilterCondition `protobuf:"bytes,1,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// contains filtered or unexported fields
}

type GroupBySpec struct {
	Tags []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

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

type HealthResponse struct {
	Healthy bool   `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type InternalField struct {
	Key   string
	Value *FieldValue
}

type InternalPoint struct {
	Timestamp int64
	Fields    []InternalField
	Sid       uint64
}

type LimitSpec struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit  int64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

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

type ListDatabasesResponse struct {
	Databases []string `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

type ListMeasurementsRequest struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

type ListMeasurementsResponse struct {
	Measurements []string `protobuf:"bytes,1,rep,name=measurements,proto3" json:"measurements,omitempty"`
	// contains filtered or unexported fields
}

type MTSClient interface {
	// 单点写入
	//
	// 将单个数据点写入时序数据库。
	// 数据首先写入 WAL，然后写入 MemTable。
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	// 批量写入
	//
	// 批量写入多个数据点，吞吐量通常比单点写入高。
	// 批量写入不是原子操作，部分失败不会回滚已写入的点。
	WriteBatch(ctx context.Context, in *WriteBatchRequest, opts ...grpc.CallOption) (*WriteBatchResponse, error)
	// 范围查询
	//
	// 查询指定时间范围内的数据，支持字段过滤、标签过滤和分页。
	// 数据按时间戳升序返回。
	QueryRange(ctx context.Context, in *QueryRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Row], error)
	// 列出 Measurement
	//
	// 返回指定数据库中的所有 Measurement 名称。
	// 如果数据库不存在，返回空列表。
	ListMeasurements(ctx context.Context, in *ListMeasurementsRequest, opts ...grpc.CallOption) (*ListMeasurementsResponse, error)
	// 创建 Measurement
	//
	// 在指定数据库中创建一个新的 Measurement。
	// 如果数据库不存在，会自动创建。
	// 如果 Measurement 已存在，不会返回错误。
	CreateMeasurement(ctx context.Context, in *CreateMeasurementRequest, opts ...grpc.CallOption) (*CreateMeasurementResponse, error)
	// 删除 Measurement
	//
	// 删除指定的 Measurement 及其所有元数据。
	// 注意：磁盘上的数据文件不会被立即删除。
	DropMeasurement(ctx context.Context, in *DropMeasurementRequest, opts ...grpc.CallOption) (*DropMeasurementResponse, error)
	// 列出数据库
	//
	// 返回所有数据库名称列表。
	ListDatabases(ctx context.Context, in *ListDatabasesRequest, opts ...grpc.CallOption) (*ListDatabasesResponse, error)
	// 创建数据库
	//
	// 创建一个新的数据库。
	// 如果数据库已存在，不会返回错误。
	CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseResponse, error)
	// 删除数据库
	//
	// 删除指定的数据库及其所有 Measurement。
	// 警告：此操作会永久删除元数据，且不可恢复。
	DropDatabase(ctx context.Context, in *DropDatabaseRequest, opts ...grpc.CallOption) (*DropDatabaseResponse, error)
	// 健康检查
	//
	// 返回服务的健康状态，用于负载均衡器健康检查和监控。
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}

type MTSServer interface {
	// 单点写入
	//
	// 将单个数据点写入时序数据库。
	// 数据首先写入 WAL，然后写入 MemTable。
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	// 批量写入
	//
	// 批量写入多个数据点，吞吐量通常比单点写入高。
	// 批量写入不是原子操作，部分失败不会回滚已写入的点。
	WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error)
	// 范围查询
	//
	// 查询指定时间范围内的数据，支持字段过滤、标签过滤和分页。
	// 数据按时间戳升序返回。
	QueryRange(*QueryRangeRequest, grpc.ServerStreamingServer[Row]) error
	// 列出 Measurement
	//
	// 返回指定数据库中的所有 Measurement 名称。
	// 如果数据库不存在，返回空列表。
	ListMeasurements(context.Context, *ListMeasurementsRequest) (*ListMeasurementsResponse, error)
	// 创建 Measurement
	//
	// 在指定数据库中创建一个新的 Measurement。
	// 如果数据库不存在，会自动创建。
	// 如果 Measurement 已存在，不会返回错误。
	CreateMeasurement(context.Context, *CreateMeasurementRequest) (*CreateMeasurementResponse, error)
	// 删除 Measurement
	//
	// 删除指定的 Measurement 及其所有元数据。
	// 注意：磁盘上的数据文件不会被立即删除。
	DropMeasurement(context.Context, *DropMeasurementRequest) (*DropMeasurementResponse, error)
	// 列出数据库
	//
	// 返回所有数据库名称列表。
	ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error)
	// 创建数据库
	//
	// 创建一个新的数据库。
	// 如果数据库已存在，不会返回错误。
	CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
	// 删除数据库
	//
	// 删除指定的数据库及其所有 Measurement。
	// 警告：此操作会永久删除元数据，且不可恢复。
	DropDatabase(context.Context, *DropDatabaseRequest) (*DropDatabaseResponse, error)
	// 健康检查
	//
	// 返回服务的健康状态，用于负载均衡器健康检查和监控。
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
}

type MTS_QueryRangeClient = grpc.ServerStreamingClient[Row]

type MTS_QueryRangeServer = grpc.ServerStreamingServer[Row]

type MemPoint struct {
	Database    string
	Measurement string
	Timestamp   int64
	Sid         uint64
	FieldData   []byte
}

type MemTableConfig struct {

	// 触发刷盘的内存大小阈值（字节），默认 64MB
	FlushMemorySize int64 `protobuf:"varint,1,opt,name=flush_memory_size,json=flushMemorySize,proto3" json:"flush_memory_size,omitempty"`
	// 触发刷盘的条目数阈值，默认 50000
	FlushPointCount int32 `protobuf:"varint,2,opt,name=flush_point_count,json=flushPointCount,proto3" json:"flush_point_count,omitempty"`
	// 触发刷盘的空闲时间阈值（纳秒），默认 60秒
	FlushIdleNanos int64 `protobuf:"varint,3,opt,name=flush_idle_nanos,json=flushIdleNanos,proto3" json:"flush_idle_nanos,omitempty"`
	// contains filtered or unexported fields
}

type OperatorSpec struct {

	// Types that are valid to be assigned to Op:
	//
	//	*OperatorSpec_Scan
	//	*OperatorSpec_Filter
	//	*OperatorSpec_GroupBy
	//	*OperatorSpec_Aggregate
	//	*OperatorSpec_Sort
	//	*OperatorSpec_Project
	//	*OperatorSpec_Limit
	Op isOperatorSpec_Op `protobuf_oneof:"op"`
	// contains filtered or unexported fields
}

type OperatorSpec_Aggregate struct {
	Aggregate *AggregateSpec `protobuf:"bytes,4,opt,name=aggregate,proto3,oneof"`
}

type OperatorSpec_Filter struct {
	Filter *FilterSpec `protobuf:"bytes,2,opt,name=filter,proto3,oneof"`
}

type OperatorSpec_GroupBy struct {
	GroupBy *GroupBySpec `protobuf:"bytes,3,opt,name=group_by,json=groupBy,proto3,oneof"`
}

type OperatorSpec_Limit struct {
	Limit *LimitSpec `protobuf:"bytes,7,opt,name=limit,proto3,oneof"`
}

type OperatorSpec_Project struct {
	Project *ProjectSpec `protobuf:"bytes,6,opt,name=project,proto3,oneof"`
}

type OperatorSpec_Scan struct {
	Scan *ScanSpec `protobuf:"bytes,1,opt,name=scan,proto3,oneof"`
}

type OperatorSpec_Sort struct {
	Sort *SortSpec `protobuf:"bytes,5,opt,name=sort,proto3,oneof"`
}

type Point struct {

	// 数据库名称
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// 测量名称（类似表名）
	Measurement string `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	// 标签键值对，用于标识时间序列
	Tags map[string]string `` /* 135-byte string literal not displayed */
	// 时间戳，纳秒级 Unix 时间戳
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// 字段值，存储实际的数据
	Fields map[string]*FieldValue `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PointRow struct {

	// Series ID，用于内部标识唯一的标签组合
	Sid uint64 `protobuf:"varint,1,opt,name=sid,proto3" json:"sid,omitempty"`
	// 时间戳
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// 标签键值对
	Tags map[string]string `` /* 135-byte string literal not displayed */
	// 字段值（按名访问使用 GetField 辅助方法）
	Fields []*FieldEntry `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type ProjectSpec struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type QueryPlan struct {
	Database    string          `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Measurement string          `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	StartTime   int64           `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime     int64           `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Ops         []*OperatorSpec `protobuf:"bytes,5,rep,name=ops,proto3" json:"ops,omitempty"`
	// contains filtered or unexported fields
}

type QueryRangeRequest struct {
	Database    string            `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Measurement string            `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	StartTime   int64             `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime     int64             `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Fields      []string          `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`
	Tags        map[string]string `` /* 135-byte string literal not displayed */
	Offset      int64             `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit       int64             `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"`
	// 降采样查询窗口（纳秒），0 或不设置表示查询原始数据
	DownsampleWindowNanos int64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type QueryRangeResponse struct {
	Rows    []*Row `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	HasMore bool   `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// contains filtered or unexported fields
}

type Row struct {
	Timestamp int64             `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Tags      map[string]string `` /* 135-byte string literal not displayed */
	Fields    []*FieldEntry     `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type ScanSpec struct {
	DownsampleWindowNanos int64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SortDirection int32

type SortField struct {
	Field     string        `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Direction SortDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=mts.v1.SortDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

type SortSpec struct {
	Fields []*SortField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedMTSServer struct{}

type UnsafeMTSServer interface {
	// contains filtered or unexported methods
}

type WriteBatchRequest struct {
	Points []*WriteRequest `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

type WriteBatchResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Count   int32  `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type WriteRequest struct {
	Database    string                 `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Measurement string                 `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	Tags        map[string]string      `` /* 135-byte string literal not displayed */
	Timestamp   int64                  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Fields      map[string]*FieldValue `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type WriteResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}