device

package
v1.3.0-alpha.5 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DeviceService_IssueModuleToken_FullMethodName             = "/ai.metathings.service.device.DeviceService/IssueModuleToken"
	DeviceService_ShowModule_FullMethodName                   = "/ai.metathings.service.device.DeviceService/ShowModule"
	DeviceService_Heartbeat_FullMethodName                    = "/ai.metathings.service.device.DeviceService/Heartbeat"
	DeviceService_PushFrameToFlow_FullMethodName              = "/ai.metathings.service.device.DeviceService/PushFrameToFlow"
	DeviceService_PushFrameToFlowOnce_FullMethodName          = "/ai.metathings.service.device.DeviceService/PushFrameToFlowOnce"
	DeviceService_PutObject_FullMethodName                    = "/ai.metathings.service.device.DeviceService/PutObject"
	DeviceService_PutObjectStreaming_FullMethodName           = "/ai.metathings.service.device.DeviceService/PutObjectStreaming"
	DeviceService_RemoveObject_FullMethodName                 = "/ai.metathings.service.device.DeviceService/RemoveObject"
	DeviceService_RenameObject_FullMethodName                 = "/ai.metathings.service.device.DeviceService/RenameObject"
	DeviceService_GetObject_FullMethodName                    = "/ai.metathings.service.device.DeviceService/GetObject"
	DeviceService_GetObjectContent_FullMethodName             = "/ai.metathings.service.device.DeviceService/GetObjectContent"
	DeviceService_GetObjectStreamingContent_FullMethodName    = "/ai.metathings.service.device.DeviceService/GetObjectStreamingContent"
	DeviceService_ListObjects_FullMethodName                  = "/ai.metathings.service.device.DeviceService/ListObjects"
	DeviceService_ShowModuleFirmwareDescriptor_FullMethodName = "/ai.metathings.service.device.DeviceService/ShowModuleFirmwareDescriptor"
)

Variables

View Source 
var DeviceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ai.metathings.service.device.DeviceService",
	HandlerType: (*DeviceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IssueModuleToken",
			Handler:    _DeviceService_IssueModuleToken_Handler,
		},
		{
			MethodName: "ShowModule",
			Handler:    _DeviceService_ShowModule_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _DeviceService_Heartbeat_Handler,
		},
		{
			MethodName: "PushFrameToFlowOnce",
			Handler:    _DeviceService_PushFrameToFlowOnce_Handler,
		},
		{
			MethodName: "PutObject",
			Handler:    _DeviceService_PutObject_Handler,
		},
		{
			MethodName: "RemoveObject",
			Handler:    _DeviceService_RemoveObject_Handler,
		},
		{
			MethodName: "RenameObject",
			Handler:    _DeviceService_RenameObject_Handler,
		},
		{
			MethodName: "GetObject",
			Handler:    _DeviceService_GetObject_Handler,
		},
		{
			MethodName: "GetObjectContent",
			Handler:    _DeviceService_GetObjectContent_Handler,
		},
		{
			MethodName: "GetObjectStreamingContent",
			Handler:    _DeviceService_GetObjectStreamingContent_Handler,
		},
		{
			MethodName: "ListObjects",
			Handler:    _DeviceService_ListObjects_Handler,
		},
		{
			MethodName: "ShowModuleFirmwareDescriptor",
			Handler:    _DeviceService_ShowModuleFirmwareDescriptor_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PushFrameToFlow",
			Handler:       _DeviceService_PushFrameToFlow_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "PutObjectStreaming",
			Handler:       _DeviceService_PutObjectStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "service.proto",
}

DeviceService_ServiceDesc is the grpc.ServiceDesc for DeviceService 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_bind_devices_proto protoreflect.FileDescriptor
View Source 
var File_create_or_update_profile_proto protoreflect.FileDescriptor
View Source 
var File_delete_profile_proto protoreflect.FileDescriptor
View Source 
var File_get_object_content_proto protoreflect.FileDescriptor
View Source 
var File_get_object_proto protoreflect.FileDescriptor
View Source 
var File_get_object_streaming_content_proto protoreflect.FileDescriptor
View Source 
var File_get_profile_by_device_proto protoreflect.FileDescriptor
View Source 
var File_get_profile_proto protoreflect.FileDescriptor
View Source 
var File_heartbeat_proto protoreflect.FileDescriptor
View Source 
var File_issue_module_token_proto protoreflect.FileDescriptor
View Source 
var File_list_objects_proto protoreflect.FileDescriptor
View Source 
var File_model_proto protoreflect.FileDescriptor
View Source 
var File_push_frame_to_flow_once_proto protoreflect.FileDescriptor
View Source 
var File_push_frame_to_flow_proto protoreflect.FileDescriptor
View Source 
var File_put_object_proto protoreflect.FileDescriptor
View Source 
var File_put_object_streaming_proto protoreflect.FileDescriptor
View Source 
var File_remove_object_proto protoreflect.FileDescriptor
View Source 
var File_rename_object_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var File_show_module_firmware_descriptor_proto protoreflect.FileDescriptor
View Source 
var File_show_module_proto protoreflect.FileDescriptor
View Source 
var File_unbind_devices_proto protoreflect.FileDescriptor

Functions

func RegisterDeviceServiceServer 

func RegisterDeviceServiceServer(s grpc.ServiceRegistrar, srv DeviceServiceServer)

Types

type BindDevicesRequest 

