v1

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2022 License: Apache-2.0 Imports: 18 Imported by: 9

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var DataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "viam.app.data.v1.DataService",
	HandlerType: (*DataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TabularDataByFilter",
			Handler:    _DataService_TabularDataByFilter_Handler,
		},
		{
			MethodName: "BinaryDataByFilter",
			Handler:    _DataService_BinaryDataByFilter_Handler,
		},
		{
			MethodName: "BinaryDataByIDs",
			Handler:    _DataService_BinaryDataByIDs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "app/data/v1/data.proto",
}

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

View Source 
var File_app_data_v1_data_proto protoreflect.FileDescriptor

Functions

func RegisterDataServiceHandler 

func RegisterDataServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDataServiceHandler registers the http handlers for service DataService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDataServiceHandlerClient 

func RegisterDataServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataServiceClient) error

RegisterDataServiceHandlerClient registers the http handlers for service DataService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DataServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DataServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DataServiceClient" to call the correct interceptors.

func RegisterDataServiceHandlerFromEndpoint 

func RegisterDataServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDataServiceHandlerFromEndpoint is same as RegisterDataServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDataServiceHandlerServer 

func RegisterDataServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataServiceServer) error

RegisterDataServiceHandlerServer registers the http handlers for service DataService to "mux". UnaryRPC :call DataServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDataServiceHandlerFromEndpoint instead.

func RegisterDataServiceServer 

func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer)

Types

type BinaryData 

type BinaryData struct {
	Binary   []byte          `protobuf:"bytes,1,opt,name=binary,proto3" json:"binary,omitempty"`
	Metadata *BinaryMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryData) Descriptor deprecated 

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

Deprecated: Use BinaryData.ProtoReflect.Descriptor instead.

func (*BinaryData) GetBinary 

func (x *BinaryData) GetBinary() []byte

func (*BinaryData) GetMetadata added in v0.1.3 

func (x *BinaryData) GetMetadata() *BinaryMetadata

func (*BinaryData) ProtoMessage 

func (*BinaryData) ProtoMessage()

func (*BinaryData) ProtoReflect 

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

func (*BinaryData) Reset 

func (x *BinaryData) Reset()

func (*BinaryData) String 

func (x *BinaryData) String() string

type BinaryDataByFilterRequest 

type BinaryDataByFilterRequest struct {
	DataRequest   *DataRequest `protobuf:"bytes,1,opt,name=data_request,json=dataRequest,proto3" json:"data_request,omitempty"`
	IncludeBinary bool         `protobuf:"varint,2,opt,name=include_binary,json=includeBinary,proto3" json:"include_binary,omitempty"`
	CountOnly     bool         `protobuf:"varint,3,opt,name=count_only,json=countOnly,proto3" json:"count_only,omitempty"`
	// contains filtered or unexported fields
}

BinaryDataByFilterRequest requests the data and metadata of binary (image + file) data when by filter

func (*BinaryDataByFilterRequest) Descriptor deprecated 

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

Deprecated: Use BinaryDataByFilterRequest.ProtoReflect.Descriptor instead.

func (*BinaryDataByFilterRequest) GetCountOnly 

func (x *BinaryDataByFilterRequest) GetCountOnly() bool

func (*BinaryDataByFilterRequest) GetDataRequest 

func (x *BinaryDataByFilterRequest) GetDataRequest() *DataRequest

func (*BinaryDataByFilterRequest) GetIncludeBinary 

func (x *BinaryDataByFilterRequest) GetIncludeBinary() bool

func (*BinaryDataByFilterRequest) ProtoMessage 

func (*BinaryDataByFilterRequest) ProtoMessage()

func (*BinaryDataByFilterRequest) ProtoReflect 

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

func (*BinaryDataByFilterRequest) Reset 

func (x *BinaryDataByFilterRequest) Reset()

func (*BinaryDataByFilterRequest) String 

