v1

package
v0.1.57 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2023 License: Apache-2.0 Imports: 19 Imported by: 8

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 (
	DataType_name = map[int32]string{
		0: "DATA_TYPE_UNSPECIFIED",
		1: "DATA_TYPE_BINARY_SENSOR",
		2: "DATA_TYPE_TABULAR_SENSOR",
		3: "DATA_TYPE_FILE",
	}
	DataType_value = map[string]int32{
		"DATA_TYPE_UNSPECIFIED":    0,
		"DATA_TYPE_BINARY_SENSOR":  1,
		"DATA_TYPE_TABULAR_SENSOR": 2,
		"DATA_TYPE_FILE":           3,
	}
)

Enum value maps for DataType.

View Source 
var DataSyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "viam.app.datasync.v1.DataSyncService",
	HandlerType: (*DataSyncServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DataCaptureUpload",
			Handler:    _DataSyncService_DataCaptureUpload_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FileUpload",
			Handler:       _DataSyncService_FileUpload_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "app/datasync/v1/data_sync.proto",
}

DataSyncService_ServiceDesc is the grpc.ServiceDesc for DataSyncService 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_datasync_v1_data_sync_proto protoreflect.FileDescriptor

Functions

func RegisterDataSyncServiceHandler 

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

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

func RegisterDataSyncServiceHandlerClient 

func RegisterDataSyncServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataSyncServiceClient) error

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

func RegisterDataSyncServiceHandlerFromEndpoint 

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

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

func RegisterDataSyncServiceHandlerServer 

func RegisterDataSyncServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataSyncServiceServer) error

RegisterDataSyncServiceHandlerServer registers the http handlers for service DataSyncService to "mux". UnaryRPC :call DataSyncServiceServer 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 RegisterDataSyncServiceHandlerFromEndpoint instead.

func RegisterDataSyncServiceServer 

func RegisterDataSyncServiceServer(s grpc.ServiceRegistrar, srv DataSyncServiceServer)

Types

type BinaryCapture 

type BinaryCapture struct {
	Interval         *CaptureInterval      `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval" bson:"interval"`
	OrgId            string                `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id" bson:"org_id"`
	RobotId          string                `protobuf:"bytes,3,opt,name=robot_id,json=robotId,proto3" json:"robot_id" bson:"robot_id"`
	PartId           string                `protobuf:"bytes,4,opt,name=part_id,json=partId,proto3" json:"part_id" bson:"part_id"`
	LocationId       string                `protobuf:"bytes,5,opt,name=location_id,json=locationId,proto3" json:"location_id" bson:"location_id"`
	ComponentName    string                `protobuf:"bytes,6,opt,name=component_name,json=componentName,proto3" json:"component_name" bson:"component_name"`
	ComponentType    string                `protobuf:"bytes,7,opt,name=component_type,json=componentType,proto3" json:"component_type" bson:"component_type"`
	ComponentModel   string                `protobuf:"bytes,8,opt,name=component_model,json=componentModel,proto3" json:"component_model" bson:"component_model"`
	MethodName       string                `protobuf:"bytes,9,opt,name=method_name,json=methodName,proto3" json:"method_name" bson:"method_name"`
	BlobPath         string                `protobuf:"bytes,10,opt,name=blob_path,json=blobPath,proto3" json:"blob_path" bson:"blob_path"`
	MethodParameters map[string]*anypb.Any `` /* 213-byte string literal not displayed */
	FileId           string                `protobuf:"bytes,12,opt,name=file_id,json=fileId,proto3" json:"file_id" bson:"file_id"`
	Tags             []string              `protobuf:"bytes,13,rep,name=tags,proto3" json:"tags" bson:"tags"`
	FileSizeBytes    int64                 `protobuf:"varint,14,opt,name=file_size_bytes,json=fileSizeBytes,proto3" json:"file_size_bytes" bson:"file_size_bytes"`
	SessionId        string                `protobuf:"bytes,15,opt,name=session_id,json=sessionId,proto3" json:"session_id" bson:"session_id"`
	MimeType         string                `protobuf:"bytes,16,opt,name=mime_type,json=mimeType,proto3" json:"mime_type" bson:"mime_type"`
	FileName         string                `protobuf:"bytes,17,opt,name=file_name,json=fileName,proto3" json:"file_name" bson:"file_name"`
	FileExt          string                `protobuf:"bytes,18,opt,name=file_ext,json=fileExt,proto3" json:"file_ext" bson:"file_ext"`
	Id               string                `protobuf:"bytes,19,opt,name=id,proto3" json:"id,omitempty" bson:"_id"`
	// contains filtered or unexported fields
}

