v1

package
v0.22.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RQ_ScanSamples_FullMethodName = "/v1.RQ/ScanSamples"
	RQ_GetVersion_FullMethodName  = "/v1.RQ/GetVersion"
)

Variables

View Source 
var (
	RESOURCE_name = map[int32]string{
		0: "UNKOWN",
		1: "METRICS",
		2: "TRACES",
		3: "LOGS",
		4: "SAMPLE_ID",
		5: "META",
		6: "META_ID",
		8: "META_INFO",
	}
	RESOURCE_value = map[string]int32{
		"UNKOWN":    0,
		"METRICS":   1,
		"TRACES":    2,
		"LOGS":      3,
		"SAMPLE_ID": 4,
		"META":      5,
		"META_ID":   6,
		"META_INFO": 8,
	}
)

Enum value maps for RESOURCE.

View Source 
var (
	PREFIX_name = map[int32]string{
		0:  "RESOURCE_SCHEMA",
		1:  "RESOURCE_ATTRIBUTES",
		2:  "SCOPE_SCHEMA",
		3:  "SCOPE_NAME",
		4:  "SCOPE_VERSION",
		5:  "SCOPE_ATTRIBUTES",
		6:  "NAME",
		7:  "ATTRIBUTES",
		8:  "TRACE_ID",
		9:  "SPAN_ID",
		10: "PARENT_SPAN_ID",
		11: "LOGS_LEVEL",
		12: "DATA",
	}
	PREFIX_value = map[string]int32{
		"RESOURCE_SCHEMA":     0,
		"RESOURCE_ATTRIBUTES": 1,
		"SCOPE_SCHEMA":        2,
		"SCOPE_NAME":          3,
		"SCOPE_VERSION":       4,
		"SCOPE_ATTRIBUTES":    5,
		"NAME":                6,
		"ATTRIBUTES":          7,
		"TRACE_ID":            8,
		"SPAN_ID":             9,
		"PARENT_SPAN_ID":      10,
		"LOGS_LEVEL":          11,
		"DATA":                12,
	}
)

Enum value maps for PREFIX.

View Source 
var (
	Scan_SCOPE_name = map[int32]string{
		0: "UNKOWN",
		1: "METRICS",
		2: "TRACES",
		3: "LOGS",
	}
	Scan_SCOPE_value = map[string]int32{
		"UNKOWN":  0,
		"METRICS": 1,
		"TRACES":  2,
		"LOGS":    3,
	}
)

Enum value maps for Scan_SCOPE.

View Source 
var (
	Scan_BaseProp_name = map[int32]string{
		0:  "RESOURCE_SCHEMA",
		2:  "SCOPE_SCHEMA",
		3:  "SCOPE_NAME",
		4:  "SCOPE_VERSION",
		6:  "NAME",
		8:  "TRACE_ID",
		9:  "SPAN_ID",
		10: "PARENT_SPAN_ID",
		11: "LOGS_LEVEL",
	}
	Scan_BaseProp_value = map[string]int32{
		"RESOURCE_SCHEMA": 0,
		"SCOPE_SCHEMA":    2,
		"SCOPE_NAME":      3,
		"SCOPE_VERSION":   4,
		"NAME":            6,
		"TRACE_ID":        8,
		"SPAN_ID":         9,
		"PARENT_SPAN_ID":  10,
		"LOGS_LEVEL":      11,
	}
)

Enum value maps for Scan_BaseProp.

View Source 
var (
	Scan_AttributeProp_name = map[int32]string{
		0: "UNKOWN_ATTR",
		1: "RESOURCE_ATTRIBUTES",
		5: "SCOPE_ATTRIBUTES",
		7: "ATTRIBUTES",
	}
	Scan_AttributeProp_value = map[string]int32{
		"UNKOWN_ATTR":         0,
		"RESOURCE_ATTRIBUTES": 1,
		"SCOPE_ATTRIBUTES":    5,
		"ATTRIBUTES":          7,
	}
)

Enum value maps for Scan_AttributeProp.

