v1

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
}

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"`
	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"`
	// contains filtered or unexported fields
}

type DataCaptureUploadMetadata struct {
	UploadMetadata *UploadMetadata `protobuf:"bytes,1,opt,name=upload_metadata,json=uploadMetadata,proto3" json:"upload_metadata,omitempty"`
	SensorMetadata *SensorMetadata `protobuf:"bytes,2,opt,name=sensor_metadata,json=sensorMetadata,proto3" json:"sensor_metadata,omitempty"`
	// contains filtered or unexported fields
}

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
}

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

type DataSyncServiceClient interface {
	// DataCaptureUpload uploads the contents and metadata for tabular data.
	DataCaptureUpload(ctx context.Context, in *DataCaptureUploadRequest, opts ...grpc.CallOption) (*DataCaptureUploadResponse, error)
	// FileUpload uploads the contents and metadata for binary (image + file) data,
	// where the first packet must be the UploadMetadata.
	FileUpload(ctx context.Context, opts ...grpc.CallOption) (DataSyncService_FileUploadClient, error)
	// StreamingDataCaptureUpload uploads the streaming contents and metadata for streaming binary (image + file) data,
	// where the first packet must be the UploadMetadata.
	StreamingDataCaptureUpload(ctx context.Context, opts ...grpc.CallOption) (DataSyncService_StreamingDataCaptureUploadClient, error)
}

type DataSyncServiceServer interface {
	// DataCaptureUpload uploads the contents and metadata for tabular data.
	DataCaptureUpload(context.Context, *DataCaptureUploadRequest) (*DataCaptureUploadResponse, error)
	// FileUpload uploads the contents and metadata for binary (image + file) data,
	// where the first packet must be the UploadMetadata.
	FileUpload(DataSyncService_FileUploadServer) error
	// StreamingDataCaptureUpload uploads the streaming contents and metadata for streaming binary (image + file) data,
	// where the first packet must be the UploadMetadata.
	StreamingDataCaptureUpload(DataSyncService_StreamingDataCaptureUploadServer) error
	// contains filtered or unexported methods
}

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

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

type DataSyncService_StreamingDataCaptureUploadClient interface {
	Send(*StreamingDataCaptureUploadRequest) error
	CloseAndRecv() (*StreamingDataCaptureUploadResponse, error)
	grpc.ClientStream
}

type DataSyncService_StreamingDataCaptureUploadServer interface {
	SendAndClose(*StreamingDataCaptureUploadResponse) error
	Recv() (*StreamingDataCaptureUploadRequest, error)
	grpc.ServerStream
}

type DataType int32

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

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
}

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

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

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

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
}

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

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

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
}

type StreamingDataCaptureUploadRequest struct {

	// Types that are assignable to UploadPacket:
	//
	//	*StreamingDataCaptureUploadRequest_Metadata
	//	*StreamingDataCaptureUploadRequest_Data
	UploadPacket isStreamingDataCaptureUploadRequest_UploadPacket `protobuf_oneof:"upload_packet"`
	// contains filtered or unexported fields
}

type StreamingDataCaptureUploadRequest_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

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

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

type UnimplementedDataSyncServiceServer struct {
}

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

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"`
	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"`
	// contains filtered or unexported fields
}