func (*BinaryCapture) Descriptor deprecated 

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

Deprecated: Use BinaryCapture.ProtoReflect.Descriptor instead.

func (*BinaryCapture) GetBlobPath 

func (x *BinaryCapture) GetBlobPath() string

func (*BinaryCapture) GetComponentModel 

func (x *BinaryCapture) GetComponentModel() string

func (*BinaryCapture) GetComponentName 

func (x *BinaryCapture) GetComponentName() string

func (*BinaryCapture) GetComponentType 

func (x *BinaryCapture) GetComponentType() string

func (*BinaryCapture) GetFileExt added in v0.1.3 

func (x *BinaryCapture) GetFileExt() string

func (*BinaryCapture) GetFileId 

func (x *BinaryCapture) GetFileId() string

func (*BinaryCapture) GetFileName added in v0.1.2 

func (x *BinaryCapture) GetFileName() string

func (*BinaryCapture) GetFileSizeBytes 

func (x *BinaryCapture) GetFileSizeBytes() int64

func (*BinaryCapture) GetId added in v0.1.5 

func (x *BinaryCapture) GetId() string

func (*BinaryCapture) GetInterval 

func (x *BinaryCapture) GetInterval() *CaptureInterval

func (*BinaryCapture) GetLocationId 

func (x *BinaryCapture) GetLocationId() string

func (*BinaryCapture) GetMethodName 

func (x *BinaryCapture) GetMethodName() string

func (*BinaryCapture) GetMethodParameters 

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

func (*BinaryCapture) GetMimeType added in v0.1.1 

func (x *BinaryCapture) GetMimeType() string

func (*BinaryCapture) GetOrgId 

func (x *BinaryCapture) GetOrgId() string

func (*BinaryCapture) GetPartId 

func (x *BinaryCapture) GetPartId() string

func (*BinaryCapture) GetRobotId 

func (x *BinaryCapture) GetRobotId() string

func (*BinaryCapture) GetSessionId 

func (x *BinaryCapture) GetSessionId() string

func (*BinaryCapture) GetTags 

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

func (*BinaryCapture) ProtoMessage 

func (*BinaryCapture) ProtoMessage()

func (*BinaryCapture) ProtoReflect 

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

func (*BinaryCapture) Reset 

func (x *BinaryCapture) Reset()

func (*BinaryCapture) String 

func (x *BinaryCapture) 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
}

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 DataCaptureMetadata 