type BindDevicesRequest struct {
	Devices []*deviced.OpDevice `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	Profile *OpProfile          `protobuf:"bytes,2,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*BindDevicesRequest) Descriptor deprecated 

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

Deprecated: Use BindDevicesRequest.ProtoReflect.Descriptor instead.

func (*BindDevicesRequest) GetDevices 

func (x *BindDevicesRequest) GetDevices() []*deviced.OpDevice

func (*BindDevicesRequest) GetProfile 

func (x *BindDevicesRequest) GetProfile() *OpProfile

func (*BindDevicesRequest) ProtoMessage 

func (*BindDevicesRequest) ProtoMessage()

func (*BindDevicesRequest) ProtoReflect 

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

func (*BindDevicesRequest) Reset 

func (x *BindDevicesRequest) Reset()

func (*BindDevicesRequest) String 

func (x *BindDevicesRequest) String() string

type CreateOrUpdateProfileRequest 

type CreateOrUpdateProfileRequest struct {
	Profile *OpProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateOrUpdateProfileRequest) Descriptor deprecated 

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

Deprecated: Use CreateOrUpdateProfileRequest.ProtoReflect.Descriptor instead.

func (*CreateOrUpdateProfileRequest) GetProfile 

func (x *CreateOrUpdateProfileRequest) GetProfile() *OpProfile

func (*CreateOrUpdateProfileRequest) ProtoMessage 

func (*CreateOrUpdateProfileRequest) ProtoMessage()

func (*CreateOrUpdateProfileRequest) ProtoReflect 

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

func (*CreateOrUpdateProfileRequest) Reset 

func (x *CreateOrUpdateProfileRequest) Reset()

func (*CreateOrUpdateProfileRequest) String 

func (x *CreateOrUpdateProfileRequest) String() string

type DeleteProfileRequest 

type DeleteProfileRequest struct {
	Profile *OpProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteProfileRequest) Descriptor deprecated 

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

Deprecated: Use DeleteProfileRequest.ProtoReflect.Descriptor instead.

func (*DeleteProfileRequest) GetProfile 

func (x *DeleteProfileRequest) GetProfile() *OpProfile

func (*DeleteProfileRequest) ProtoMessage 

func (*DeleteProfileRequest) ProtoMessage()

func (*DeleteProfileRequest) ProtoReflect 

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

func (*DeleteProfileRequest) Reset 

func (x *DeleteProfileRequest) Reset()

func (*DeleteProfileRequest) String 

func (x *DeleteProfileRequest) String() string

type DeviceServiceClient 

type DeviceServiceClient interface {
	IssueModuleToken(ctx context.Context, in *IssueModuleTokenRequest, opts ...grpc.CallOption) (*IssueModuleTokenResponse, error)
	ShowModule(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ShowModuleResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PushFrameToFlow(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PushFrameToFlowRequest, PushFrameToFlowResponse], error)
	PushFrameToFlowOnce(ctx context.Context, in *PushFrameToFlowOnceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PutObjectStreaming(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PutObjectStreamingRequest, PutObjectStreamingResponse], error)
	RemoveObject(ctx context.Context, in *RemoveObjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RenameObject(ctx context.Context, in *RenameObjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (*GetObjectResponse, error)
	GetObjectContent(ctx context.Context, in *GetObjectContentRequest, opts ...grpc.CallOption) (*GetObjectContentResponse, error)
	GetObjectStreamingContent(ctx context.Context, in *GetObjectStreamingContentRequest, opts ...grpc.CallOption) (*GetObjectStreamingContentResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
	ShowModuleFirmwareDescriptor(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ShowModuleFirmwareDescriptorResponse, error)
}

DeviceServiceClient is the client API for DeviceService 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 NewDeviceServiceClient 

func NewDeviceServiceClient(cc grpc.ClientConnInterface) DeviceServiceClient

type DeviceServiceServer 

type DeviceServiceServer interface {
	IssueModuleToken(context.Context, *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)
	ShowModule(context.Context, *emptypb.Empty) (*ShowModuleResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*emptypb.Empty, error)
	PushFrameToFlow(grpc.BidiStreamingServer[PushFrameToFlowRequest, PushFrameToFlowResponse]) error
	PushFrameToFlowOnce(context.Context, *PushFrameToFlowOnceRequest) (*emptypb.Empty, error)
	PutObject(context.Context, *PutObjectRequest) (*emptypb.Empty, error)
	PutObjectStreaming(grpc.BidiStreamingServer[PutObjectStreamingRequest, PutObjectStreamingResponse]) error
	RemoveObject(context.Context, *RemoveObjectRequest) (*emptypb.Empty, error)
	RenameObject(context.Context, *RenameObjectRequest) (*emptypb.Empty, error)
	GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)
	GetObjectContent(context.Context, *GetObjectContentRequest) (*GetObjectContentResponse, error)
	GetObjectStreamingContent(context.Context, *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)
	ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
	ShowModuleFirmwareDescriptor(context.Context, *emptypb.Empty) (*ShowModuleFirmwareDescriptorResponse, error)
	// contains filtered or unexported methods
}

DeviceServiceServer is the server API for DeviceService service. All implementations must embed UnimplementedDeviceServiceServer for forward compatibility.

type DeviceService_PushFrameToFlowClient 

type DeviceService_PushFrameToFlowClient = grpc.BidiStreamingClient[PushFrameToFlowRequest, PushFrameToFlowResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DeviceService_PushFrameToFlowServer 

type DeviceService_PushFrameToFlowServer = grpc.BidiStreamingServer[PushFrameToFlowRequest, PushFrameToFlowResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DeviceService_PutObjectStreamingClient 

type DeviceService_PutObjectStreamingClient = grpc.BidiStreamingClient[PutObjectStreamingRequest, PutObjectStreamingResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DeviceService_PutObjectStreamingServer 

type DeviceService_PutObjectStreamingServer = grpc.BidiStreamingServer[PutObjectStreamingRequest, PutObjectStreamingResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GetObjectContentRequest 

type GetObjectContentRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectContentRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectContentRequest.ProtoReflect.Descriptor instead.

func (*GetObjectContentRequest) GetObject 

func (x *GetObjectContentRequest) GetObject() *deviced.OpObject

func (*GetObjectContentRequest) ProtoMessage 

func (*GetObjectContentRequest) ProtoMessage()

func (*GetObjectContentRequest) ProtoReflect added in v1.2.14 

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

func (*GetObjectContentRequest) Reset 

func (x *GetObjectContentRequest) Reset()

func (*GetObjectContentRequest) String 

func (x *GetObjectContentRequest) String() string

type GetObjectContentResponse 

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

func (*GetObjectContentResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectContentResponse.ProtoReflect.Descriptor instead.

func (*GetObjectContentResponse) GetContent 

func (x *GetObjectContentResponse) GetContent() []byte

func (*GetObjectContentResponse) ProtoMessage 

func (*GetObjectContentResponse) ProtoMessage()

func (*GetObjectContentResponse) ProtoReflect added in v1.2.14 

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

func (*GetObjectContentResponse) Reset 

func (x *GetObjectContentResponse) Reset()

func (*GetObjectContentResponse) String 

func (x *GetObjectContentResponse) String() string

type GetObjectRequest 

type GetObjectRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectRequest.ProtoReflect.Descriptor instead.

func (*GetObjectRequest) GetObject 

func (x *GetObjectRequest) GetObject() *deviced.OpObject

func (*GetObjectRequest) ProtoMessage 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) ProtoReflect added in v1.2.14 

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

func (*GetObjectRequest) Reset 

func (x *GetObjectRequest) Reset()

func (*GetObjectRequest) String 

func (x *GetObjectRequest) String() string

type GetObjectResponse 

type GetObjectResponse struct {
	Object *deviced.Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectResponse.ProtoReflect.Descriptor instead.

func (*GetObjectResponse) GetObject 

func (x *GetObjectResponse) GetObject() *deviced.Object

func (*GetObjectResponse) ProtoMessage 

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) ProtoReflect added in v1.2.14 

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

func (*GetObjectResponse) Reset 

func (x *GetObjectResponse) Reset()

func (*GetObjectResponse) String 

func (x *GetObjectResponse) String() string

type GetObjectStreamingContentRequest 

type GetObjectStreamingContentRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectStreamingContentRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectStreamingContentRequest.ProtoReflect.Descriptor instead.

func (*GetObjectStreamingContentRequest) GetObject 

func (x *GetObjectStreamingContentRequest) GetObject() *deviced.OpObject

func (*GetObjectStreamingContentRequest) ProtoMessage 

func (*GetObjectStreamingContentRequest) ProtoMessage()

func (*GetObjectStreamingContentRequest) ProtoReflect added in v1.2.14 

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

func (*GetObjectStreamingContentRequest) Reset 

func (x *GetObjectStreamingContentRequest) Reset()

func (*GetObjectStreamingContentRequest) String 

func (x *GetObjectStreamingContentRequest) String() string

type GetObjectStreamingContentResponse 

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

func (*GetObjectStreamingContentResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectStreamingContentResponse.ProtoReflect.Descriptor instead.

func (*GetObjectStreamingContentResponse) GetContent 

func (x *GetObjectStreamingContentResponse) GetContent() []byte

func (*GetObjectStreamingContentResponse) ProtoMessage 

func (*GetObjectStreamingContentResponse) ProtoMessage()

func (*GetObjectStreamingContentResponse) ProtoReflect added in v1.2.14 

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

func (*GetObjectStreamingContentResponse) Reset 

func (x *GetObjectStreamingContentResponse) Reset()

func (*GetObjectStreamingContentResponse) String 

func (x *GetObjectStreamingContentResponse) String() string

type GetProfileByDeviceRequest 

type GetProfileByDeviceRequest struct {
	Device *deviced.OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProfileByDeviceRequest) Descriptor deprecated 

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

Deprecated: Use GetProfileByDeviceRequest.ProtoReflect.Descriptor instead.

func (*GetProfileByDeviceRequest) GetDevice 

func (x *GetProfileByDeviceRequest) GetDevice() *deviced.OpDevice

func (*GetProfileByDeviceRequest) ProtoMessage 

func (*GetProfileByDeviceRequest) ProtoMessage()

func (*GetProfileByDeviceRequest) ProtoReflect 

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

func (*GetProfileByDeviceRequest) Reset 

func (x *GetProfileByDeviceRequest) Reset()

func (*GetProfileByDeviceRequest) String 

func (x *GetProfileByDeviceRequest) String() string

type GetProfileByDeviceResponse 

type GetProfileByDeviceResponse struct {
	Profile *Profile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProfileByDeviceResponse) Descriptor deprecated 

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

Deprecated: Use GetProfileByDeviceResponse.ProtoReflect.Descriptor instead.

func (*GetProfileByDeviceResponse) GetProfile 

func (x *GetProfileByDeviceResponse) GetProfile() *Profile

func (*GetProfileByDeviceResponse) ProtoMessage 

func (*GetProfileByDeviceResponse) ProtoMessage()

func (*GetProfileByDeviceResponse) ProtoReflect 

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

func (*GetProfileByDeviceResponse) Reset 

func (x *GetProfileByDeviceResponse) Reset()

func (*GetProfileByDeviceResponse) String 

func (x *GetProfileByDeviceResponse) String() string

type GetProfileRequest 

type GetProfileRequest struct {
	Profile *OpProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProfileRequest) Descriptor deprecated 

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

Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.

func (*GetProfileRequest) GetProfile 

func (x *GetProfileRequest) GetProfile() *OpProfile

func (*GetProfileRequest) ProtoMessage 

func (*GetProfileRequest) ProtoMessage()

func (*GetProfileRequest) ProtoReflect 

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

func (*GetProfileRequest) Reset 

func (x *GetProfileRequest) Reset()

func (*GetProfileRequest) String 

func (x *GetProfileRequest) String() string

type GetProfileResponse 

type GetProfileResponse struct {
	Profile *Profile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProfileResponse) Descriptor deprecated 

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

Deprecated: Use GetProfileResponse.ProtoReflect.Descriptor instead.

func (*GetProfileResponse) GetProfile 

func (x *GetProfileResponse) GetProfile() *Profile

func (*GetProfileResponse) ProtoMessage 

func (*GetProfileResponse) ProtoMessage()

func (*GetProfileResponse) ProtoReflect 

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

func (*GetProfileResponse) Reset 

func (x *GetProfileResponse) Reset()

func (*GetProfileResponse) String 

func (x *GetProfileResponse) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Module *deviced.OpModule `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetModule 

func (x *HeartbeatRequest) GetModule() *deviced.OpModule

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect added in v1.2.14 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type IssueModuleTokenRequest 

type IssueModuleTokenRequest struct {
	Credential *identityd2.OpCredential `protobuf:"bytes,1,opt,name=credential,proto3" json:"credential,omitempty"`
	Timestamp  *timestamppb.Timestamp   `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Nonce      *wrapperspb.Int64Value   `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Hmac       *wrapperspb.StringValue  `protobuf:"bytes,4,opt,name=hmac,proto3" json:"hmac,omitempty"`
	// contains filtered or unexported fields
}

func (*IssueModuleTokenRequest) Descriptor deprecated 

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

Deprecated: Use IssueModuleTokenRequest.ProtoReflect.Descriptor instead.

func (*IssueModuleTokenRequest) GetCredential 

func (x *IssueModuleTokenRequest) GetCredential() *identityd2.OpCredential

func (*IssueModuleTokenRequest) GetHmac 

func (x *IssueModuleTokenRequest) GetHmac() *wrapperspb.StringValue

func (*IssueModuleTokenRequest) GetNonce 

func (x *IssueModuleTokenRequest) GetNonce() *wrapperspb.Int64Value

func (*IssueModuleTokenRequest) GetTimestamp 

func (x *IssueModuleTokenRequest) GetTimestamp() *timestamppb.Timestamp

func (*IssueModuleTokenRequest) ProtoMessage 

func (*IssueModuleTokenRequest) ProtoMessage()

func (*IssueModuleTokenRequest) ProtoReflect added in v1.2.14 

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

func (*IssueModuleTokenRequest) Reset 

func (x *IssueModuleTokenRequest) Reset()

func (*IssueModuleTokenRequest) String 

func (x *IssueModuleTokenRequest) String() string

type IssueModuleTokenResponse 

type IssueModuleTokenResponse struct {
	Token *identityd2.Token `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*IssueModuleTokenResponse) Descriptor deprecated 

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

Deprecated: Use IssueModuleTokenResponse.ProtoReflect.Descriptor instead.

func (*IssueModuleTokenResponse) GetToken 

func (x *IssueModuleTokenResponse) GetToken() *identityd2.Token

func (*IssueModuleTokenResponse) ProtoMessage 

func (*IssueModuleTokenResponse) ProtoMessage()

func (*IssueModuleTokenResponse) ProtoReflect added in v1.2.14 

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

func (*IssueModuleTokenResponse) Reset 

func (x *IssueModuleTokenResponse) Reset()

func (*IssueModuleTokenResponse) String 

func (x *IssueModuleTokenResponse) String() string

type ListObjectsRequest 

type ListObjectsRequest struct {
	Object    *deviced.OpObject      `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Recursive *wrapperspb.BoolValue  `protobuf:"bytes,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	Depth     *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=depth,proto3" json:"depth,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListObjectsRequest) GetDepth added in v1.2.9 

func (x *ListObjectsRequest) GetDepth() *wrapperspb.Int32Value

func (*ListObjectsRequest) GetObject 

func (x *ListObjectsRequest) GetObject() *deviced.OpObject

func (*ListObjectsRequest) GetRecursive added in v1.2.9 

func (x *ListObjectsRequest) GetRecursive() *wrapperspb.BoolValue

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) ProtoReflect added in v1.2.14 

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

func (*ListObjectsRequest) Reset 

func (x *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String 

func (x *ListObjectsRequest) String() string

type ListObjectsResponse 

type ListObjectsResponse struct {
	Objects []*deviced.Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListObjectsResponse) GetObjects 

func (x *ListObjectsResponse) GetObjects() []*deviced.Object

func (*ListObjectsResponse) ProtoMessage 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) ProtoReflect added in v1.2.14 

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

func (*ListObjectsResponse) Reset 

func (x *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String 

func (x *ListObjectsResponse) String() string

type OpProfile 

type OpProfile struct {
	Name    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Driver  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Address *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Port    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*OpProfile) Descriptor deprecated 

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

Deprecated: Use OpProfile.ProtoReflect.Descriptor instead.

func (*OpProfile) GetAddress 

func (x *OpProfile) GetAddress() *wrapperspb.StringValue

func (*OpProfile) GetDriver 

func (x *OpProfile) GetDriver() *wrapperspb.StringValue

func (*OpProfile) GetName 

func (x *OpProfile) GetName() *wrapperspb.StringValue

func (*OpProfile) GetPort 

func (x *OpProfile) GetPort() *wrapperspb.StringValue

func (*OpProfile) ProtoMessage 

func (*OpProfile) ProtoMessage()

func (*OpProfile) ProtoReflect 

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

func (*OpProfile) Reset 

func (x *OpProfile) Reset()

func (*OpProfile) String 

func (x *OpProfile) String() string

type Profile 

type Profile struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Driver  string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Port    string `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Profile) Descriptor deprecated 

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

Deprecated: Use Profile.ProtoReflect.Descriptor instead.

func (*Profile) GetAddress 

func (x *Profile) GetAddress() string

func (*Profile) GetDriver 

func (x *Profile) GetDriver() string

func (*Profile) GetName 

func (x *Profile) GetName() string

func (*Profile) GetPort 

func (x *Profile) GetPort() string

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) ProtoReflect 

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

func (*Profile) Reset 

func (x *Profile) Reset()

func (*Profile) String 

func (x *Profile) String() string

type PushFrameToFlowOnceRequest added in v1.2.9 

type PushFrameToFlowOnceRequest struct {
	Id    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Flow  *deviced.OpFlow         `protobuf:"bytes,2,opt,name=flow,proto3" json:"flow,omitempty"`
	Frame *deviced.OpFrame        `protobuf:"bytes,3,opt,name=frame,proto3" json:"frame,omitempty"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowOnceRequest) Descriptor deprecated added in v1.2.9 

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

Deprecated: Use PushFrameToFlowOnceRequest.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowOnceRequest) GetFlow added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) GetFlow() *deviced.OpFlow

func (*PushFrameToFlowOnceRequest) GetFrame added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) GetFrame() *deviced.OpFrame

func (*PushFrameToFlowOnceRequest) GetId added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) GetId() *wrapperspb.StringValue

func (*PushFrameToFlowOnceRequest) ProtoMessage added in v1.2.9 

func (*PushFrameToFlowOnceRequest) ProtoMessage()

func (*PushFrameToFlowOnceRequest) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowOnceRequest) Reset added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) Reset()

func (*PushFrameToFlowOnceRequest) String added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) String() string