View Source 
var File_rq_v1_resource_proto protoreflect.FileDescriptor
View Source 
var File_rq_v1_sample_proto protoreflect.FileDescriptor
View Source 
var File_rq_v1_scan_proto protoreflect.FileDescriptor
View Source 
var File_rq_v1_service_proto protoreflect.FileDescriptor
View Source 
var RQ_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.RQ",
	HandlerType: (*RQServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ScanSamples",
			Handler:    _RQ_ScanSamples_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _RQ_GetVersion_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rq/v1/service.proto",
}

RQ_ServiceDesc is the grpc.ServiceDesc for RQ service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRQServer 

func RegisterRQServer(s grpc.ServiceRegistrar, srv RQServer)

Types

type Data 

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
}

func (*Data) Descriptor deprecated 

func (*Data) Descriptor() ([]byte, []int)

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetData 

func (m *Data) GetData() isData_Data

func (*Data) GetLogs 

func (x *Data) GetLogs() *v11.LogsData

func (*Data) GetMetrics 

func (x *Data) GetMetrics() *v1.MetricsData

func (*Data) GetTraces 

func (x *Data) GetTraces() *v12.TracesData

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

func (x *Data) ProtoReflect() protoreflect.Message

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type Data_Logs 

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

type Data_Metrics 

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

type Data_Traces 

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

type GetVersionRequest 

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

func (*GetVersionRequest) Descriptor deprecated 

func (*GetVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect 

func (x *GetVersionRequest) ProtoReflect() protoreflect.Message

func (*GetVersionRequest) Reset 

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (x *GetVersionRequest) String() string

type Meta 

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
}

Meta stores sample metaddata.

func (*Meta) Descriptor deprecated 

func (*Meta) Descriptor() ([]byte, []int)

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetId 

func (x *Meta) GetId() []uint64

func (*Meta) GetMinTs 

func (x *Meta) GetMinTs() []uint64

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

func (x *Meta) ProtoReflect() protoreflect.Message

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type MetaInfo 

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
}

func (*MetaInfo) Descriptor deprecated 

func (*MetaInfo) Descriptor() ([]byte, []int)

Deprecated: Use MetaInfo.ProtoReflect.Descriptor instead.

func (*MetaInfo) GetId 

func (x *MetaInfo) GetId() uint64

func (*MetaInfo) GetMaxTs 

func (x *MetaInfo) GetMaxTs() uint64

func (*MetaInfo) GetMinTs 

func (x *MetaInfo) GetMinTs() uint64

func (*MetaInfo) ProtoMessage 

func (*MetaInfo) ProtoMessage()

func (*MetaInfo) ProtoReflect 

func (x *MetaInfo) ProtoReflect() protoreflect.Message

func (*MetaInfo) Reset 

func (x *MetaInfo) Reset()

func (*MetaInfo) String 

func (x *MetaInfo) String() string

type PREFIX 

type PREFIX int32
const (
	PREFIX_RESOURCE_SCHEMA     PREFIX = 0
	PREFIX_RESOURCE_ATTRIBUTES PREFIX = 1
	PREFIX_SCOPE_SCHEMA        PREFIX = 2
	PREFIX_SCOPE_NAME          PREFIX = 3
	PREFIX_SCOPE_VERSION       PREFIX = 4
	PREFIX_SCOPE_ATTRIBUTES    PREFIX = 5
	PREFIX_NAME                PREFIX = 6
	PREFIX_ATTRIBUTES          PREFIX = 7
	PREFIX_TRACE_ID            PREFIX = 8
	PREFIX_SPAN_ID             PREFIX = 9
	PREFIX_PARENT_SPAN_ID      PREFIX = 10
	PREFIX_LOGS_LEVEL          PREFIX = 11
	PREFIX_DATA                PREFIX = 12
)

func (PREFIX) Descriptor 

func (PREFIX) Descriptor() protoreflect.EnumDescriptor

func (PREFIX) Enum 

func (x PREFIX) Enum() *PREFIX

func (PREFIX) EnumDescriptor deprecated 

