Documentation
¶
Overview ¶
Package v1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterDataServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterDataServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataServiceClient) error
- func RegisterDataServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterDataServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataServiceServer) error
- func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer)
- type BinaryData
- func (*BinaryData) Descriptor() ([]byte, []int)deprecated
- func (x *BinaryData) GetBinary() []byte
- func (x *BinaryData) GetId() string
- func (x *BinaryData) GetUri() string
- func (*BinaryData) ProtoMessage()
- func (x *BinaryData) ProtoReflect() protoreflect.Message
- func (x *BinaryData) Reset()
- func (x *BinaryData) String() string
- type BinaryDataByFilterRequest
- func (*BinaryDataByFilterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BinaryDataByFilterRequest) GetCountOnly() bool
- func (x *BinaryDataByFilterRequest) GetDataRequest() *DataRequest
- func (x *BinaryDataByFilterRequest) GetIncludeBinary() bool
- func (*BinaryDataByFilterRequest) ProtoMessage()
- func (x *BinaryDataByFilterRequest) ProtoReflect() protoreflect.Message
- func (x *BinaryDataByFilterRequest) Reset()
- func (x *BinaryDataByFilterRequest) String() string
- type BinaryDataByFilterResponse
- func (*BinaryDataByFilterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BinaryDataByFilterResponse) GetCount() int64
- func (x *BinaryDataByFilterResponse) GetData() []*BinaryData
- func (x *BinaryDataByFilterResponse) GetMetadata() []*CaptureMetadata
- func (*BinaryDataByFilterResponse) ProtoMessage()
- func (x *BinaryDataByFilterResponse) ProtoReflect() protoreflect.Message
- func (x *BinaryDataByFilterResponse) Reset()
- func (x *BinaryDataByFilterResponse) String() string
- type BinaryDataByIDsRequest
- func (*BinaryDataByIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BinaryDataByIDsRequest) GetFileIds() []string
- func (x *BinaryDataByIDsRequest) GetIncludeBinary() bool
- func (*BinaryDataByIDsRequest) ProtoMessage()
- func (x *BinaryDataByIDsRequest) ProtoReflect() protoreflect.Message
- func (x *BinaryDataByIDsRequest) Reset()
- func (x *BinaryDataByIDsRequest) String() string
- type BinaryDataByIDsResponse
- func (*BinaryDataByIDsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BinaryDataByIDsResponse) GetCount() int64
- func (x *BinaryDataByIDsResponse) GetData() []*BinaryData
- func (x *BinaryDataByIDsResponse) GetMetadata() []*CaptureMetadata
- func (*BinaryDataByIDsResponse) ProtoMessage()
- func (x *BinaryDataByIDsResponse) ProtoReflect() protoreflect.Message
- func (x *BinaryDataByIDsResponse) Reset()
- func (x *BinaryDataByIDsResponse) String() string
- type CaptureInterval
- func (*CaptureInterval) Descriptor() ([]byte, []int)deprecated
- func (x *CaptureInterval) GetEnd() *timestamppb.Timestamp
- func (x *CaptureInterval) GetStart() *timestamppb.Timestamp
- func (*CaptureInterval) ProtoMessage()
- func (x *CaptureInterval) ProtoReflect() protoreflect.Message
- func (x *CaptureInterval) Reset()
- func (x *CaptureInterval) String() string
- type CaptureMetadata
- func (*CaptureMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CaptureMetadata) GetComponentModel() string
- func (x *CaptureMetadata) GetComponentName() string
- func (x *CaptureMetadata) GetComponentType() string
- func (x *CaptureMetadata) GetFileId() string
- func (x *CaptureMetadata) GetLocationId() string
- func (x *CaptureMetadata) GetMethodName() string
- func (x *CaptureMetadata) GetMethodParameters() map[string]*anypb.Any
- func (x *CaptureMetadata) GetMimeType() string
- func (x *CaptureMetadata) GetPartId() string
- func (x *CaptureMetadata) GetPartName() string
- func (x *CaptureMetadata) GetRobotId() string
- func (x *CaptureMetadata) GetRobotName() string
- func (x *CaptureMetadata) GetTags() []string
- func (x *CaptureMetadata) GetTimeReceived() *timestamppb.Timestamp
- func (x *CaptureMetadata) GetTimeRequested() *timestamppb.Timestamp
- func (*CaptureMetadata) ProtoMessage()
- func (x *CaptureMetadata) ProtoReflect() protoreflect.Message
- func (x *CaptureMetadata) Reset()
- func (x *CaptureMetadata) String() string
- type DataRequest
- func (*DataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DataRequest) GetFilter() *Filter
- func (x *DataRequest) GetLimit() int32
- func (x *DataRequest) GetSkip() int32
- func (*DataRequest) ProtoMessage()
- func (x *DataRequest) ProtoReflect() protoreflect.Message
- func (x *DataRequest) Reset()
- func (x *DataRequest) String() string
- type DataServiceClient
- type DataServiceServer
- type DataService_BinaryDataByFilterClient
- type DataService_BinaryDataByFilterServer
- type DataService_BinaryDataByIDsClient
- type DataService_BinaryDataByIDsServer
- type DataService_TabularDataByFilterClient
- type DataService_TabularDataByFilterServer
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)deprecated
- func (x *Filter) GetComponentModel() string
- func (x *Filter) GetComponentName() string
- func (x *Filter) GetComponentType() string
- func (x *Filter) GetInterval() *CaptureInterval
- func (x *Filter) GetLocationId() string
- func (x *Filter) GetMethod() string
- func (x *Filter) GetMimeType() string
- func (x *Filter) GetOrgId() string
- func (x *Filter) GetPartId() string
- func (x *Filter) GetPartName() string
- func (x *Filter) GetRobotId() string
- func (x *Filter) GetRobotName() string
- func (x *Filter) GetTags() []string
- func (*Filter) ProtoMessage()
- func (x *Filter) ProtoReflect() protoreflect.Message
- func (x *Filter) Reset()
- func (x *Filter) String() string
- type TabularData
- type TabularDataByFilterRequest
- func (*TabularDataByFilterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TabularDataByFilterRequest) GetCountOnly() bool
- func (x *TabularDataByFilterRequest) GetDataRequest() *DataRequest
- func (*TabularDataByFilterRequest) ProtoMessage()
- func (x *TabularDataByFilterRequest) ProtoReflect() protoreflect.Message
- func (x *TabularDataByFilterRequest) Reset()
- func (x *TabularDataByFilterRequest) String() string
- type TabularDataByFilterResponse
- func (*TabularDataByFilterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TabularDataByFilterResponse) GetCount() int64
- func (x *TabularDataByFilterResponse) GetData() []*TabularData
- func (x *TabularDataByFilterResponse) GetMetadata() []*CaptureMetadata
- func (*TabularDataByFilterResponse) ProtoMessage()
- func (x *TabularDataByFilterResponse) ProtoReflect() protoreflect.Message
- func (x *TabularDataByFilterResponse) Reset()
- func (x *TabularDataByFilterResponse) String() string
- type UnimplementedDataServiceServer
- func (UnimplementedDataServiceServer) BinaryDataByFilter(*BinaryDataByFilterRequest, DataService_BinaryDataByFilterServer) error
- func (UnimplementedDataServiceServer) BinaryDataByIDs(*BinaryDataByIDsRequest, DataService_BinaryDataByIDsServer) error
- func (UnimplementedDataServiceServer) TabularDataByFilter(*TabularDataByFilterRequest, DataService_TabularDataByFilterServer) error
- type UnsafeDataServiceServer
Constants ¶
This section is empty.
Variables ¶
var DataService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "viam.app.data.v1.DataService", HandlerType: (*DataServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "TabularDataByFilter", Handler: _DataService_TabularDataByFilter_Handler, ServerStreams: true, }, { StreamName: "BinaryDataByFilter", Handler: _DataService_BinaryDataByFilter_Handler, ServerStreams: true, }, { StreamName: "BinaryDataByIDs", Handler: _DataService_BinaryDataByIDs_Handler, ServerStreams: true, }, }, 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)
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 { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Uri string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"` Binary []byte `protobuf:"bytes,3,opt,name=binary,proto3" json:"binary,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) GetId ¶
func (x *BinaryData) GetId() string
func (*BinaryData) GetUri ¶
func (x *BinaryData) GetUri() string
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 { Metadata []*CaptureMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"` Data []*BinaryData `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 }
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) GetMetadata ¶
func (x *BinaryDataByFilterResponse) GetMetadata() []*CaptureMetadata
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 { Metadata []*CaptureMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"` Data []*BinaryData `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 }
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) GetMetadata ¶
func (x *BinaryDataByIDsResponse) GetMetadata() []*CaptureMetadata
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 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 { LocationId string `protobuf:"bytes,1,opt,name=location_id,json=locationId,proto3" json:"location_id,omitempty"` RobotName string `protobuf:"bytes,2,opt,name=robot_name,json=robotName,proto3" json:"robot_name,omitempty"` RobotId string `protobuf:"bytes,3,opt,name=robot_id,json=robotId,proto3" json:"robot_id,omitempty"` PartName string `protobuf:"bytes,4,opt,name=part_name,json=partName,proto3" json:"part_name,omitempty"` PartId string `protobuf:"bytes,5,opt,name=part_id,json=partId,proto3" json:"part_id,omitempty"` ComponentType string `protobuf:"bytes,6,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"` ComponentModel string `protobuf:"bytes,7,opt,name=component_model,json=componentModel,proto3" json:"component_model,omitempty"` ComponentName string `protobuf:"bytes,8,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"` MethodName string `protobuf:"bytes,9,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,11,rep,name=tags,proto3" json:"tags,omitempty"` TimeRequested *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=time_requested,json=timeRequested,proto3" json:"time_requested,omitempty"` TimeReceived *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=time_received,json=timeReceived,proto3" json:"time_received,omitempty"` MimeType string `protobuf:"bytes,14,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"` FileId string `protobuf:"bytes,15,opt,name=file_id,json=fileId,proto3" json:"file_id,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) GetFileId ¶
func (x *CaptureMetadata) GetFileId() 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) 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) GetTimeReceived ¶
func (x *CaptureMetadata) GetTimeReceived() *timestamppb.Timestamp
func (*CaptureMetadata) GetTimeRequested ¶
func (x *CaptureMetadata) GetTimeRequested() *timestamppb.Timestamp
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 int32 `protobuf:"varint,2,opt,name=skip,proto3" json:"skip,omitempty"` Limit int32 `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() int32
func (*DataRequest) GetSkip ¶
func (x *DataRequest) GetSkip() int32
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) (DataService_TabularDataByFilterClient, error) // BinaryDataByFilter queries binary data and metadata based on given filters. BinaryDataByFilter(ctx context.Context, in *BinaryDataByFilterRequest, opts ...grpc.CallOption) (DataService_BinaryDataByFilterClient, error) // BinaryDataByIDs queries binary data and metadata based on given IDs. BinaryDataByIDs(ctx context.Context, in *BinaryDataByIDsRequest, opts ...grpc.CallOption) (DataService_BinaryDataByIDsClient, 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(*TabularDataByFilterRequest, DataService_TabularDataByFilterServer) error // BinaryDataByFilter queries binary data and metadata based on given filters. BinaryDataByFilter(*BinaryDataByFilterRequest, DataService_BinaryDataByFilterServer) error // BinaryDataByIDs queries binary data and metadata based on given IDs. BinaryDataByIDs(*BinaryDataByIDsRequest, DataService_BinaryDataByIDsServer) error // contains filtered or unexported methods }
DataServiceServer is the server API for DataService service. All implementations must embed UnimplementedDataServiceServer for forward compatibility
type DataService_BinaryDataByFilterClient ¶
type DataService_BinaryDataByFilterClient interface { Recv() (*BinaryDataByFilterResponse, error) grpc.ClientStream }
type DataService_BinaryDataByFilterServer ¶
type DataService_BinaryDataByFilterServer interface { Send(*BinaryDataByFilterResponse) error grpc.ServerStream }
type DataService_BinaryDataByIDsClient ¶
type DataService_BinaryDataByIDsClient interface { Recv() (*BinaryDataByIDsResponse, error) grpc.ClientStream }
type DataService_BinaryDataByIDsServer ¶
type DataService_BinaryDataByIDsServer interface { Send(*BinaryDataByIDsResponse) error grpc.ServerStream }
type DataService_TabularDataByFilterClient ¶
type DataService_TabularDataByFilterClient interface { Recv() (*TabularDataByFilterResponse, error) grpc.ClientStream }
type DataService_TabularDataByFilterServer ¶
type DataService_TabularDataByFilterServer interface { Send(*TabularDataByFilterResponse) error grpc.ServerStream }
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"` OrgId string `protobuf:"bytes,11,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` MimeType string `protobuf:"bytes,12,opt,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) GetComponentModel ¶
func (*Filter) GetComponentName ¶
func (*Filter) GetComponentType ¶
func (*Filter) GetInterval ¶
func (x *Filter) GetInterval() *CaptureInterval
func (*Filter) GetLocationId ¶
func (*Filter) GetMimeType ¶
func (*Filter) GetPartName ¶
func (*Filter) GetRobotId ¶
func (*Filter) GetRobotName ¶
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type TabularData ¶
type TabularData struct { Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,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) 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(*BinaryDataByFilterRequest, DataService_BinaryDataByFilterServer) error
func (UnimplementedDataServiceServer) BinaryDataByIDs ¶
func (UnimplementedDataServiceServer) BinaryDataByIDs(*BinaryDataByIDsRequest, DataService_BinaryDataByIDsServer) error
func (UnimplementedDataServiceServer) TabularDataByFilter ¶
func (UnimplementedDataServiceServer) TabularDataByFilter(*TabularDataByFilterRequest, DataService_TabularDataByFilterServer) 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.