v1

type DataPoint struct {

	// timestamp is in the timeunit of milliseconds.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// tag_families contains tags selected in the projection
	TagFamilies []*v1.TagFamily `protobuf:"bytes,2,rep,name=tag_families,json=tagFamilies,proto3" json:"tag_families,omitempty"`
	// fields contains fields selected in the projection
	Fields []*DataPoint_Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type DataPointValue struct {

	// timestamp is in the timeunit of milliseconds.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// the order of tag_families' items match the measure schema
	TagFamilies []*v1.TagFamilyForWrite `protobuf:"bytes,2,rep,name=tag_families,json=tagFamilies,proto3" json:"tag_families,omitempty"`
	// the order of fields match the measure schema
	Fields []*v1.FieldValue `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

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

type InternalWriteRequest struct {
	ShardId    uint32        `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SeriesHash []byte        `protobuf:"bytes,2,opt,name=series_hash,json=seriesHash,proto3" json:"series_hash,omitempty"`
	Request    *WriteRequest `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

type MeasureServiceClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	Write(ctx context.Context, opts ...grpc.CallOption) (MeasureService_WriteClient, error)
	TopN(ctx context.Context, in *TopNRequest, opts ...grpc.CallOption) (*TopNResponse, error)
}

type MeasureServiceServer interface {
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	Write(MeasureService_WriteServer) error
	TopN(context.Context, *TopNRequest) (*TopNResponse, error)
	// contains filtered or unexported methods
}

type MeasureService_WriteClient interface {
	Send(*WriteRequest) error
	Recv() (*WriteResponse, error)
	grpc.ClientStream
}

type MeasureService_WriteServer interface {
	Send(*WriteResponse) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type QueryRequest struct {

	// metadata is required
	Metadata *v11.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// time_range is a range query with begin/end time of entities in the timeunit of milliseconds.
	TimeRange *v1.TimeRange `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	// tag_families are indexed.
	Criteria []*v1.Criteria `protobuf:"bytes,4,rep,name=criteria,proto3" json:"criteria,omitempty"`
	// tag_projection can be used to select tags of the data points in the response
	TagProjection *v1.TagProjection `protobuf:"bytes,5,opt,name=tag_projection,json=tagProjection,proto3" json:"tag_projection,omitempty"`
	// field_projection can be used to select fields of the data points in the response
	FieldProjection *QueryRequest_FieldProjection `protobuf:"bytes,6,opt,name=field_projection,json=fieldProjection,proto3" json:"field_projection,omitempty"`
	// group_by groups data points based on their field value for a specific tag and use field_name as the projection name
	GroupBy *QueryRequest_GroupBy `protobuf:"bytes,7,opt,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	// agg aggregates data points based on a field
	Agg *QueryRequest_Aggregation `protobuf:"bytes,8,opt,name=agg,proto3" json:"agg,omitempty"`
	// top limits the result based on a particular field.
	// If order_by is specificed, top sorts the dataset based on order_by's output
	Top *QueryRequest_Top `protobuf:"bytes,9,opt,name=top,proto3" json:"top,omitempty"`
	// offset is used to support pagination, together with the following limit.
	// If top is sepcificed, offset processes the dataset based on top's output
	Offset uint32 `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	// limit is used to impose a boundary on the number of records being returned.
	// If top is sepcificed, limit processes the dataset based on top's output
	Limit uint32 `protobuf:"varint,11,opt,name=limit,proto3" json:"limit,omitempty"`
	// order_by is given to specify the sort for a tag.
	OrderBy *v1.QueryOrder `protobuf:"bytes,12,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest_Aggregation struct {
	Function v1.AggregationFunction `protobuf:"varint,1,opt,name=function,proto3,enum=banyandb.model.v1.AggregationFunction" json:"function,omitempty"`
	// field_name must be one of files indicated by the field_projection
	FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// contains filtered or unexported fields
}

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

type QueryRequest_GroupBy struct {

	// tag_projection must be a subset of the tag_projection of QueryRequest
	TagProjection *v1.TagProjection `protobuf:"bytes,1,opt,name=tag_projection,json=tagProjection,proto3" json:"tag_projection,omitempty"`
	// field_name must be one of fields indicated by field_projection
	FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest_Top struct {

	// number set the how many items should be returned
	Number int32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// field_name must be one of files indicated by the field_projection
	FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// field_value_sort indicates how to sort fields
	// ASC: bottomN
	// DESC: topN
	// UNSPECIFIED: topN
	FieldValueSort v1.Sort `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

type QueryResponse struct {

	// data_points are the actual data returned
	DataPoints []*DataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"`
	// contains filtered or unexported fields
}

type TopNList struct {

	// timestamp is in the timeunit of milliseconds.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// items contains top-n items in a list
	Items []*TopNList_Item `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

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

type TopNRequest struct {

	// metadata is required
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// time_range is a range query with begin/end time of entities in the timeunit of milliseconds.
	TimeRange *v11.TimeRange `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	// top_n set the how many items should be returned in each list.
	TopN int32 `protobuf:"varint,3,opt,name=top_n,json=topN,proto3" json:"top_n,omitempty"`
	// agg aggregates lists grouped by field names in the time_range
	Agg v11.AggregationFunction `protobuf:"varint,4,opt,name=agg,proto3,enum=banyandb.model.v1.AggregationFunction" json:"agg,omitempty"`
	// criteria select counters.
	Conditions []*v11.Condition `protobuf:"bytes,5,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// field_value_sort indicates how to sort fields
	FieldValueSort v11.Sort `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

type TopNResponse struct {

	// lists contain a series topN lists ranked by timestamp
	// if agg_func in query request is specified, lists' size should be one.
	Lists []*TopNList `protobuf:"bytes,1,rep,name=lists,proto3" json:"lists,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedMeasureServiceServer struct {
}

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

type WriteRequest struct {

	// the metadata is required.
	Metadata *v11.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// the data_point is required.
	DataPoint *DataPointValue `protobuf:"bytes,2,opt,name=data_point,json=dataPoint,proto3" json:"data_point,omitempty"`
	// contains filtered or unexported fields
}

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