func (PREFIX) EnumDescriptor() ([]byte, []int)

Deprecated: Use PREFIX.Descriptor instead.

func (PREFIX) Number 

func (x PREFIX) Number() protoreflect.EnumNumber

func (PREFIX) String 

func (x PREFIX) String() string

func (PREFIX) Type 

func (PREFIX) Type() protoreflect.EnumType

type RESOURCE 

type RESOURCE int32
const (
	RESOURCE_UNKOWN    RESOURCE = 0
	RESOURCE_METRICS   RESOURCE = 1
	RESOURCE_TRACES    RESOURCE = 2
	RESOURCE_LOGS      RESOURCE = 3
	RESOURCE_SAMPLE_ID RESOURCE = 4
	RESOURCE_META      RESOURCE = 5
	RESOURCE_META_ID   RESOURCE = 6
	RESOURCE_META_INFO RESOURCE = 8
)

func (RESOURCE) Descriptor 

func (RESOURCE) Descriptor() protoreflect.EnumDescriptor

func (RESOURCE) Enum 

func (x RESOURCE) Enum() *RESOURCE

func (RESOURCE) EnumDescriptor deprecated 

func (RESOURCE) EnumDescriptor() ([]byte, []int)

Deprecated: Use RESOURCE.Descriptor instead.

func (RESOURCE) Number 

func (x RESOURCE) Number() protoreflect.EnumNumber

func (RESOURCE) String 

func (x RESOURCE) String() string

func (RESOURCE) Type 

func (RESOURCE) Type() protoreflect.EnumType

type RQClient 

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)
}

RQClient is the client API for RQ service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRQClient 

func NewRQClient(cc grpc.ClientConnInterface) RQClient

type RQServer 

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

RQServer is the server API for RQ service. All implementations must embed UnimplementedRQServer for forward compatibility

type Sample 

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
}

func (*Sample) Descriptor deprecated 

func (*Sample) Descriptor() ([]byte, []int)

Deprecated: Use Sample.ProtoReflect.Descriptor instead.

func (*Sample) GetData 

func (x *Sample) GetData() *Data

func (*Sample) GetId 

func (x *Sample) GetId() uint64

func (*Sample) GetMaxTs 

func (x *Sample) GetMaxTs() uint64

func (*Sample) GetMinTs 

func (x *Sample) GetMinTs() uint64

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect 

func (x *Sample) ProtoReflect() protoreflect.Message

func (*Sample) Reset 

func (x *Sample) Reset()

func (*Sample) String 

func (x *Sample) String() string

type Scan 

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
}

func (*Scan) Descriptor deprecated 

func (*Scan) Descriptor() ([]byte, []int)

Deprecated: Use Scan.ProtoReflect.Descriptor instead.

func (*Scan) GetFilters 

func (x *Scan) GetFilters() []*Scan_Filter

func (*Scan) GetLimit 

func (x *Scan) GetLimit() uint64

func (*Scan) GetNow 

func (x *Scan) GetNow() *timestamppb.Timestamp

func (*Scan) GetOffset 

func (x *Scan) GetOffset() *durationpb.Duration

func (*Scan) GetReverse 

func (x *Scan) GetReverse() bool

func (*Scan) GetScope 

func (x *Scan) GetScope() Scan_SCOPE

func (*Scan) GetTimeRange 

func (x *Scan) GetTimeRange() *Scan_TimeRange

func (*Scan) ProtoMessage 

func (*Scan) ProtoMessage()

func (*Scan) ProtoReflect 

func (x *Scan) ProtoReflect() protoreflect.Message

func (*Scan) Reset 

func (x *Scan) Reset()

func (*Scan) String 

func (x *Scan) String() string

type Scan_AttrFilter 

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
}

func (*Scan_AttrFilter) Descriptor deprecated 

func (*Scan_AttrFilter) Descriptor() ([]byte, []int)

Deprecated: Use Scan_AttrFilter.ProtoReflect.Descriptor instead.

func (*Scan_AttrFilter) GetKey 