type PushFrameToFlowRequest 

type PushFrameToFlowRequest struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*PushFrameToFlowRequest_Config_
	//	*PushFrameToFlowRequest_Ping_
	//	*PushFrameToFlowRequest_Frame
	Request isPushFrameToFlowRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowRequest) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowRequest.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowRequest) GetConfig 

func (x *PushFrameToFlowRequest) GetConfig() *PushFrameToFlowRequest_Config

func (*PushFrameToFlowRequest) GetFrame 

func (x *PushFrameToFlowRequest) GetFrame() *deviced.OpFrame

func (*PushFrameToFlowRequest) GetId 

func (x *PushFrameToFlowRequest) GetId() *wrapperspb.StringValue

func (*PushFrameToFlowRequest) GetPing 

func (x *PushFrameToFlowRequest) GetPing() *PushFrameToFlowRequest_Ping

func (*PushFrameToFlowRequest) GetRequest 

func (m *PushFrameToFlowRequest) GetRequest() isPushFrameToFlowRequest_Request

func (*PushFrameToFlowRequest) ProtoMessage 

func (*PushFrameToFlowRequest) ProtoMessage()

func (*PushFrameToFlowRequest) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowRequest) Reset 

func (x *PushFrameToFlowRequest) Reset()

func (*PushFrameToFlowRequest) String 