type DataCaptureMetadata struct {
	ComponentType    string                `protobuf:"bytes,1,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"`
	ComponentName    string                `protobuf:"bytes,2,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	ComponentModel   string                `protobuf:"bytes,3,opt,name=component_model,json=componentModel,proto3" json:"component_model,omitempty"`
	MethodName       string                `protobuf:"bytes,4,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	Type             DataType              `protobuf:"varint,5,opt,name=type,proto3,enum=viam.app.datasync.v1.DataType" json:"type,omitempty"`
	MethodParameters map[string]*anypb.Any `` /* 197-byte string literal not displayed */
	FileExtension    string                `protobuf:"bytes,7,opt,name=file_extension,json=fileExtension,proto3" json:"file_extension,omitempty"`
	Tags             []string              `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	SessionId        string                `protobuf:"bytes,9,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DataCaptureMetadata) Descriptor deprecated 

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

Deprecated: Use DataCaptureMetadata.ProtoReflect.Descriptor instead.

func (*DataCaptureMetadata) GetComponentModel 

func (x *DataCaptureMetadata) GetComponentModel() string

func (*DataCaptureMetadata) GetComponentName 

func (x *DataCaptureMetadata) GetComponentName() string

func (*DataCaptureMetadata) GetComponentType 

func (x *DataCaptureMetadata) GetComponentType() string

func (*DataCaptureMetadata) GetFileExtension 

func (x *DataCaptureMetadata) GetFileExtension() string

func (*DataCaptureMetadata) GetMethodName 

func (x *DataCaptureMetadata) GetMethodName() string

func (*DataCaptureMetadata) GetMethodParameters 

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

func (*DataCaptureMetadata) GetSessionId 

func (x *DataCaptureMetadata) GetSessionId() string

func (*DataCaptureMetadata) GetTags 

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

func (*DataCaptureMetadata) GetType 

func (x *DataCaptureMetadata) GetType() DataType

func (*DataCaptureMetadata) ProtoMessage 

func (*DataCaptureMetadata) ProtoMessage()

func (*DataCaptureMetadata) ProtoReflect 

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

func (*DataCaptureMetadata) Reset 

func (x *DataCaptureMetadata) Reset()

func (*DataCaptureMetadata) String 

func (x *DataCaptureMetadata) String() string

type DataCaptureUploadRequest added in v0.1.29 

type DataCaptureUploadRequest struct {
	Metadata       *UploadMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	SensorContents []*SensorData   `protobuf:"bytes,2,rep,name=sensor_contents,json=sensorContents,proto3" json:"sensor_contents,omitempty"`
	// contains filtered or unexported fields
}

func (*DataCaptureUploadRequest) Descriptor deprecated added in v0.1.29 

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

Deprecated: Use DataCaptureUploadRequest.ProtoReflect.Descriptor instead.

func (*DataCaptureUploadRequest) GetMetadata added in v0.1.29 

func (x *DataCaptureUploadRequest) GetMetadata() *UploadMetadata

func (*DataCaptureUploadRequest) GetSensorContents added in v0.1.29 

func (x *DataCaptureUploadRequest) GetSensorContents() []*SensorData

func (*DataCaptureUploadRequest) ProtoMessage added in v0.1.29 

func (*DataCaptureUploadRequest) ProtoMessage()

func (*DataCaptureUploadRequest) ProtoReflect added in v0.1.29 

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

func (*DataCaptureUploadRequest) Reset added in v0.1.29 

func (x *DataCaptureUploadRequest) Reset()

func (*DataCaptureUploadRequest) String added in v0.1.29 

func (x *DataCaptureUploadRequest) String() string

type DataCaptureUploadResponse added in v0.1.29 

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

func (*DataCaptureUploadResponse) Descriptor deprecated added in v0.1.29 

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

Deprecated: Use DataCaptureUploadResponse.ProtoReflect.Descriptor instead.

func (*DataCaptureUploadResponse) ProtoMessage added in v0.1.29 

func (*DataCaptureUploadResponse) ProtoMessage()

func (*DataCaptureUploadResponse) ProtoReflect added in v0.1.29 

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

func (*DataCaptureUploadResponse) Reset added in v0.1.29 

func (x *DataCaptureUploadResponse) Reset()

func (*DataCaptureUploadResponse) String added in v0.1.29 

func (x *DataCaptureUploadResponse) String() string

type DataSyncServiceClient 

type DataSyncServiceClient interface {
	DataCaptureUpload(ctx context.Context, in *DataCaptureUploadRequest, opts ...grpc.CallOption) (*DataCaptureUploadResponse, error)
	FileUpload(ctx context.Context, opts ...grpc.CallOption) (DataSyncService_FileUploadClient, error)
}

DataSyncServiceClient is the client API for DataSyncService 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 NewDataSyncServiceClient 

func NewDataSyncServiceClient(cc grpc.ClientConnInterface) DataSyncServiceClient

type DataSyncServiceServer 

type DataSyncServiceServer interface {
	DataCaptureUpload(context.Context, *DataCaptureUploadRequest) (*DataCaptureUploadResponse, error)
	FileUpload(DataSyncService_FileUploadServer) error
	// contains filtered or unexported methods
}

DataSyncServiceServer is the server API for DataSyncService service. All implementations must embed UnimplementedDataSyncServiceServer for forward compatibility

type DataSyncService_FileUploadClient added in v0.1.29 

type DataSyncService_FileUploadClient interface {
	Send(*FileUploadRequest) error
	CloseAndRecv() (*FileUploadResponse, error)
	grpc.ClientStream
}

type DataSyncService_FileUploadServer added in v0.1.29 

type DataSyncService_FileUploadServer interface {
	SendAndClose(*FileUploadResponse) error
	Recv() (*FileUploadRequest, error)
	grpc.ServerStream
}

type DataType 

type DataType int32
const (
	DataType_DATA_TYPE_UNSPECIFIED    DataType = 0
	DataType_DATA_TYPE_BINARY_SENSOR  DataType = 1
	DataType_DATA_TYPE_TABULAR_SENSOR DataType = 2
	DataType_DATA_TYPE_FILE           DataType = 3
)

func (DataType) Descriptor 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated 

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type 

func (DataType) Type() protoreflect.EnumType

type FileData 

type FileData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*FileData) Descriptor deprecated 

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

