v1

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2022 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{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Upload",
			Handler:       _DataSyncService_Upload_Handler,
			ServerStreams: true,
			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 DataSyncServiceClient 

type DataSyncServiceClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (DataSyncService_UploadClient, 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 {
	Upload(DataSyncService_UploadServer) error
	// contains filtered or unexported methods
}

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

type DataSyncService_UploadClient 

type DataSyncService_UploadClient interface {
	Send(*UploadRequest) error
	Recv() (*UploadResponse, error)
	grpc.ClientStream
}

type DataSyncService_UploadServer 

type DataSyncService_UploadServer interface {
	Send(*UploadResponse) error
	Recv() (*UploadRequest, 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 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) Upload 

func (UnimplementedDataSyncServiceServer) Upload(DataSyncService_UploadServer) 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

type UploadRequest 

type UploadRequest struct {

	// Types that are assignable to UploadPacket:
	//
	//	*UploadRequest_Metadata
	//	*UploadRequest_SensorContents
	//	*UploadRequest_FileContents
	UploadPacket isUploadRequest_UploadPacket `protobuf_oneof:"upload_packet"`
	// contains filtered or unexported fields
}

func (*UploadRequest) Descriptor deprecated 

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

Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.

func (*UploadRequest) GetFileContents 

func (x *UploadRequest) GetFileContents() *FileData

func (*UploadRequest) GetMetadata 

func (x *UploadRequest) GetMetadata() *UploadMetadata

func (*UploadRequest) GetSensorContents 

func (x *UploadRequest) GetSensorContents() *SensorData

func (*UploadRequest) GetUploadPacket 

func (m *UploadRequest) GetUploadPacket() isUploadRequest_UploadPacket

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) ProtoReflect 

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

func (*UploadRequest) Reset 

func (x *UploadRequest) Reset()

func (*UploadRequest) String 

func (x *UploadRequest) String() string

type UploadRequest_FileContents 

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

type UploadRequest_Metadata 

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

type UploadRequest_SensorContents 

type UploadRequest_SensorContents struct {
	SensorContents *SensorData `protobuf:"bytes,2,opt,name=sensor_contents,json=sensorContents,proto3,oneof"`
}

type UploadResponse 

type UploadResponse struct {
	RequestsWritten int32 `protobuf:"varint,1,opt,name=requests_written,json=requestsWritten,proto3" json:"requests_written,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadResponse) Descriptor deprecated 

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

Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.

func (*UploadResponse) GetRequestsWritten 

func (x *UploadResponse) GetRequestsWritten() int32

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) ProtoReflect 

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

func (*UploadResponse) Reset 

func (x *UploadResponse) Reset()

func (*UploadResponse) String 

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