func (x *PushFrameToFlowRequest) String() string

type PushFrameToFlowRequest_Config 

type PushFrameToFlowRequest_Config struct {
	Flow      *deviced.OpFlow       `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	ConfigAck *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	PushAck   *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=push_ack,json=pushAck,proto3" json:"push_ack,omitempty"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowRequest_Config) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowRequest_Config.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowRequest_Config) GetConfigAck 

func (x *PushFrameToFlowRequest_Config) GetConfigAck() *wrapperspb.BoolValue

func (*PushFrameToFlowRequest_Config) GetFlow 

func (x *PushFrameToFlowRequest_Config) GetFlow() *deviced.OpFlow

func (*PushFrameToFlowRequest_Config) GetPushAck 

func (x *PushFrameToFlowRequest_Config) GetPushAck() *wrapperspb.BoolValue

func (*PushFrameToFlowRequest_Config) ProtoMessage 

func (*PushFrameToFlowRequest_Config) ProtoMessage()

func (*PushFrameToFlowRequest_Config) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowRequest_Config) Reset 

func (x *PushFrameToFlowRequest_Config) Reset()

func (*PushFrameToFlowRequest_Config) String 

func (x *PushFrameToFlowRequest_Config) String() string

type PushFrameToFlowRequest_Config_ 

type PushFrameToFlowRequest_Config_ struct {
	Config *PushFrameToFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PushFrameToFlowRequest_Frame 

type PushFrameToFlowRequest_Frame struct {
	Frame *deviced.OpFrame `protobuf:"bytes,4,opt,name=frame,proto3,oneof"`
}

type PushFrameToFlowRequest_Ping 

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

func (*PushFrameToFlowRequest_Ping) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowRequest_Ping.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowRequest_Ping) ProtoMessage 

func (*PushFrameToFlowRequest_Ping) ProtoMessage()

func (*PushFrameToFlowRequest_Ping) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowRequest_Ping) Reset 

func (x *PushFrameToFlowRequest_Ping) Reset()

func (*PushFrameToFlowRequest_Ping) String 

func (x *PushFrameToFlowRequest_Ping) String() string

type PushFrameToFlowRequest_Ping_ 

type PushFrameToFlowRequest_Ping_ struct {
	Ping *PushFrameToFlowRequest_Ping `protobuf:"bytes,3,opt,name=ping,proto3,oneof"`
}

type PushFrameToFlowResponse 

type PushFrameToFlowResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Response:
	//
	//	*PushFrameToFlowResponse_Config_
	//	*PushFrameToFlowResponse_Pong_
	//	*PushFrameToFlowResponse_Ack_
	Response isPushFrameToFlowResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowResponse) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse) GetAck 

func (x *PushFrameToFlowResponse) GetAck() *PushFrameToFlowResponse_Ack

func (*PushFrameToFlowResponse) GetConfig 

func (x *PushFrameToFlowResponse) GetConfig() *PushFrameToFlowResponse_Config

func (*PushFrameToFlowResponse) GetId 

func (x *PushFrameToFlowResponse) GetId() string

func (*PushFrameToFlowResponse) GetPong 

func (x *PushFrameToFlowResponse) GetPong() *PushFrameToFlowResponse_Pong

func (*PushFrameToFlowResponse) GetResponse 

func (m *PushFrameToFlowResponse) GetResponse() isPushFrameToFlowResponse_Response

func (*PushFrameToFlowResponse) ProtoMessage 

func (*PushFrameToFlowResponse) ProtoMessage()

func (*PushFrameToFlowResponse) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowResponse) Reset 

func (x *PushFrameToFlowResponse) Reset()

func (*PushFrameToFlowResponse) String 

func (x *PushFrameToFlowResponse) String() string

type PushFrameToFlowResponse_Ack 

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

func (*PushFrameToFlowResponse_Ack) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse_Ack.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse_Ack) ProtoMessage 

func (*PushFrameToFlowResponse_Ack) ProtoMessage()

func (*PushFrameToFlowResponse_Ack) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowResponse_Ack) Reset 

func (x *PushFrameToFlowResponse_Ack) Reset()

func (*PushFrameToFlowResponse_Ack) String 

func (x *PushFrameToFlowResponse_Ack) String() string

type PushFrameToFlowResponse_Ack_ 

type PushFrameToFlowResponse_Ack_ struct {
	Ack *PushFrameToFlowResponse_Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof"`
}