Deprecated: Use FileData.ProtoReflect.Descriptor instead.

func (*FileData) GetData 

func (x *FileData) GetData() []byte

func (*FileData) ProtoMessage 

func (*FileData) ProtoMessage()

func (*FileData) ProtoReflect 

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

func (*FileData) Reset 

func (x *FileData) Reset()

func (*FileData) String 

func (x *FileData) String() string

type FileUploadRequest added in v0.1.29 

type FileUploadRequest struct {

	// Types that are assignable to UploadPacket:
	//
	//	*FileUploadRequest_Metadata
	//	*FileUploadRequest_FileContents
	UploadPacket isFileUploadRequest_UploadPacket `protobuf_oneof:"upload_packet"`
	// contains filtered or unexported fields
}

func (*FileUploadRequest) Descriptor deprecated added in v0.1.29 

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

Deprecated: Use FileUploadRequest.ProtoReflect.Descriptor instead.

func (*FileUploadRequest) GetFileContents added in v0.1.29 

func (x *FileUploadRequest) GetFileContents() *FileData

func (*FileUploadRequest) GetMetadata added in v0.1.29 

func (x *FileUploadRequest) GetMetadata() *UploadMetadata

func (*FileUploadRequest) GetUploadPacket added in v0.1.29 

func (m *FileUploadRequest) GetUploadPacket() isFileUploadRequest_UploadPacket

func (*FileUploadRequest) ProtoMessage added in v0.1.29 

func (*FileUploadRequest) ProtoMessage()

func (*FileUploadRequest) ProtoReflect added in v0.1.29 

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

func (*FileUploadRequest) Reset added in v0.1.29 

func (x *FileUploadRequest) Reset()

func (*FileUploadRequest) String added in v0.1.29 

func (x *FileUploadRequest) String() string

type FileUploadRequest_FileContents added in v0.1.29 

type FileUploadRequest_FileContents struct {
	FileContents *FileData `protobuf:"bytes,2,opt,name=file_contents,json=fileContents,proto3,oneof"`
}

type FileUploadRequest_Metadata added in v0.1.29 

type FileUploadRequest_Metadata struct {
	Metadata *UploadMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}

type FileUploadResponse added in v0.1.29 

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

func (*FileUploadResponse) Descriptor deprecated added in v0.1.29 

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

Deprecated: Use FileUploadResponse.ProtoReflect.Descriptor instead.

func (*FileUploadResponse) ProtoMessage added in v0.1.29 

func (*FileUploadResponse) ProtoMessage()

func (*FileUploadResponse) ProtoReflect added in v0.1.29 

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

func (*FileUploadResponse) Reset added in v0.1.29 

func (x *FileUploadResponse) Reset()

func (*FileUploadResponse) String added in v0.1.29 

func (x *FileUploadResponse) String() string

type SensorData 

type SensorData struct {
	Metadata *SensorMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to Data:
	//
	//	*SensorData_Struct
	//	*SensorData_Binary
	Data isSensorData_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*SensorData) Descriptor deprecated 

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

Deprecated: Use SensorData.ProtoReflect.Descriptor instead.

func (*SensorData) GetBinary 

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

func (*SensorData) GetData 

func (m *SensorData) GetData() isSensorData_Data

func (*SensorData) GetMetadata 

func (x *SensorData) GetMetadata() *SensorMetadata

func (*SensorData) GetStruct 

func (x *SensorData) GetStruct() *structpb.Struct

func (*SensorData) ProtoMessage 

func (*SensorData) ProtoMessage()

func (*SensorData) ProtoReflect 

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

func (*SensorData) Reset 

func (x *SensorData) Reset()

func (*SensorData) String 

func (x *SensorData) String() string

type SensorData_Binary 

type SensorData_Binary struct {
	Binary []byte `protobuf:"bytes,3,opt,name=binary,proto3,oneof"`
}

type SensorData_Struct 

type SensorData_Struct struct {
	Struct *structpb.Struct `protobuf:"bytes,2,opt,name=struct,proto3,oneof"`
}

type SensorMetadata 

