v1

type Data struct {

	// Types that are assignable to Data:
	//
	//	*Data_Metrics
	//	*Data_Logs
	//	*Data_Traces
	Data isData_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type Data_Logs struct {
	Logs *v11.LogsData `protobuf:"bytes,2,opt,name=logs,proto3,oneof"`
}

type Data_Metrics struct {
	Metrics *v1.MetricsData `protobuf:"bytes,1,opt,name=metrics,proto3,oneof"`
}

type Data_Traces struct {
	Traces *v12.TracesData `protobuf:"bytes,3,opt,name=traces,proto3,oneof"`
}

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

type Meta struct {
	Id []uint64 `protobuf:"varint,1,rep,packed,name=id,proto3" json:"id,omitempty"`
	// Minimum timetamp observed in this sample in milliseconds
	MinTs []uint64 `protobuf:"varint,2,rep,packed,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	// contains filtered or unexported fields
}

type MetaInfo struct {
	MinTs uint64 `protobuf:"varint,1,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	MaxTs uint64 `protobuf:"varint,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	Id    uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type PREFIX int32

type RESOURCE int32

type RQClient interface {
	ScanSamples(ctx context.Context, in *Scan, opts ...grpc.CallOption) (*Data, error)
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*Version, error)
}

type RQServer interface {
	ScanSamples(context.Context, *Scan) (*Data, error)
	GetVersion(context.Context, *GetVersionRequest) (*Version, error)
	// contains filtered or unexported methods
}

type Sample struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Serialized Data object, compressed with zstd. We use bytes here because we
	// automatically sore Sample as a arrow.Record.
	Data *Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Minimum timetamp observed in this sample in milliseconds
	MinTs uint64 `protobuf:"varint,3,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	// Maximum timestamp observed in this sample in milliseconds
	MaxTs uint64 `protobuf:"varint,4,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	// contains filtered or unexported fields
}

type Scan struct {
	Scope Scan_SCOPE `protobuf:"varint,1,opt,name=scope,proto3,enum=v1.Scan_SCOPE" json:"scope,omitempty"`
	// Timestamps to bound scan. This is optional, if it is not set a time range
	// of the last 15 minutes since now.
	TimeRange *Scan_TimeRange `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	Filters   []*Scan_Filter  `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
	// Number of samples to process. Defauluts to no limit.
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// Scans in reverse order, with latest samples comming first.  To get the
	// latest sample you can set reverse to true and limit 1.
	Reverse bool `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// Now is current scan evaluation time. This is optional, when not set current
	// system time is used.
	//
	// Useful for reprdocucible scanning by compining this with time_range a
	// script can ensure it will be processing the same samples.
	Now *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=now,proto3" json:"now,omitempty"`
	// Offset relative to current scanning time.
	Offset *durationpb.Duration `protobuf:"bytes,7,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type Scan_AttrFilter struct {
	Prop  Scan_AttributeProp `protobuf:"varint,1,opt,name=prop,proto3,enum=v1.Scan_AttributeProp" json:"prop,omitempty"`
	Key   string             `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value string             `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Scan_AttributeProp int32

type Scan_BaseFilter struct {
	Prop  Scan_BaseProp `protobuf:"varint,1,opt,name=prop,proto3,enum=v1.Scan_BaseProp" json:"prop,omitempty"`
	Value string        `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Scan_BaseProp int32

type Scan_Filter struct {

	// Types that are assignable to Value:
	//
	//	*Scan_Filter_Base
	//	*Scan_Filter_Attr
	Value isScan_Filter_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type Scan_Filter_Attr struct {
	Attr *Scan_AttrFilter `protobuf:"bytes,2,opt,name=attr,proto3,oneof"`
}

type Scan_Filter_Base struct {
	Base *Scan_BaseFilter `protobuf:"bytes,1,opt,name=base,proto3,oneof"`
}

type Scan_SCOPE int32

type Scan_TimeRange struct {
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRQServer struct {
}

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

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