func (x *Scan_AttrFilter) GetKey() string

func (*Scan_AttrFilter) GetProp 

func (x *Scan_AttrFilter) GetProp() Scan_AttributeProp

func (*Scan_AttrFilter) GetValue 

func (x *Scan_AttrFilter) GetValue() string

func (*Scan_AttrFilter) ProtoMessage 

func (*Scan_AttrFilter) ProtoMessage()

func (*Scan_AttrFilter) ProtoReflect 

func (x *Scan_AttrFilter) ProtoReflect() protoreflect.Message

func (*Scan_AttrFilter) Reset 

func (x *Scan_AttrFilter) Reset()

func (*Scan_AttrFilter) String 

func (x *Scan_AttrFilter) String() string

type Scan_AttributeProp 

type Scan_AttributeProp int32
const (
	Scan_UNKOWN_ATTR         Scan_AttributeProp = 0
	Scan_RESOURCE_ATTRIBUTES Scan_AttributeProp = 1
	Scan_SCOPE_ATTRIBUTES    Scan_AttributeProp = 5
	Scan_ATTRIBUTES          Scan_AttributeProp = 7
)

func (Scan_AttributeProp) Descriptor 

func (Scan_AttributeProp) Descriptor() protoreflect.EnumDescriptor

func (Scan_AttributeProp) Enum 

func (x Scan_AttributeProp) Enum() *Scan_AttributeProp

func (Scan_AttributeProp) EnumDescriptor deprecated 

func (Scan_AttributeProp) EnumDescriptor() ([]byte, []int)

Deprecated: Use Scan_AttributeProp.Descriptor instead.

func (Scan_AttributeProp) Number 

func (x Scan_AttributeProp) Number() protoreflect.EnumNumber

func (Scan_AttributeProp) String 

func (x Scan_AttributeProp) String() string

func (Scan_AttributeProp) Type 

func (Scan_AttributeProp) Type() protoreflect.EnumType

type Scan_BaseFilter 

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
}

func (*Scan_BaseFilter) Descriptor deprecated 

func (*Scan_BaseFilter) Descriptor() ([]byte, []int)

Deprecated: Use Scan_BaseFilter.ProtoReflect.Descriptor instead.

func (*Scan_BaseFilter) GetProp 

func (x *Scan_BaseFilter) GetProp() Scan_BaseProp

func (*Scan_BaseFilter) GetValue 

func (x *Scan_BaseFilter) GetValue() string

func (*Scan_BaseFilter) ProtoMessage 

func (*Scan_BaseFilter) ProtoMessage()

func (*Scan_BaseFilter) ProtoReflect 

func (x *Scan_BaseFilter) ProtoReflect() protoreflect.Message

func (*Scan_BaseFilter) Reset 

func (x *Scan_BaseFilter) Reset()

func (*Scan_BaseFilter) String 

func (x *Scan_BaseFilter) String() string

type Scan_BaseProp 

type Scan_BaseProp int32
const (
	Scan_RESOURCE_SCHEMA Scan_BaseProp = 0
	Scan_SCOPE_SCHEMA    Scan_BaseProp = 2
	Scan_SCOPE_NAME      Scan_BaseProp = 3
	Scan_SCOPE_VERSION   Scan_BaseProp = 4
	Scan_NAME            Scan_BaseProp = 6
	Scan_TRACE_ID        Scan_BaseProp = 8
	Scan_SPAN_ID         Scan_BaseProp = 9
	Scan_PARENT_SPAN_ID  Scan_BaseProp = 10
	Scan_LOGS_LEVEL      Scan_BaseProp = 11
)

func (Scan_BaseProp) Descriptor 

func (Scan_BaseProp) Descriptor() protoreflect.EnumDescriptor

func (Scan_BaseProp) Enum 

func (x Scan_BaseProp) Enum() *Scan_BaseProp

func (Scan_BaseProp) EnumDescriptor deprecated 

func (Scan_BaseProp) EnumDescriptor() ([]byte, []int)