type SensorMetadata struct {
	TimeRequested *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time_requested,json=timeRequested,proto3" json:"time_requested,omitempty"`
	TimeReceived  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time_received,json=timeReceived,proto3" json:"time_received,omitempty"`
	// contains filtered or unexported fields
}

func (*SensorMetadata) Descriptor deprecated 

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

Deprecated: Use SensorMetadata.ProtoReflect.Descriptor instead.

func (*SensorMetadata) GetTimeReceived 

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

func (*SensorMetadata) GetTimeRequested 

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

func (*SensorMetadata) ProtoMessage 

func (*SensorMetadata) ProtoMessage()

func (*SensorMetadata) ProtoReflect 

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

func (*SensorMetadata) Reset 

func (x *SensorMetadata) Reset()

func (*SensorMetadata) String 

func (x *SensorMetadata) String() string

type TabularCapture 

type TabularCapture struct {
	Interval         *CaptureInterval      `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval" bson:"interval"`
	OrgId            string                `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id" bson:"org_id"`
	RobotId          string                `protobuf:"bytes,3,opt,name=robot_id,json=robotId,proto3" json:"robot_id" bson:"robot_id"`
	PartId           string                `protobuf:"bytes,4,opt,name=part_id,json=partId,proto3" json:"part_id" bson:"part_id"`
	LocationId       string                `protobuf:"bytes,5,opt,name=location_id,json=locationId,proto3" json:"location_id" bson:"location_id"`
	ComponentName    string                `protobuf:"bytes,6,opt,name=component_name,json=componentName,proto3" json:"component_name" bson:"component_name"`
	ComponentType    string                `protobuf:"bytes,7,opt,name=component_type,json=componentType,proto3" json:"component_type" bson:"component_type"`
	ComponentModel   string                `protobuf:"bytes,8,opt,name=component_model,json=componentModel,proto3" json:"component_model" bson:"component_model"`
	MethodName       string                `protobuf:"bytes,9,opt,name=method_name,json=methodName,proto3" json:"method_name" bson:"method_name"`
	BlobPath         string                `protobuf:"bytes,10,opt,name=blob_path,json=blobPath,proto3" json:"blob_path" bson:"blob_path"`
	ColumnNames      []string              `protobuf:"bytes,11,rep,name=column_names,json=columnNames,proto3" json:"column_names" bson:"column_names"`
	MethodParameters map[string]*anypb.Any `` /* 213-byte string literal not displayed */
	FileId           string                `protobuf:"bytes,13,opt,name=file_id,json=fileId,proto3" json:"file_id" bson:"file_id"`
	Tags             []string              `protobuf:"bytes,14,rep,name=tags,proto3" json:"tags" bson:"tags"`
	MessageCount     int32                 `protobuf:"varint,15,opt,name=message_count,json=messageCount,proto3" json:"message_count" bson:"message_count"`
	FileSizeBytes    int64                 `protobuf:"varint,16,opt,name=file_size_bytes,json=fileSizeBytes,proto3" json:"file_size_bytes" bson:"file_size_bytes"`
	SessionId        string                `protobuf:"bytes,17,opt,name=session_id,json=sessionId,proto3" json:"session_id" bson:"session_id"`
	MimeType         string                `protobuf:"bytes,18,opt,name=mime_type,json=mimeType,proto3" json:"mime_type" bson:"mime_type"`
	Id               string                `protobuf:"bytes,19,opt,name=id,proto3" json:"id,omitempty" bson:"_id"`
	// contains filtered or unexported fields
}

func (*TabularCapture) Descriptor deprecated 

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

Deprecated: Use TabularCapture.ProtoReflect.Descriptor instead.

func (*TabularCapture) GetBlobPath 

func (x *TabularCapture) GetBlobPath() string

func (*TabularCapture) GetColumnNames 

func (x *TabularCapture) GetColumnNames() []string

func (*TabularCapture) GetComponentModel 

func (x *TabularCapture) GetComponentModel() string

func (*TabularCapture) GetComponentName 

func (x *TabularCapture) GetComponentName() string

func (*TabularCapture) GetComponentType 

func (x *TabularCapture) GetComponentType() string

func (*TabularCapture) GetFileId 

func (x *TabularCapture) GetFileId() string

func (*TabularCapture) GetFileSizeBytes 

func (x *TabularCapture) GetFileSizeBytes() int64

func (*TabularCapture) GetId added in v0.1.5 

func (x *TabularCapture) GetId() string