type PushFrameToFlowResponse_Config 

type PushFrameToFlowResponse_Config struct {
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowResponse_Config) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse_Config.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse_Config) GetSession 

func (x *PushFrameToFlowResponse_Config) GetSession() string

func (*PushFrameToFlowResponse_Config) ProtoMessage 

func (*PushFrameToFlowResponse_Config) ProtoMessage()

func (*PushFrameToFlowResponse_Config) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowResponse_Config) Reset 

func (x *PushFrameToFlowResponse_Config) Reset()

func (*PushFrameToFlowResponse_Config) String 

func (x *PushFrameToFlowResponse_Config) String() string

type PushFrameToFlowResponse_Config_ 

type PushFrameToFlowResponse_Config_ struct {
	Config *PushFrameToFlowResponse_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PushFrameToFlowResponse_Pong 

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

func (*PushFrameToFlowResponse_Pong) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse_Pong.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse_Pong) ProtoMessage 

func (*PushFrameToFlowResponse_Pong) ProtoMessage()

func (*PushFrameToFlowResponse_Pong) ProtoReflect added in v1.2.14 

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

func (*PushFrameToFlowResponse_Pong) Reset 

func (x *PushFrameToFlowResponse_Pong) Reset()

func (*PushFrameToFlowResponse_Pong) String 