func (x *BinaryDataByFilterRequest) String() string

type BinaryDataByFilterResponse 

type BinaryDataByFilterResponse struct {
	Data  []*BinaryData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Count int64         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

BinaryDataByFilterResponse provides the data and metadata of binary (image + file) data when a filter is provided

func (*BinaryDataByFilterResponse) Descriptor deprecated 

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

Deprecated: Use BinaryDataByFilterResponse.ProtoReflect.Descriptor instead.

func (*BinaryDataByFilterResponse) GetCount 

func (x *BinaryDataByFilterResponse) GetCount() int64

func (*BinaryDataByFilterResponse) GetData 

func (x *BinaryDataByFilterResponse) GetData() []*BinaryData

func (*BinaryDataByFilterResponse) ProtoMessage 

func (*BinaryDataByFilterResponse) ProtoMessage()

func (*BinaryDataByFilterResponse) ProtoReflect 

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

func (*BinaryDataByFilterResponse) Reset 

func (x *BinaryDataByFilterResponse) Reset()

func (*BinaryDataByFilterResponse) String 

func (x *BinaryDataByFilterResponse) String() string

type BinaryDataByIDsRequest 

type BinaryDataByIDsRequest struct {
	FileIds       []string `protobuf:"bytes,1,rep,name=file_ids,json=fileIds,proto3" json:"file_ids,omitempty"`
	IncludeBinary bool     `protobuf:"varint,2,opt,name=include_binary,json=includeBinary,proto3" json:"include_binary,omitempty"` // by default
	// contains filtered or unexported fields
}

BinaryDataByFilterRequest requests the data and metadata of binary (image + file) data by file ids

func (*BinaryDataByIDsRequest) Descriptor deprecated 

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

Deprecated: Use BinaryDataByIDsRequest.ProtoReflect.Descriptor instead.

func (*BinaryDataByIDsRequest) GetFileIds 

func (x *BinaryDataByIDsRequest) GetFileIds() []string

func (*BinaryDataByIDsRequest) GetIncludeBinary 

func (x *BinaryDataByIDsRequest) GetIncludeBinary() bool

func (*BinaryDataByIDsRequest) ProtoMessage 

func (*BinaryDataByIDsRequest) ProtoMessage()

func (*BinaryDataByIDsRequest) ProtoReflect 

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

func (*BinaryDataByIDsRequest) Reset 

func (x *BinaryDataByIDsRequest) Reset()

func (*BinaryDataByIDsRequest) String 

func (x *BinaryDataByIDsRequest) String() string

type BinaryDataByIDsResponse 

type BinaryDataByIDsResponse struct {
	Data  []*BinaryData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Count int64         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

BinaryDataByIDsResponse provides the data and metadata of binary (image + file) data when a filter is provided

func (*BinaryDataByIDsResponse) Descriptor deprecated 

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

Deprecated: Use BinaryDataByIDsResponse.ProtoReflect.Descriptor instead.

func (*BinaryDataByIDsResponse) GetCount 

func (x *BinaryDataByIDsResponse) GetCount() int64

func (*BinaryDataByIDsResponse) GetData 

func (x *BinaryDataByIDsResponse) GetData() []*BinaryData

func (*BinaryDataByIDsResponse) ProtoMessage 

func (*BinaryDataByIDsResponse) ProtoMessage()

func (*BinaryDataByIDsResponse) ProtoReflect 

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

func (*BinaryDataByIDsResponse) Reset 

func (x *BinaryDataByIDsResponse) Reset()

func (*BinaryDataByIDsResponse) String 

func (x *BinaryDataByIDsResponse) String() string

type BinaryMetadata added in v0.1.3 

type BinaryMetadata struct {
	Id              string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CaptureMetadata *CaptureMetadata       `protobuf:"bytes,2,opt,name=capture_metadata,json=captureMetadata,proto3" json:"capture_metadata,omitempty"`
	TimeRequested   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time_requested,json=timeRequested,proto3" json:"time_requested,omitempty"`
	TimeReceived    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time_received,json=timeReceived,proto3" json:"time_received,omitempty"`
	FileName        string                 `protobuf:"bytes,5,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	FileExt         string                 `protobuf:"bytes,6,opt,name=file_ext,json=fileExt,proto3" json:"file_ext,omitempty"`
	Uri             string                 `protobuf:"bytes,7,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryMetadata) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use BinaryMetadata.ProtoReflect.Descriptor instead.

func (*BinaryMetadata) GetCaptureMetadata added in v0.1.3 

func (x *BinaryMetadata) GetCaptureMetadata() *CaptureMetadata

func (*BinaryMetadata) GetFileExt added in v0.1.3 

func (x *BinaryMetadata) GetFileExt() string

func (*BinaryMetadata) GetFileName added in v0.1.3 

func (x *BinaryMetadata) GetFileName() string

func (*BinaryMetadata) GetId added in v0.1.3 

func (x *BinaryMetadata) GetId() string

func (*BinaryMetadata) GetTimeReceived added in v0.1.3 

func (x *BinaryMetadata) GetTimeReceived() *timestamppb.Timestamp

func (*BinaryMetadata) GetTimeRequested added in v0.1.3 

func (x *BinaryMetadata) GetTimeRequested() *timestamppb.Timestamp

func (*BinaryMetadata) GetUri added in v0.1.3 

func (x *BinaryMetadata) GetUri() string

func (*BinaryMetadata) ProtoMessage added in v0.1.3 

func (*BinaryMetadata) ProtoMessage()

func (*BinaryMetadata) ProtoReflect added in v0.1.3 

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

func (*BinaryMetadata) Reset added in v0.1.3 

func (x *BinaryMetadata) Reset()

func (*BinaryMetadata) String added in v0.1.3 

func (x *BinaryMetadata) String() string

type CaptureInterval 

type CaptureInterval 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
}

CaptureInterval describes the start and end time of the capture in this file

func (*CaptureInterval) Descriptor deprecated 

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

Deprecated: Use CaptureInterval.ProtoReflect.Descriptor instead.

func (*CaptureInterval) GetEnd 

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

func (*CaptureInterval) GetStart 

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

func (*CaptureInterval) ProtoMessage 

func (*CaptureInterval) ProtoMessage()

func (*CaptureInterval) ProtoReflect 

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

func (*CaptureInterval) Reset 

func (x *CaptureInterval) Reset()

func (*CaptureInterval) String 

func (x *CaptureInterval) String() string

type CaptureMetadata 

type CaptureMetadata struct {
	OrgId            string                `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	LocationId       string                `protobuf:"bytes,2,opt,name=location_id,json=locationId,proto3" json:"location_id,omitempty"`
	RobotName        string                `protobuf:"bytes,3,opt,name=robot_name,json=robotName,proto3" json:"robot_name,omitempty"`
	RobotId          string                `protobuf:"bytes,4,opt,name=robot_id,json=robotId,proto3" json:"robot_id,omitempty"`
	PartName         string                `protobuf:"bytes,5,opt,name=part_name,json=partName,proto3" json:"part_name,omitempty"`
	PartId           string                `protobuf:"bytes,6,opt,name=part_id,json=partId,proto3" json:"part_id,omitempty"`
	ComponentType    string                `protobuf:"bytes,7,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"`
	ComponentModel   string                `protobuf:"bytes,8,opt,name=component_model,json=componentModel,proto3" json:"component_model,omitempty"`
	ComponentName    string                `protobuf:"bytes,9,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	MethodName       string                `protobuf:"bytes,10,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	MethodParameters map[string]*anypb.Any `` /* 198-byte string literal not displayed */
	Tags             []string              `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
	MimeType         string                `protobuf:"bytes,13,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
	// contains filtered or unexported fields
}

CaptureMetadata contains information on the settings used for the data capture

func (*CaptureMetadata) Descriptor deprecated 

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

Deprecated: Use CaptureMetadata.ProtoReflect.Descriptor instead.

func (*CaptureMetadata) GetComponentModel 

func (x *CaptureMetadata) GetComponentModel() string

func (*CaptureMetadata) GetComponentName 

func (x *CaptureMetadata) GetComponentName() string

func (*CaptureMetadata) GetComponentType 

func (x *CaptureMetadata) GetComponentType() string

func (*CaptureMetadata) GetLocationId 

func (x *CaptureMetadata) GetLocationId() string

func (*CaptureMetadata) GetMethodName 

func (x *CaptureMetadata) GetMethodName() string

func (*CaptureMetadata) GetMethodParameters 

func (x *CaptureMetadata) GetMethodParameters() map[string]*anypb.Any

func (*CaptureMetadata) GetMimeType 

func (x *CaptureMetadata) GetMimeType() string

func (*CaptureMetadata) GetOrgId added in v0.1.1 

func (x *CaptureMetadata) GetOrgId() string

func (*CaptureMetadata) GetPartId 

func (x *CaptureMetadata) GetPartId() string

func (*CaptureMetadata) GetPartName 

func (x *CaptureMetadata) GetPartName() string

func (*CaptureMetadata) GetRobotId 

func (x *CaptureMetadata) GetRobotId() string

func (*CaptureMetadata) GetRobotName 

func (x *CaptureMetadata) GetRobotName() string

func (*CaptureMetadata) GetTags 

func (x *CaptureMetadata) GetTags() []string

func (*CaptureMetadata) ProtoMessage 

func (*CaptureMetadata) ProtoMessage()

func (*CaptureMetadata) ProtoReflect 

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

func (*CaptureMetadata) Reset 

func (x *CaptureMetadata) Reset()

func (*CaptureMetadata) String 

func (x *CaptureMetadata) String() string

type DataRequest 

type DataRequest struct {
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Skip   int64   `protobuf:"varint,2,opt,name=skip,proto3" json:"skip,omitempty"`
	Limit  int64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DataRequest) Descriptor deprecated 

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

Deprecated: Use DataRequest.ProtoReflect.Descriptor instead.

func (*DataRequest) GetFilter 

func (x *DataRequest) GetFilter() *Filter

func (*DataRequest) GetLimit 

func (x *DataRequest) GetLimit() int64

func (*DataRequest) GetSkip 

func (x *DataRequest) GetSkip() int64

func (*DataRequest) ProtoMessage 

func (*DataRequest) ProtoMessage()

func (*DataRequest) ProtoReflect 

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

func (*DataRequest) Reset 

func (x *DataRequest) Reset()

func (*DataRequest) String 

func (x *DataRequest) String() string

type DataServiceClient 

type DataServiceClient interface {
	// TabularDataByFilter queries tabular data and metadata based on given filters.
	TabularDataByFilter(ctx context.Context, in *TabularDataByFilterRequest, opts ...grpc.CallOption) (*TabularDataByFilterResponse, error)
	// BinaryDataByFilter queries binary data and metadata based on given filters.
	BinaryDataByFilter(ctx context.Context, in *BinaryDataByFilterRequest, opts ...grpc.CallOption) (*BinaryDataByFilterResponse, error)
	// BinaryDataByIDs queries binary data and metadata based on given IDs.
	BinaryDataByIDs(ctx context.Context, in *BinaryDataByIDsRequest, opts ...grpc.CallOption) (*BinaryDataByIDsResponse, error)
}

DataServiceClient is the client API for DataService 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 NewDataServiceClient 

func NewDataServiceClient(cc grpc.ClientConnInterface) DataServiceClient

type DataServiceServer 

type DataServiceServer interface {
	// TabularDataByFilter queries tabular data and metadata based on given filters.
	TabularDataByFilter(context.Context, *TabularDataByFilterRequest) (*TabularDataByFilterResponse, error)
	// BinaryDataByFilter queries binary data and metadata based on given filters.
	BinaryDataByFilter(context.Context, *BinaryDataByFilterRequest) (*BinaryDataByFilterResponse, error)
	// BinaryDataByIDs queries binary data and metadata based on given IDs.
	BinaryDataByIDs(context.Context, *BinaryDataByIDsRequest) (*BinaryDataByIDsResponse, error)
	// contains filtered or unexported methods
}

DataServiceServer is the server API for DataService service. All implementations must embed UnimplementedDataServiceServer for forward compatibility

type Filter 

type Filter struct {
	ComponentName  string           `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	ComponentType  string           `protobuf:"bytes,2,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"`
	ComponentModel string           `protobuf:"bytes,3,opt,name=component_model,json=componentModel,proto3" json:"component_model,omitempty"`
	Method         string           `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Tags           []string         `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	RobotName      string           `protobuf:"bytes,6,opt,name=robot_name,json=robotName,proto3" json:"robot_name,omitempty"`
	RobotId        string           `protobuf:"bytes,7,opt,name=robot_id,json=robotId,proto3" json:"robot_id,omitempty"`
	PartName       string           `protobuf:"bytes,8,opt,name=part_name,json=partName,proto3" json:"part_name,omitempty"`
	PartId         string           `protobuf:"bytes,9,opt,name=part_id,json=partId,proto3" json:"part_id,omitempty"`
	LocationId     string           `protobuf:"bytes,10,opt,name=location_id,json=locationId,proto3" json:"location_id,omitempty"`
	OrgIds         []string         `protobuf:"bytes,11,rep,name=org_ids,json=orgIds,proto3" json:"org_ids,omitempty"`
	MimeType       []string         `protobuf:"bytes,12,rep,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
	Interval       *CaptureInterval `protobuf:"bytes,13,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetComponentModel 

func (x *Filter) GetComponentModel() string

func (*Filter) GetComponentName 

func (x *Filter) GetComponentName() string

func (*Filter) GetComponentType 

func (x *Filter) GetComponentType() string

func (*Filter) GetInterval 

func (x *Filter) GetInterval() *CaptureInterval

func (*Filter) GetLocationId 

func (x *Filter) GetLocationId() string

func (*Filter) GetMethod 

func (x *Filter) GetMethod() string

func (*Filter) GetMimeType 

func (x *Filter) GetMimeType() []string

func (*Filter) GetOrgIds added in v0.1.2 

func (x *Filter) GetOrgIds() []string

func (*Filter) GetPartId 

func (x *Filter) GetPartId() string

func (*Filter) GetPartName 

func (x *Filter) GetPartName() string

func (*Filter) GetRobotId 

func (x *Filter) GetRobotId() string

func (*Filter) GetRobotName 

func (x *Filter) GetRobotName() string

func (*Filter) GetTags 

func (x *Filter) GetTags() []string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type TabularData 

type TabularData struct {
	Data          *structpb.Struct       `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	MetadataIndex int32                  `protobuf:"varint,2,opt,name=metadata_index,json=metadataIndex,proto3" json:"metadata_index,omitempty"`
	TimeRequested *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time_requested,json=timeRequested,proto3" json:"time_requested,omitempty"`
	TimeReceived  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time_received,json=timeReceived,proto3" json:"time_received,omitempty"`
	// contains filtered or unexported fields
}

func (*TabularData) Descriptor deprecated 

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

Deprecated: Use TabularData.ProtoReflect.Descriptor instead.

func (*TabularData) GetData 

func (x *TabularData) GetData() *structpb.Struct

func (*TabularData) GetMetadataIndex added in v0.1.1 

func (x *TabularData) GetMetadataIndex() int32

func (*TabularData) GetTimeReceived added in v0.1.1 

func (x *TabularData) GetTimeReceived() *timestamppb.Timestamp

func (*TabularData) GetTimeRequested added in v0.1.1 

func (x *TabularData) GetTimeRequested() *timestamppb.Timestamp

func (*TabularData) ProtoMessage 

func (*TabularData) ProtoMessage()

func (*TabularData) ProtoReflect 

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

func (*TabularData) Reset 

func (x *TabularData) Reset()

func (*TabularData) String 

func (x *TabularData) String() string

type TabularDataByFilterRequest 

type TabularDataByFilterRequest struct {
	DataRequest *DataRequest `protobuf:"bytes,1,opt,name=data_request,json=dataRequest,proto3" json:"data_request,omitempty"`
	CountOnly   bool         `protobuf:"varint,2,opt,name=count_only,json=countOnly,proto3" json:"count_only,omitempty"`
	// contains filtered or unexported fields
}

TabularDataByFilterRequest requests tabular data based on filter values

func (*TabularDataByFilterRequest) Descriptor deprecated 

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

Deprecated: Use TabularDataByFilterRequest.ProtoReflect.Descriptor instead.

func (*TabularDataByFilterRequest) GetCountOnly 

func (x *TabularDataByFilterRequest) GetCountOnly() bool

func (*TabularDataByFilterRequest) GetDataRequest 

func (x *TabularDataByFilterRequest) GetDataRequest() *DataRequest

func (*TabularDataByFilterRequest) ProtoMessage 

func (*TabularDataByFilterRequest) ProtoMessage()

func (*TabularDataByFilterRequest) ProtoReflect 

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

func (*TabularDataByFilterRequest) Reset 

func (x *TabularDataByFilterRequest) Reset()

func (*TabularDataByFilterRequest) String 

func (x *TabularDataByFilterRequest) String() string

type TabularDataByFilterResponse 

type TabularDataByFilterResponse struct {
	Metadata []*CaptureMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	Data     []*TabularData     `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	Count    int64              `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

TabularDataByFilterResponse provides the data and metadata of tabular data

func (*TabularDataByFilterResponse) Descriptor deprecated 

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

Deprecated: Use TabularDataByFilterResponse.ProtoReflect.Descriptor instead.

func (*TabularDataByFilterResponse) GetCount 

func (x *TabularDataByFilterResponse) GetCount() int64

func (*TabularDataByFilterResponse) GetData 

func (x *TabularDataByFilterResponse) GetData() []*TabularData

func (*TabularDataByFilterResponse) GetMetadata 

func (x *TabularDataByFilterResponse) GetMetadata() []*CaptureMetadata

func (*TabularDataByFilterResponse) ProtoMessage 

func (*TabularDataByFilterResponse) ProtoMessage()

func (*TabularDataByFilterResponse) ProtoReflect 

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

func (*TabularDataByFilterResponse) Reset 

func (x *TabularDataByFilterResponse) Reset()

func (*TabularDataByFilterResponse) String 

func (x *TabularDataByFilterResponse) String() string

type UnimplementedDataServiceServer 

type UnimplementedDataServiceServer struct {
}

UnimplementedDataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataServiceServer) BinaryDataByFilter 

func (UnimplementedDataServiceServer) BinaryDataByFilter(context.Context, *BinaryDataByFilterRequest) (*BinaryDataByFilterResponse, error)

func (UnimplementedDataServiceServer) BinaryDataByIDs 

func (UnimplementedDataServiceServer) BinaryDataByIDs(context.Context, *BinaryDataByIDsRequest) (*BinaryDataByIDsResponse, error)

func (UnimplementedDataServiceServer) TabularDataByFilter 

func (UnimplementedDataServiceServer) TabularDataByFilter(context.Context, *TabularDataByFilterRequest) (*TabularDataByFilterResponse, error)

type UnsafeDataServiceServer 

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

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

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.