ceresdbproto

type Endpoint struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type Expr struct {

	// Types that are assignable to Node:
	//	*Expr_Operand
	//	*Expr_SubExpr
	Node isExpr_Node `protobuf_oneof:"Node"`
	// contains filtered or unexported fields
}

type Expr_Operand struct {
	Operand *Operand `protobuf:"bytes,1,opt,name=operand,proto3,oneof"`
}

type Expr_SubExpr struct {
	SubExpr *SubExpr `protobuf:"bytes,2,opt,name=sub_expr,json=subExpr,proto3,oneof"`
}

type Field struct {
	NameIndex uint32 `protobuf:"varint,1,opt,name=name_index,json=nameIndex,proto3" json:"name_index,omitempty"`
	Value     *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type FieldGroup struct {
	Timestamp int64    `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Fields    []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type Filter struct {
	TagKey    string            `protobuf:"bytes,1,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	Operators []*FilterOperator `protobuf:"bytes,2,rep,name=operators,proto3" json:"operators,omitempty"`
	// contains filtered or unexported fields
}

type FilterOperator struct {
	FilterType FilterType `protobuf:"varint,1,opt,name=filter_type,json=filterType,proto3,enum=storage.FilterType" json:"filter_type,omitempty"`
	Params     []string   `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

type FilterType int32

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type Operand struct {

	// Types that are assignable to Value:
	//	*Operand_FloatVal
	//	*Operand_StringVal
	//	*Operand_Selector
	Value isOperand_Value `protobuf_oneof:"Value"`
	// contains filtered or unexported fields
}

type Operand_FloatVal struct {
	FloatVal float64 `protobuf:"fixed64,1,opt,name=float_val,json=floatVal,proto3,oneof"`
}

type Operand_Selector struct {
	Selector *Selector `protobuf:"bytes,3,opt,name=selector,proto3,oneof"`
}

type Operand_StringVal struct {
	StringVal string `protobuf:"bytes,2,opt,name=string_val,json=stringVal,proto3,oneof"`
}

type PrometheusQueryRequest struct {
	Expr *Expr `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	// use oneof to represent option for scalar value
	// https://github.com/protocolbuffers/protobuf/issues/1606
	//
	// Types that are assignable to LookbackDelta:
	//	*PrometheusQueryRequest_Delta
	LookbackDelta isPrometheusQueryRequest_LookbackDelta `protobuf_oneof:"lookback_delta"`
	// contains filtered or unexported fields
}

type PrometheusQueryRequest_Delta struct {
	Delta int64 `protobuf:"varint,2,opt,name=delta,proto3,oneof"`
}

type PrometheusQueryResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Samples within a time series must be ordered by time.
	Timeseries []*TimeSeries `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest struct {
	Metrics []string `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Ql      string   `protobuf:"bytes,2,opt,name=ql,proto3" json:"ql,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {
	Header        *ResponseHeader          `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SchemaType    QueryResponse_SchemaType `` /* 130-byte string literal not displayed */
	SchemaContent string                   `protobuf:"bytes,3,opt,name=schema_content,json=schemaContent,proto3" json:"schema_content,omitempty"`
	Rows          [][]byte                 `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse_SchemaType int32

type ResponseHeader struct {
	Code  uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Route struct {
	Metric   string    `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Endpoint *Endpoint `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Ext      []byte    `protobuf:"bytes,3,opt,name=ext,proto3" json:"ext,omitempty"`
	// contains filtered or unexported fields
}

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

type RouteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Routes []*Route        `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

type Sample struct {
	Value     float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64   `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Selector struct {
	Measurement string    `protobuf:"bytes,1,opt,name=measurement,proto3" json:"measurement,omitempty"`
	Filters     []*Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	Start       int64     `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	End         int64     `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	AlignStart  int64     `protobuf:"varint,5,opt,name=align_start,json=alignStart,proto3" json:"align_start,omitempty"`
	AlignEnd    int64     `protobuf:"varint,6,opt,name=align_end,json=alignEnd,proto3" json:"align_end,omitempty"`
	Step        int64     `protobuf:"varint,7,opt,name=step,proto3" json:"step,omitempty"`
	Range       int64     `protobuf:"varint,8,opt,name=range,proto3" json:"range,omitempty"`
	Offset      int64     `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
	Field       string    `protobuf:"bytes,10,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

type StorageServiceClient interface {
	Route(ctx context.Context, in *RouteRequest, opts ...grpc.CallOption) (*RouteResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	StreamWrite(ctx context.Context, opts ...grpc.CallOption) (StorageService_StreamWriteClient, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	StreamQuery(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (StorageService_StreamQueryClient, error)
	PromQuery(ctx context.Context, in *PrometheusQueryRequest, opts ...grpc.CallOption) (*PrometheusQueryResponse, error)
}

type StorageServiceServer interface {
	Route(context.Context, *RouteRequest) (*RouteResponse, error)
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	StreamWrite(StorageService_StreamWriteServer) error
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	StreamQuery(*QueryRequest, StorageService_StreamQueryServer) error
	PromQuery(context.Context, *PrometheusQueryRequest) (*PrometheusQueryResponse, error)
	// contains filtered or unexported methods
}

type StorageService_StreamQueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type StorageService_StreamQueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type StorageService_StreamWriteClient interface {
	Send(*WriteRequest) error
	CloseAndRecv() (*WriteResponse, error)
	grpc.ClientStream
}

type StorageService_StreamWriteServer interface {
	SendAndClose(*WriteResponse) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type SubExpr struct {
	OpType   SubExpr_OperatorType `protobuf:"varint,1,opt,name=op_type,json=opType,proto3,enum=storage.SubExpr_OperatorType" json:"op_type,omitempty"`
	Operator string               `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Operands []*Expr              `protobuf:"bytes,3,rep,name=operands,proto3" json:"operands,omitempty"`
	// for aggr
	Group   []string `protobuf:"bytes,4,rep,name=group,proto3" json:"group,omitempty"`
	Without bool     `protobuf:"varint,5,opt,name=without,proto3" json:"without,omitempty"`
	// contains filtered or unexported fields
}

type SubExpr_OperatorType int32

type Tag struct {
	NameIndex uint32 `protobuf:"varint,1,opt,name=name_index,json=nameIndex,proto3" json:"name_index,omitempty"`
	Value     *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type TimeSeries struct {
	Labels  []*Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedStorageServiceServer struct {
}

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

type Value struct {

	// Types that are assignable to Value:
	//	*Value_Float64Value
	//	*Value_StringValue
	//	*Value_Int64Value
	//	*Value_Float32Value
	//	*Value_Int32Value
	//	*Value_Int16Value
	//	*Value_Int8Value
	//	*Value_BoolValue
	//	*Value_Uint64Value
	//	*Value_Uint32Value
	//	*Value_Uint16Value
	//	*Value_Uint8Value
	//	*Value_TimestampValue
	//	*Value_VarbinaryValue
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

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

type Value_Float32Value struct {
	Float32Value float32 `protobuf:"fixed32,4,opt,name=float32_value,json=float32Value,proto3,oneof"`
}

type Value_Float64Value struct {
	Float64Value float64 `protobuf:"fixed64,1,opt,name=float64_value,json=float64Value,proto3,oneof"`
}

type Value_Int16Value struct {
	Int16Value int32 `protobuf:"varint,6,opt,name=int16_value,json=int16Value,proto3,oneof"`
}

type Value_Int32Value struct {
	Int32Value int32 `protobuf:"varint,5,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type Value_Int64Value struct {
	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type Value_Int8Value struct {
	Int8Value int32 `protobuf:"varint,7,opt,name=int8_value,json=int8Value,proto3,oneof"`
}

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

type Value_TimestampValue struct {
	TimestampValue int64 `protobuf:"varint,13,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type Value_Uint16Value struct {
	Uint16Value uint32 `protobuf:"varint,11,opt,name=uint16_value,json=uint16Value,proto3,oneof"`
}

type Value_Uint32Value struct {
	Uint32Value uint32 `protobuf:"varint,10,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type Value_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,9,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

type Value_Uint8Value struct {
	Uint8Value uint32 `protobuf:"varint,12,opt,name=uint8_value,json=uint8Value,proto3,oneof"`
}

type Value_VarbinaryValue struct {
	VarbinaryValue []byte `protobuf:"bytes,14,opt,name=varbinary_value,json=varbinaryValue,proto3,oneof"`
}

type WriteEntry struct {
	Tags        []*Tag        `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	FieldGroups []*FieldGroup `protobuf:"bytes,2,rep,name=field_groups,json=fieldGroups,proto3" json:"field_groups,omitempty"`
	// contains filtered or unexported fields
}

type WriteMetric struct {
	Metric     string        `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	TagNames   []string      `protobuf:"bytes,2,rep,name=tag_names,json=tagNames,proto3" json:"tag_names,omitempty"`
	FieldNames []string      `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
	Entries    []*WriteEntry `protobuf:"bytes,4,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

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

type WriteResponse struct {
	Header  *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Success uint32          `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Failed  uint32          `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}