func (x *PushFrameToFlowResponse_Pong) String() string

type PushFrameToFlowResponse_Pong_ 

type PushFrameToFlowResponse_Pong_ struct {
	Pong *PushFrameToFlowResponse_Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type PutObjectRequest 

type PutObjectRequest struct {
	Object  *deviced.OpObject      `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Content *wrapperspb.BytesValue `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectRequest) Descriptor deprecated 

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

Deprecated: Use PutObjectRequest.ProtoReflect.Descriptor instead.

func (*PutObjectRequest) GetContent 

func (x *PutObjectRequest) GetContent() *wrapperspb.BytesValue

func (*PutObjectRequest) GetObject 

func (x *PutObjectRequest) GetObject() *deviced.OpObject

func (*PutObjectRequest) ProtoMessage 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) ProtoReflect added in v1.2.14 

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

func (*PutObjectRequest) Reset 

func (x *PutObjectRequest) Reset()

func (*PutObjectRequest) String 

func (x *PutObjectRequest) String() string

type PutObjectStreamingRequest 

type PutObjectStreamingRequest struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*PutObjectStreamingRequest_Metadata_
	//	*PutObjectStreamingRequest_Chunks
	Request isPutObjectStreamingRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*PutObjectStreamingRequest) Descriptor deprecated 

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

Deprecated: Use PutObjectStreamingRequest.ProtoReflect.Descriptor instead.

func (*PutObjectStreamingRequest) GetChunks 

func (x *PutObjectStreamingRequest) GetChunks() *deviced.OpObjectChunks

func (*PutObjectStreamingRequest) GetId 

func (x *PutObjectStreamingRequest) GetId() *wrapperspb.StringValue

func (*PutObjectStreamingRequest) GetMetadata 

func (x *PutObjectStreamingRequest) GetMetadata() *PutObjectStreamingRequest_Metadata

func (*PutObjectStreamingRequest) GetRequest 

func (m *PutObjectStreamingRequest) GetRequest() isPutObjectStreamingRequest_Request