Deprecated: Use Scan_BaseProp.Descriptor instead.

func (Scan_BaseProp) Number 

func (x Scan_BaseProp) Number() protoreflect.EnumNumber

func (Scan_BaseProp) String 

func (x Scan_BaseProp) String() string

func (Scan_BaseProp) Type 

func (Scan_BaseProp) Type() protoreflect.EnumType

type Scan_Filter 

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
}

func (*Scan_Filter) Descriptor deprecated 

func (*Scan_Filter) Descriptor() ([]byte, []int)

Deprecated: Use Scan_Filter.ProtoReflect.Descriptor instead.

func (*Scan_Filter) GetAttr 

func (x *Scan_Filter) GetAttr() *Scan_AttrFilter

func (*Scan_Filter) GetBase 

func (x *Scan_Filter) GetBase() *Scan_BaseFilter

func (*Scan_Filter) GetValue 

func (m *Scan_Filter) GetValue() isScan_Filter_Value

func (*Scan_Filter) ProtoMessage 

func (*Scan_Filter) ProtoMessage()

func (*Scan_Filter) ProtoReflect 

func (x *Scan_Filter) ProtoReflect() protoreflect.Message

func (*Scan_Filter) Reset 

func (x *Scan_Filter) Reset()

func (*Scan_Filter) String 

func (x *Scan_Filter) String() string

type Scan_Filter_Attr 

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

type Scan_Filter_Base 

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

type Scan_SCOPE 

type Scan_SCOPE int32
const (
	Scan_UNKOWN  Scan_SCOPE = 0
	Scan_METRICS Scan_SCOPE = 1
	Scan_TRACES  Scan_SCOPE = 2
	Scan_LOGS    Scan_SCOPE = 3
)

func (Scan_SCOPE) Descriptor 

func (Scan_SCOPE) Descriptor() protoreflect.EnumDescriptor

func (Scan_SCOPE) Enum 

func (x Scan_SCOPE) Enum() *Scan_SCOPE

func (Scan_SCOPE) EnumDescriptor deprecated 

func (Scan_SCOPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use Scan_SCOPE.Descriptor instead.

func (Scan_SCOPE) Number 

func (x Scan_SCOPE) Number() protoreflect.EnumNumber

func (Scan_SCOPE) String 

func (x Scan_SCOPE) String() string

func (Scan_SCOPE) Type 

func (Scan_SCOPE) Type() protoreflect.EnumType

type Scan_TimeRange 

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
}

func (*Scan_TimeRange) Descriptor deprecated 

func (*Scan_TimeRange) Descriptor() ([]byte, []int)

Deprecated: Use Scan_TimeRange.ProtoReflect.Descriptor instead.

func (*Scan_TimeRange) GetEnd 

func (x *Scan_TimeRange) GetEnd() *timestamppb.Timestamp

func (*Scan_TimeRange) GetStart 

func (x *Scan_TimeRange) GetStart() *timestamppb.Timestamp

func (*Scan_TimeRange) ProtoMessage 

func (*Scan_TimeRange) ProtoMessage()

func (*Scan_TimeRange) ProtoReflect 

func (x *Scan_TimeRange) ProtoReflect() protoreflect.Message

func (*Scan_TimeRange) Reset 

func (x *Scan_TimeRange) Reset()

func (*Scan_TimeRange) String 

func (x *Scan_TimeRange) String() string

type UnimplementedRQServer 

type UnimplementedRQServer struct {
}

UnimplementedRQServer must be embedded to have forward compatible implementations.

func (UnimplementedRQServer) GetVersion 

func (UnimplementedRQServer) GetVersion(context.Context, *GetVersionRequest) (*Version, error)

func (UnimplementedRQServer) ScanSamples 

func (UnimplementedRQServer) ScanSamples(context.Context, *Scan) (*Data, error)

type UnsafeRQServer 

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

UnsafeRQServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RQServer will result in compilation errors.

type Version 

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

func (*Version) Descriptor deprecated 

func (*Version) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetVersion 

func (x *Version) GetVersion() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.