Versions in this module Expand all Collapse all v0 v0.22.0 Apr 16, 2024 Changes in this version + const RQ_GetVersion_FullMethodName + const RQ_ScanSamples_FullMethodName + var File_rq_v1_resource_proto protoreflect.FileDescriptor + var File_rq_v1_sample_proto protoreflect.FileDescriptor + var File_rq_v1_scan_proto protoreflect.FileDescriptor + var File_rq_v1_service_proto protoreflect.FileDescriptor + var PREFIX_name = map[int32]string + var PREFIX_value = map[string]int32 + var RESOURCE_name = map[int32]string + var RESOURCE_value = map[string]int32 + var RQ_ServiceDesc = grpc.ServiceDesc + var Scan_AttributeProp_name = map[int32]string + var Scan_AttributeProp_value = map[string]int32 + var Scan_BaseProp_name = map[int32]string + var Scan_BaseProp_value = map[string]int32 + var Scan_SCOPE_name = map[int32]string + var Scan_SCOPE_value = map[string]int32 + func RegisterRQServer(s grpc.ServiceRegistrar, srv RQServer) + type Data struct + Data isData_Data + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (m *Data) GetData() isData_Data + func (x *Data) GetLogs() *v11.LogsData + func (x *Data) GetMetrics() *v1.MetricsData + func (x *Data) GetTraces() *v12.TracesData + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type Data_Logs struct + Logs *v11.LogsData + type Data_Metrics struct + Metrics *v1.MetricsData + type Data_Traces struct + Traces *v12.TracesData + type GetVersionRequest struct + func (*GetVersionRequest) Descriptor() ([]byte, []int) + func (*GetVersionRequest) ProtoMessage() + func (x *GetVersionRequest) ProtoReflect() protoreflect.Message + func (x *GetVersionRequest) Reset() + func (x *GetVersionRequest) String() string + type Meta struct + Id []uint64 + MinTs []uint64 + func (*Meta) Descriptor() ([]byte, []int) + func (*Meta) ProtoMessage() + func (x *Meta) GetId() []uint64 + func (x *Meta) GetMinTs() []uint64 + func (x *Meta) ProtoReflect() protoreflect.Message + func (x *Meta) Reset() + func (x *Meta) String() string + type MetaInfo struct + Id uint64 + MaxTs uint64 + MinTs uint64 + func (*MetaInfo) Descriptor() ([]byte, []int) + func (*MetaInfo) ProtoMessage() + func (x *MetaInfo) GetId() uint64 + func (x *MetaInfo) GetMaxTs() uint64 + func (x *MetaInfo) GetMinTs() uint64 + func (x *MetaInfo) ProtoReflect() protoreflect.Message + func (x *MetaInfo) Reset() + func (x *MetaInfo) String() string + type PREFIX int32 + const PREFIX_ATTRIBUTES + const PREFIX_DATA + const PREFIX_LOGS_LEVEL + const PREFIX_NAME + const PREFIX_PARENT_SPAN_ID + const PREFIX_RESOURCE_ATTRIBUTES + const PREFIX_RESOURCE_SCHEMA + const PREFIX_SCOPE_ATTRIBUTES + const PREFIX_SCOPE_NAME + const PREFIX_SCOPE_SCHEMA + const PREFIX_SCOPE_VERSION + const PREFIX_SPAN_ID + const PREFIX_TRACE_ID + func (PREFIX) Descriptor() protoreflect.EnumDescriptor + func (PREFIX) EnumDescriptor() ([]byte, []int) + func (PREFIX) Type() protoreflect.EnumType + func (x PREFIX) Enum() *PREFIX + func (x PREFIX) Number() protoreflect.EnumNumber + func (x PREFIX) String() string + type RESOURCE int32 + const RESOURCE_LOGS + const RESOURCE_META + const RESOURCE_META_ID + const RESOURCE_META_INFO + const RESOURCE_METRICS + const RESOURCE_SAMPLE_ID + const RESOURCE_TRACES + const RESOURCE_UNKOWN + func (RESOURCE) Descriptor() protoreflect.EnumDescriptor + func (RESOURCE) EnumDescriptor() ([]byte, []int) + func (RESOURCE) Type() protoreflect.EnumType + func (x RESOURCE) Enum() *RESOURCE + func (x RESOURCE) Number() protoreflect.EnumNumber + func (x RESOURCE) String() string + type RQClient interface + GetVersion func(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*Version, error) + ScanSamples func(ctx context.Context, in *Scan, opts ...grpc.CallOption) (*Data, error) + func NewRQClient(cc grpc.ClientConnInterface) RQClient + type RQServer interface + GetVersion func(context.Context, *GetVersionRequest) (*Version, error) + ScanSamples func(context.Context, *Scan) (*Data, error) + type Sample struct + Data *Data + Id uint64 + MaxTs uint64 + MinTs uint64 + func (*Sample) Descriptor() ([]byte, []int) + func (*Sample) ProtoMessage() + func (x *Sample) GetData() *Data + func (x *Sample) GetId() uint64 + func (x *Sample) GetMaxTs() uint64 + func (x *Sample) GetMinTs() uint64 + func (x *Sample) ProtoReflect() protoreflect.Message + func (x *Sample) Reset() + func (x *Sample) String() string + type Scan struct + Filters []*Scan_Filter + Limit uint64 + Now *timestamppb.Timestamp + Offset *durationpb.Duration + Reverse bool + Scope Scan_SCOPE + TimeRange *Scan_TimeRange + func (*Scan) Descriptor() ([]byte, []int) + func (*Scan) ProtoMessage() + func (x *Scan) GetFilters() []*Scan_Filter + func (x *Scan) GetLimit() uint64 + func (x *Scan) GetNow() *timestamppb.Timestamp + func (x *Scan) GetOffset() *durationpb.Duration + func (x *Scan) GetReverse() bool + func (x *Scan) GetScope() Scan_SCOPE + func (x *Scan) GetTimeRange() *Scan_TimeRange + func (x *Scan) ProtoReflect() protoreflect.Message + func (x *Scan) Reset() + func (x *Scan) String() string + type Scan_AttrFilter struct + Key string + Prop Scan_AttributeProp + Value string + func (*Scan_AttrFilter) Descriptor() ([]byte, []int) + func (*Scan_AttrFilter) ProtoMessage() + func (x *Scan_AttrFilter) GetKey() string + func (x *Scan_AttrFilter) GetProp() Scan_AttributeProp + func (x *Scan_AttrFilter) GetValue() string + func (x *Scan_AttrFilter) ProtoReflect() protoreflect.Message + func (x *Scan_AttrFilter) Reset() + func (x *Scan_AttrFilter) String() string + type Scan_AttributeProp int32 + const Scan_ATTRIBUTES + const Scan_RESOURCE_ATTRIBUTES + const Scan_SCOPE_ATTRIBUTES + const Scan_UNKOWN_ATTR + func (Scan_AttributeProp) Descriptor() protoreflect.EnumDescriptor + func (Scan_AttributeProp) EnumDescriptor() ([]byte, []int) + func (Scan_AttributeProp) Type() protoreflect.EnumType + func (x Scan_AttributeProp) Enum() *Scan_AttributeProp + func (x Scan_AttributeProp) Number() protoreflect.EnumNumber + func (x Scan_AttributeProp) String() string + type Scan_BaseFilter struct + Prop Scan_BaseProp + Value string + func (*Scan_BaseFilter) Descriptor() ([]byte, []int) + func (*Scan_BaseFilter) ProtoMessage() + func (x *Scan_BaseFilter) GetProp() Scan_BaseProp + func (x *Scan_BaseFilter) GetValue() string + func (x *Scan_BaseFilter) ProtoReflect() protoreflect.Message + func (x *Scan_BaseFilter) Reset() + func (x *Scan_BaseFilter) String() string + type Scan_BaseProp int32 + const Scan_LOGS_LEVEL + const Scan_NAME + const Scan_PARENT_SPAN_ID + const Scan_RESOURCE_SCHEMA + const Scan_SCOPE_NAME + const Scan_SCOPE_SCHEMA + const Scan_SCOPE_VERSION + const Scan_SPAN_ID + const Scan_TRACE_ID + func (Scan_BaseProp) Descriptor() protoreflect.EnumDescriptor + func (Scan_BaseProp) EnumDescriptor() ([]byte, []int) + func (Scan_BaseProp) Type() protoreflect.EnumType + func (x Scan_BaseProp) Enum() *Scan_BaseProp + func (x Scan_BaseProp) Number() protoreflect.EnumNumber + func (x Scan_BaseProp) String() string + type Scan_Filter struct + Value isScan_Filter_Value + func (*Scan_Filter) Descriptor() ([]byte, []int) + func (*Scan_Filter) ProtoMessage() + func (m *Scan_Filter) GetValue() isScan_Filter_Value + func (x *Scan_Filter) GetAttr() *Scan_AttrFilter + func (x *Scan_Filter) GetBase() *Scan_BaseFilter + func (x *Scan_Filter) ProtoReflect() protoreflect.Message + func (x *Scan_Filter) Reset() + func (x *Scan_Filter) String() string + type Scan_Filter_Attr struct + Attr *Scan_AttrFilter + type Scan_Filter_Base struct + Base *Scan_BaseFilter + type Scan_SCOPE int32 + const Scan_LOGS + const Scan_METRICS + const Scan_TRACES + const Scan_UNKOWN + func (Scan_SCOPE) Descriptor() protoreflect.EnumDescriptor + func (Scan_SCOPE) EnumDescriptor() ([]byte, []int) + func (Scan_SCOPE) Type() protoreflect.EnumType + func (x Scan_SCOPE) Enum() *Scan_SCOPE + func (x Scan_SCOPE) Number() protoreflect.EnumNumber + func (x Scan_SCOPE) String() string + type Scan_TimeRange struct + End *timestamppb.Timestamp + Start *timestamppb.Timestamp + func (*Scan_TimeRange) Descriptor() ([]byte, []int) + func (*Scan_TimeRange) ProtoMessage() + func (x *Scan_TimeRange) GetEnd() *timestamppb.Timestamp + func (x *Scan_TimeRange) GetStart() *timestamppb.Timestamp + func (x *Scan_TimeRange) ProtoReflect() protoreflect.Message + func (x *Scan_TimeRange) Reset() + func (x *Scan_TimeRange) String() string + type UnimplementedRQServer struct + func (UnimplementedRQServer) GetVersion(context.Context, *GetVersionRequest) (*Version, error) + func (UnimplementedRQServer) ScanSamples(context.Context, *Scan) (*Data, error) + type UnsafeRQServer interface + type Version struct + Version string + func (*Version) Descriptor() ([]byte, []int) + func (*Version) ProtoMessage() + func (x *Version) GetVersion() string + func (x *Version) ProtoReflect() protoreflect.Message + func (x *Version) Reset() + func (x *Version) String() string
Go to main page