func (*PutObjectStreamingRequest) ProtoMessage 

func (*PutObjectStreamingRequest) ProtoMessage()

func (*PutObjectStreamingRequest) ProtoReflect added in v1.2.14 

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

func (*PutObjectStreamingRequest) Reset 

func (x *PutObjectStreamingRequest) Reset()

func (*PutObjectStreamingRequest) String 

func (x *PutObjectStreamingRequest) String() string

type PutObjectStreamingRequest_Chunks 

type PutObjectStreamingRequest_Chunks struct {
	Chunks *deviced.OpObjectChunks `protobuf:"bytes,3,opt,name=chunks,proto3,oneof"`
}

type PutObjectStreamingRequest_Metadata 

type PutObjectStreamingRequest_Metadata struct {
	Object *deviced.OpObject       `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Sha1   *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=sha1,proto3" json:"sha1,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectStreamingRequest_Metadata) Descriptor deprecated 

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

Deprecated: Use PutObjectStreamingRequest_Metadata.ProtoReflect.Descriptor instead.

func (*PutObjectStreamingRequest_Metadata) GetObject 

func (x *PutObjectStreamingRequest_Metadata) GetObject() *deviced.OpObject

func (*PutObjectStreamingRequest_Metadata) GetSha1 

func (x *PutObjectStreamingRequest_Metadata) GetSha1() *wrapperspb.StringValue

func (*PutObjectStreamingRequest_Metadata) ProtoMessage 

func (*PutObjectStreamingRequest_Metadata) ProtoMessage()

func (*PutObjectStreamingRequest_Metadata) ProtoReflect added in v1.2.14 

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

func (*PutObjectStreamingRequest_Metadata) Reset 

func (x *PutObjectStreamingRequest_Metadata) Reset()

func (*PutObjectStreamingRequest_Metadata) String 

func (x *PutObjectStreamingRequest_Metadata) String() string

type PutObjectStreamingRequest_Metadata_ 

type PutObjectStreamingRequest_Metadata_ struct {
	Metadata *PutObjectStreamingRequest_Metadata `protobuf:"bytes,2,opt,name=metadata,proto3,oneof"`
}

type PutObjectStreamingResponse 

type PutObjectStreamingResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Response:
	//
	//	*PutObjectStreamingResponse_Chunks
	Response isPutObjectStreamingResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*PutObjectStreamingResponse) Descriptor deprecated 

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

Deprecated: Use PutObjectStreamingResponse.ProtoReflect.Descriptor instead.

func (*PutObjectStreamingResponse) GetChunks 

func (x *PutObjectStreamingResponse) GetChunks() *deviced.ObjectChunks

func (*PutObjectStreamingResponse) GetId 

func (x *PutObjectStreamingResponse) GetId() string

func (*PutObjectStreamingResponse) GetResponse 

func (m *PutObjectStreamingResponse) GetResponse() isPutObjectStreamingResponse_Response

func (*PutObjectStreamingResponse) ProtoMessage 

func (*PutObjectStreamingResponse) ProtoMessage()

func (*PutObjectStreamingResponse) ProtoReflect added in v1.2.14 

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

func (*PutObjectStreamingResponse) Reset 

func (x *PutObjectStreamingResponse) Reset()

func (*PutObjectStreamingResponse) String 

func (x *PutObjectStreamingResponse) String() string

type PutObjectStreamingResponse_Chunks 

type PutObjectStreamingResponse_Chunks struct {
	Chunks *deviced.ObjectChunks `protobuf:"bytes,2,opt,name=chunks,proto3,oneof"`
}

type RemoveObjectRequest 

type RemoveObjectRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveObjectRequest) Descriptor deprecated 

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

Deprecated: Use RemoveObjectRequest.ProtoReflect.Descriptor instead.

func (*RemoveObjectRequest) GetObject 

func (x *RemoveObjectRequest) GetObject() *deviced.OpObject

func (*RemoveObjectRequest) ProtoMessage 

func (*RemoveObjectRequest) ProtoMessage()

func (*RemoveObjectRequest) ProtoReflect added in v1.2.14 

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

func (*RemoveObjectRequest) Reset 

func (x *RemoveObjectRequest) Reset()

func (*RemoveObjectRequest) String 

func (x *RemoveObjectRequest) String() string

type RenameObjectRequest 

type RenameObjectRequest struct {
	Source      *deviced.OpObject `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination *deviced.OpObject `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameObjectRequest) Descriptor deprecated 

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

Deprecated: Use RenameObjectRequest.ProtoReflect.Descriptor instead.

func (*RenameObjectRequest) GetDestination 

func (x *RenameObjectRequest) GetDestination() *deviced.OpObject

func (*RenameObjectRequest) GetSource 

func (x *RenameObjectRequest) GetSource() *deviced.OpObject

func (*RenameObjectRequest) ProtoMessage 

func (*RenameObjectRequest) ProtoMessage()

func (*RenameObjectRequest) ProtoReflect added in v1.2.14 

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

func (*RenameObjectRequest) Reset 

func (x *RenameObjectRequest) Reset()

func (*RenameObjectRequest) String 

func (x *RenameObjectRequest) String() string

type ShowModuleFirmwareDescriptorResponse 

type ShowModuleFirmwareDescriptorResponse struct {
	FirmwareDescriptor *deviced.FirmwareDescriptor `protobuf:"bytes,1,opt,name=firmware_descriptor,json=firmwareDescriptor,proto3" json:"firmware_descriptor,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowModuleFirmwareDescriptorResponse) Descriptor deprecated 

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

Deprecated: Use ShowModuleFirmwareDescriptorResponse.ProtoReflect.Descriptor instead.

func (*ShowModuleFirmwareDescriptorResponse) GetFirmwareDescriptor 

func (x *ShowModuleFirmwareDescriptorResponse) GetFirmwareDescriptor() *deviced.FirmwareDescriptor

func (*ShowModuleFirmwareDescriptorResponse) ProtoMessage 

func (*ShowModuleFirmwareDescriptorResponse) ProtoMessage()

func (*ShowModuleFirmwareDescriptorResponse) ProtoReflect added in v1.2.14 

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

func (*ShowModuleFirmwareDescriptorResponse) Reset 

func (x *ShowModuleFirmwareDescriptorResponse) Reset()

func (*ShowModuleFirmwareDescriptorResponse) String 

func (x *ShowModuleFirmwareDescriptorResponse) String() string

type ShowModuleResponse 

type ShowModuleResponse struct {
	Module *deviced.Module `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowModuleResponse) Descriptor deprecated 

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

Deprecated: Use ShowModuleResponse.ProtoReflect.Descriptor instead.

func (*ShowModuleResponse) GetModule 

func (x *ShowModuleResponse) GetModule() *deviced.Module

func (*ShowModuleResponse) ProtoMessage 

func (*ShowModuleResponse) ProtoMessage()

func (*ShowModuleResponse) ProtoReflect added in v1.2.14 

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

func (*ShowModuleResponse) Reset 

func (x *ShowModuleResponse) Reset()

func (*ShowModuleResponse) String 

func (x *ShowModuleResponse) String() string

type UnbindDevicesRequest 

type UnbindDevicesRequest struct {
	Devices []*deviced.OpDevice `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	// contains filtered or unexported fields
}

func (*UnbindDevicesRequest) Descriptor deprecated 

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

Deprecated: Use UnbindDevicesRequest.ProtoReflect.Descriptor instead.

func (*UnbindDevicesRequest) GetDevices 

func (x *UnbindDevicesRequest) GetDevices() []*deviced.OpDevice

func (*UnbindDevicesRequest) ProtoMessage 

func (*UnbindDevicesRequest) ProtoMessage()

func (*UnbindDevicesRequest) ProtoReflect 

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

func (*UnbindDevicesRequest) Reset 

func (x *UnbindDevicesRequest) Reset()

func (*UnbindDevicesRequest) String 

func (x *UnbindDevicesRequest) String() string

type UnimplementedDeviceServiceServer added in v1.2.14 

type UnimplementedDeviceServiceServer struct{}

UnimplementedDeviceServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDeviceServiceServer) GetObject added in v1.2.14 