func (*TabularCapture) GetInterval 

func (x *TabularCapture) GetInterval() *CaptureInterval

func (*TabularCapture) GetLocationId 

func (x *TabularCapture) GetLocationId() string

func (*TabularCapture) GetMessageCount 

func (x *TabularCapture) GetMessageCount() int32

func (*TabularCapture) GetMethodName 

func (x *TabularCapture) GetMethodName() string

func (*TabularCapture) GetMethodParameters 

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

func (*TabularCapture) GetMimeType added in v0.1.1 

func (x *TabularCapture) GetMimeType() string

func (*TabularCapture) GetOrgId 

func (x *TabularCapture) GetOrgId() string

func (*TabularCapture) GetPartId 

func (x *TabularCapture) GetPartId() string

func (*TabularCapture) GetRobotId 

func (x *TabularCapture) GetRobotId() string

func (*TabularCapture) GetSessionId 

func (x *TabularCapture) GetSessionId() string

func (*TabularCapture) GetTags 

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

func (*TabularCapture) ProtoMessage 

func (*TabularCapture) ProtoMessage()

func (*TabularCapture) ProtoReflect 

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

func (*TabularCapture) Reset 

func (x *TabularCapture) Reset()

func (*TabularCapture) String 

func (x *TabularCapture) String() string

type UnimplementedDataSyncServiceServer 

type UnimplementedDataSyncServiceServer struct {
}

UnimplementedDataSyncServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSyncServiceServer) DataCaptureUpload added in v0.1.29 

func (UnimplementedDataSyncServiceServer) DataCaptureUpload(context.Context, *DataCaptureUploadRequest) (*DataCaptureUploadResponse, error)

func (UnimplementedDataSyncServiceServer) FileUpload added in v0.1.29 

func (UnimplementedDataSyncServiceServer) FileUpload(DataSyncService_FileUploadServer) error

type UnsafeDataSyncServiceServer 

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

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

type UploadMetadata 

type UploadMetadata struct {
	PartId           string                `protobuf:"bytes,1,opt,name=part_id,json=partId,proto3" json:"part_id,omitempty"`
	ComponentType    string                `protobuf:"bytes,2,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"`
	ComponentName    string                `protobuf:"bytes,3,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	ComponentModel   string                `protobuf:"bytes,4,opt,name=component_model,json=componentModel,proto3" json:"component_model,omitempty"`
	MethodName       string                `protobuf:"bytes,5,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	Type             DataType              `protobuf:"varint,6,opt,name=type,proto3,enum=viam.app.datasync.v1.DataType" json:"type,omitempty"`
	FileName         string                `protobuf:"bytes,7,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	MethodParameters map[string]*anypb.Any `` /* 197-byte string literal not displayed */
	FileExtension    string                `protobuf:"bytes,9,opt,name=file_extension,json=fileExtension,proto3" json:"file_extension,omitempty"`
	Tags             []string              `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	SessionId        string                `protobuf:"bytes,11,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadMetadata) Descriptor deprecated 

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

Deprecated: Use UploadMetadata.ProtoReflect.Descriptor instead.

func (*UploadMetadata) GetComponentModel 

func (x *UploadMetadata) GetComponentModel() string

func (*UploadMetadata) GetComponentName 

func (x *UploadMetadata) GetComponentName() string

func (*UploadMetadata) GetComponentType 

func (x *UploadMetadata) GetComponentType() string

func (*UploadMetadata) GetFileExtension 

func (x *UploadMetadata) GetFileExtension() string

func (*UploadMetadata) GetFileName 

func (x *UploadMetadata) GetFileName() string

func (*UploadMetadata) GetMethodName 

func (x *UploadMetadata) GetMethodName() string

func (*UploadMetadata) GetMethodParameters 

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

func (*UploadMetadata) GetPartId 

func (x *UploadMetadata) GetPartId() string

func (*UploadMetadata) GetSessionId 

func (x *UploadMetadata) GetSessionId() string

func (*UploadMetadata) GetTags 

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

func (*UploadMetadata) GetType 

func (x *UploadMetadata) GetType() DataType

func (*UploadMetadata) ProtoMessage 

func (*UploadMetadata) ProtoMessage()

func (*UploadMetadata) ProtoReflect 

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

func (*UploadMetadata) Reset 

func (x *UploadMetadata) Reset()

func (*UploadMetadata) String 

func (x *UploadMetadata) 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.