func (UnimplementedDeviceServiceServer) GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)

func (UnimplementedDeviceServiceServer) GetObjectContent added in v1.2.14 

func (UnimplementedDeviceServiceServer) GetObjectContent(context.Context, *GetObjectContentRequest) (*GetObjectContentResponse, error)

func (UnimplementedDeviceServiceServer) GetObjectStreamingContent added in v1.2.14 

func (UnimplementedDeviceServiceServer) GetObjectStreamingContent(context.Context, *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)

func (UnimplementedDeviceServiceServer) Heartbeat added in v1.2.14 

func (UnimplementedDeviceServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*emptypb.Empty, error)

func (UnimplementedDeviceServiceServer) IssueModuleToken added in v1.2.14 

func (UnimplementedDeviceServiceServer) IssueModuleToken(context.Context, *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)

func (UnimplementedDeviceServiceServer) ListObjects added in v1.2.14 

func (UnimplementedDeviceServiceServer) ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)

func (UnimplementedDeviceServiceServer) PushFrameToFlow added in v1.2.14 

func (UnimplementedDeviceServiceServer) PushFrameToFlow(grpc.BidiStreamingServer[PushFrameToFlowRequest, PushFrameToFlowResponse]) error

func (UnimplementedDeviceServiceServer) PushFrameToFlowOnce added in v1.2.14 

func (UnimplementedDeviceServiceServer) PushFrameToFlowOnce(context.Context, *PushFrameToFlowOnceRequest) (*emptypb.Empty, error)

func (UnimplementedDeviceServiceServer) PutObject added in v1.2.14 

func (UnimplementedDeviceServiceServer) PutObject(context.Context, *PutObjectRequest) (*emptypb.Empty, error)

func (UnimplementedDeviceServiceServer) PutObjectStreaming added in v1.2.14 

func (UnimplementedDeviceServiceServer) PutObjectStreaming(grpc.BidiStreamingServer[PutObjectStreamingRequest, PutObjectStreamingResponse]) error

func (UnimplementedDeviceServiceServer) RemoveObject added in v1.2.14 

func (UnimplementedDeviceServiceServer) RemoveObject(context.Context, *RemoveObjectRequest) (*emptypb.Empty, error)

func (UnimplementedDeviceServiceServer) RenameObject added in v1.2.14 

func (UnimplementedDeviceServiceServer) RenameObject(context.Context, *RenameObjectRequest) (*emptypb.Empty, error)

func (UnimplementedDeviceServiceServer) ShowModule added in v1.2.14 

func (UnimplementedDeviceServiceServer) ShowModule(context.Context, *emptypb.Empty) (*ShowModuleResponse, error)

func (UnimplementedDeviceServiceServer) ShowModuleFirmwareDescriptor added in v1.2.14 

func (UnimplementedDeviceServiceServer) ShowModuleFirmwareDescriptor(context.Context, *emptypb.Empty) (*ShowModuleFirmwareDescriptorResponse, error)

type UnsafeDeviceServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.