Documentation
¶
Overview ¶
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterGrpcGatewayHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterGrpcGatewayHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GrpcGatewayClient) error
- func RegisterGrpcGatewayHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterGrpcGatewayHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GrpcGatewayServer) error
- func RegisterGrpcGatewayServer(s grpc.ServiceRegistrar, srv GrpcGatewayServer)
- type CancelPendingCommandsRequest
- func (*CancelPendingCommandsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelPendingCommandsRequest) GetCorrelationIdFilter() []string
- func (x *CancelPendingCommandsRequest) GetResourceId() *commands.ResourceId
- func (*CancelPendingCommandsRequest) ProtoMessage()
- func (x *CancelPendingCommandsRequest) ProtoReflect() protoreflect.Message
- func (x *CancelPendingCommandsRequest) Reset()
- func (x *CancelPendingCommandsRequest) String() string
- type CancelPendingCommandsResponse
- func (*CancelPendingCommandsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CancelPendingCommandsResponse) GetCorrelationIds() []string
- func (*CancelPendingCommandsResponse) ProtoMessage()
- func (x *CancelPendingCommandsResponse) ProtoReflect() protoreflect.Message
- func (x *CancelPendingCommandsResponse) Reset()
- func (x *CancelPendingCommandsResponse) String() string
- type CancelPendingMetadataUpdatesRequest
- func (*CancelPendingMetadataUpdatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelPendingMetadataUpdatesRequest) GetCorrelationIdFilter() []string
- func (x *CancelPendingMetadataUpdatesRequest) GetDeviceId() string
- func (*CancelPendingMetadataUpdatesRequest) ProtoMessage()
- func (x *CancelPendingMetadataUpdatesRequest) ProtoReflect() protoreflect.Message
- func (x *CancelPendingMetadataUpdatesRequest) Reset()
- func (x *CancelPendingMetadataUpdatesRequest) String() string
- type Content
- type CreateResourceRequest
- func (*CreateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceRequest) GetContent() *Content
- func (x *CreateResourceRequest) GetResourceId() *commands.ResourceId
- func (x *CreateResourceRequest) GetTimeToLive() int64
- func (*CreateResourceRequest) ProtoMessage()
- func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateResourceRequest) Reset()
- func (x *CreateResourceRequest) String() string
- func (req *CreateResourceRequest) ToRACommand(ctx context.Context) (*commands.CreateResourceRequest, error)
- type CreateResourceResponse
- func (*CreateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceResponse) GetData() *events.ResourceCreated
- func (*CreateResourceResponse) ProtoMessage()
- func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateResourceResponse) Reset()
- func (x *CreateResourceResponse) String() string
- type DeleteDevicesRequest
- func (*DeleteDevicesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDevicesRequest) GetDeviceIdFilter() []string
- func (*DeleteDevicesRequest) ProtoMessage()
- func (x *DeleteDevicesRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDevicesRequest) Reset()
- func (x *DeleteDevicesRequest) String() string
- type DeleteDevicesResponse
- func (*DeleteDevicesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDevicesResponse) GetDeviceIds() []string
- func (*DeleteDevicesResponse) ProtoMessage()
- func (x *DeleteDevicesResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteDevicesResponse) Reset()
- func (x *DeleteDevicesResponse) String() string
- type DeleteResourceRequest
- func (*DeleteResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteResourceRequest) GetResourceId() *commands.ResourceId
- func (x *DeleteResourceRequest) GetTimeToLive() int64
- func (*DeleteResourceRequest) ProtoMessage()
- func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteResourceRequest) Reset()
- func (x *DeleteResourceRequest) String() string
- func (req *DeleteResourceRequest) ToRACommand(ctx context.Context) (*commands.DeleteResourceRequest, error)
- type DeleteResourceResponse
- func (*DeleteResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteResourceResponse) GetData() *events.ResourceDeleted
- func (*DeleteResourceResponse) ProtoMessage()
- func (x *DeleteResourceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteResourceResponse) Reset()
- func (x *DeleteResourceResponse) String() string
- type Device
- func (*Device) Descriptor() ([]byte, []int)deprecated
- func (x *Device) GetId() string
- func (x *Device) GetInterfaces() []string
- func (x *Device) GetManufacturerName() []*LocalizedString
- func (x *Device) GetMetadata() *Device_Metadata
- func (x *Device) GetModelNumber() string
- func (x *Device) GetName() string
- func (x *Device) GetProtocolIndependentId() string
- func (x *Device) GetTypes() []string
- func (*Device) ProtoMessage()
- func (x *Device) ProtoReflect() protoreflect.Message
- func (x *Device) Reset()
- func (x *Device) String() string
- func (d *Device) ToSchema() device.Device
- type Device_Metadata
- func (*Device_Metadata) Descriptor() ([]byte, []int)deprecated
- func (x *Device_Metadata) GetShadowSynchronization() commands.ShadowSynchronization
- func (x *Device_Metadata) GetStatus() *commands.ConnectionStatus
- func (*Device_Metadata) ProtoMessage()
- func (x *Device_Metadata) ProtoReflect() protoreflect.Message
- func (x *Device_Metadata) Reset()
- func (x *Device_Metadata) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetCorrelationId() string
- func (x *Event) GetDeviceMetadataUpdatePending() *events.DeviceMetadataUpdatePending
- func (x *Event) GetDeviceMetadataUpdated() *events.DeviceMetadataUpdated
- func (x *Event) GetDeviceRegistered() *Event_DeviceRegistered
- func (x *Event) GetDeviceUnregistered() *Event_DeviceUnregistered
- func (x *Event) GetOperationProcessed() *Event_OperationProcessed
- func (x *Event) GetResourceChanged() *events.ResourceChanged
- func (x *Event) GetResourceCreatePending() *events.ResourceCreatePending
- func (x *Event) GetResourceCreated() *events.ResourceCreated
- func (x *Event) GetResourceDeletePending() *events.ResourceDeletePending
- func (x *Event) GetResourceDeleted() *events.ResourceDeleted
- func (x *Event) GetResourcePublished() *events.ResourceLinksPublished
- func (x *Event) GetResourceRetrievePending() *events.ResourceRetrievePending
- func (x *Event) GetResourceRetrieved() *events.ResourceRetrieved
- func (x *Event) GetResourceUnpublished() *events.ResourceLinksUnpublished
- func (x *Event) GetResourceUpdatePending() *events.ResourceUpdatePending
- func (x *Event) GetResourceUpdated() *events.ResourceUpdated
- func (x *Event) GetSubscriptionCanceled() *Event_SubscriptionCanceled
- func (x *Event) GetSubscriptionId() string
- func (m *Event) GetType() isEvent_Type
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Event_DeviceMetadataUpdatePending
- type Event_DeviceMetadataUpdated
- type Event_DeviceRegistered
- func (*Event_DeviceRegistered) Descriptor() ([]byte, []int)deprecated
- func (x *Event_DeviceRegistered) GetDeviceIds() []string
- func (x *Event_DeviceRegistered) GetOpenTelemetryCarrier() map[string]string
- func (*Event_DeviceRegistered) ProtoMessage()
- func (x *Event_DeviceRegistered) ProtoReflect() protoreflect.Message
- func (x *Event_DeviceRegistered) Reset()
- func (x *Event_DeviceRegistered) String() string
- type Event_DeviceRegistered_
- type Event_DeviceUnregistered
- func (*Event_DeviceUnregistered) Descriptor() ([]byte, []int)deprecated
- func (x *Event_DeviceUnregistered) GetDeviceIds() []string
- func (x *Event_DeviceUnregistered) GetOpenTelemetryCarrier() map[string]string
- func (*Event_DeviceUnregistered) ProtoMessage()
- func (x *Event_DeviceUnregistered) ProtoReflect() protoreflect.Message
- func (x *Event_DeviceUnregistered) Reset()
- func (x *Event_DeviceUnregistered) String() string
- type Event_DeviceUnregistered_
- type Event_OperationProcessed
- func (*Event_OperationProcessed) Descriptor() ([]byte, []int)deprecated
- func (x *Event_OperationProcessed) GetErrorStatus() *Event_OperationProcessed_ErrorStatus
- func (*Event_OperationProcessed) ProtoMessage()
- func (x *Event_OperationProcessed) ProtoReflect() protoreflect.Message
- func (x *Event_OperationProcessed) Reset()
- func (x *Event_OperationProcessed) String() string
- type Event_OperationProcessed_
- type Event_OperationProcessed_ErrorStatus
- func (*Event_OperationProcessed_ErrorStatus) Descriptor() ([]byte, []int)deprecated
- func (x *Event_OperationProcessed_ErrorStatus) GetCode() Event_OperationProcessed_ErrorStatus_Code
- func (x *Event_OperationProcessed_ErrorStatus) GetMessage() string
- func (*Event_OperationProcessed_ErrorStatus) ProtoMessage()
- func (x *Event_OperationProcessed_ErrorStatus) ProtoReflect() protoreflect.Message
- func (x *Event_OperationProcessed_ErrorStatus) Reset()
- func (x *Event_OperationProcessed_ErrorStatus) String() string
- type Event_OperationProcessed_ErrorStatus_Code
- func (Event_OperationProcessed_ErrorStatus_Code) Descriptor() protoreflect.EnumDescriptor
- func (x Event_OperationProcessed_ErrorStatus_Code) Enum() *Event_OperationProcessed_ErrorStatus_Code
- func (Event_OperationProcessed_ErrorStatus_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x Event_OperationProcessed_ErrorStatus_Code) Number() protoreflect.EnumNumber
- func (x Event_OperationProcessed_ErrorStatus_Code) String() string
- func (Event_OperationProcessed_ErrorStatus_Code) Type() protoreflect.EnumType
- type Event_ResourceChanged
- type Event_ResourceCreatePending
- type Event_ResourceCreated
- type Event_ResourceDeletePending
- type Event_ResourceDeleted
- type Event_ResourcePublished
- type Event_ResourceRetrievePending
- type Event_ResourceRetrieved
- type Event_ResourceUnpublished
- type Event_ResourceUpdatePending
- type Event_ResourceUpdated
- type Event_SubscriptionCanceled
- func (*Event_SubscriptionCanceled) Descriptor() ([]byte, []int)deprecated
- func (x *Event_SubscriptionCanceled) GetReason() string
- func (*Event_SubscriptionCanceled) ProtoMessage()
- func (x *Event_SubscriptionCanceled) ProtoReflect() protoreflect.Message
- func (x *Event_SubscriptionCanceled) Reset()
- func (x *Event_SubscriptionCanceled) String() string
- type Event_SubscriptionCanceled_
- type GetDevicesMetadataRequest
- func (*GetDevicesMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDevicesMetadataRequest) GetDeviceIdFilter() []string
- func (x *GetDevicesMetadataRequest) GetTypeFilter() []string
- func (*GetDevicesMetadataRequest) ProtoMessage()
- func (x *GetDevicesMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *GetDevicesMetadataRequest) Reset()
- func (x *GetDevicesMetadataRequest) String() string
- type GetDevicesRequest
- func (*GetDevicesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDevicesRequest) GetDeviceIdFilter() []string
- func (x *GetDevicesRequest) GetStatusFilter() []GetDevicesRequest_Status
- func (x *GetDevicesRequest) GetTypeFilter() []string
- func (*GetDevicesRequest) ProtoMessage()
- func (x *GetDevicesRequest) ProtoReflect() protoreflect.Message
- func (x *GetDevicesRequest) Reset()
- func (x *GetDevicesRequest) String() string
- type GetDevicesRequest_Status
- func (GetDevicesRequest_Status) Descriptor() protoreflect.EnumDescriptor
- func (x GetDevicesRequest_Status) Enum() *GetDevicesRequest_Status
- func (GetDevicesRequest_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x GetDevicesRequest_Status) Number() protoreflect.EnumNumber
- func (x GetDevicesRequest_Status) String() string
- func (GetDevicesRequest_Status) Type() protoreflect.EnumType
- type GetEventsRequest
- func (*GetEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventsRequest) GetDeviceIdFilter() []string
- func (x *GetEventsRequest) GetResourceIdFilter() []string
- func (x *GetEventsRequest) GetTimestampFilter() int64
- func (*GetEventsRequest) ProtoMessage()
- func (x *GetEventsRequest) ProtoReflect() protoreflect.Message
- func (x *GetEventsRequest) Reset()
- func (x *GetEventsRequest) String() string
- type GetEventsResponse
- func (*GetEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventsResponse) GetDeviceMetadataSnapshotTaken() *events.DeviceMetadataSnapshotTaken
- func (x *GetEventsResponse) GetDeviceMetadataUpdatePending() *events.DeviceMetadataUpdatePending
- func (x *GetEventsResponse) GetDeviceMetadataUpdated() *events.DeviceMetadataUpdated
- func (x *GetEventsResponse) GetResourceChanged() *events.ResourceChanged
- func (x *GetEventsResponse) GetResourceCreatePending() *events.ResourceCreatePending
- func (x *GetEventsResponse) GetResourceCreated() *events.ResourceCreated
- func (x *GetEventsResponse) GetResourceDeletePending() *events.ResourceDeletePending
- func (x *GetEventsResponse) GetResourceDeleted() *events.ResourceDeleted
- func (x *GetEventsResponse) GetResourceLinksPublished() *events.ResourceLinksPublished
- func (x *GetEventsResponse) GetResourceLinksSnapshotTaken() *events.ResourceLinksSnapshotTaken
- func (x *GetEventsResponse) GetResourceLinksUnpublished() *events.ResourceLinksUnpublished
- func (x *GetEventsResponse) GetResourceRetrievePending() *events.ResourceRetrievePending
- func (x *GetEventsResponse) GetResourceRetrieved() *events.ResourceRetrieved
- func (x *GetEventsResponse) GetResourceStateSnapshotTaken() *events.ResourceStateSnapshotTaken
- func (x *GetEventsResponse) GetResourceUpdatePending() *events.ResourceUpdatePending
- func (x *GetEventsResponse) GetResourceUpdated() *events.ResourceUpdated
- func (m *GetEventsResponse) GetType() isGetEventsResponse_Type
- func (*GetEventsResponse) ProtoMessage()
- func (x *GetEventsResponse) ProtoReflect() protoreflect.Message
- func (x *GetEventsResponse) Reset()
- func (x *GetEventsResponse) String() string
- type GetEventsResponse_DeviceMetadataSnapshotTaken
- type GetEventsResponse_DeviceMetadataUpdatePending
- type GetEventsResponse_DeviceMetadataUpdated
- type GetEventsResponse_ResourceChanged
- type GetEventsResponse_ResourceCreatePending
- type GetEventsResponse_ResourceCreated
- type GetEventsResponse_ResourceDeletePending
- type GetEventsResponse_ResourceDeleted
- type GetEventsResponse_ResourceLinksPublished
- type GetEventsResponse_ResourceLinksSnapshotTaken
- type GetEventsResponse_ResourceLinksUnpublished
- type GetEventsResponse_ResourceRetrievePending
- type GetEventsResponse_ResourceRetrieved
- type GetEventsResponse_ResourceStateSnapshotTaken
- type GetEventsResponse_ResourceUpdatePending
- type GetEventsResponse_ResourceUpdated
- type GetPendingCommandsRequest
- func (*GetPendingCommandsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPendingCommandsRequest) GetCommandFilter() []GetPendingCommandsRequest_Command
- func (x *GetPendingCommandsRequest) GetDeviceIdFilter() []string
- func (x *GetPendingCommandsRequest) GetResourceIdFilter() []string
- func (x *GetPendingCommandsRequest) GetTypeFilter() []string
- func (*GetPendingCommandsRequest) ProtoMessage()
- func (x *GetPendingCommandsRequest) ProtoReflect() protoreflect.Message
- func (x *GetPendingCommandsRequest) Reset()
- func (x *GetPendingCommandsRequest) String() string
- type GetPendingCommandsRequest_Command
- func (GetPendingCommandsRequest_Command) Descriptor() protoreflect.EnumDescriptor
- func (x GetPendingCommandsRequest_Command) Enum() *GetPendingCommandsRequest_Command
- func (GetPendingCommandsRequest_Command) EnumDescriptor() ([]byte, []int)deprecated
- func (x GetPendingCommandsRequest_Command) Number() protoreflect.EnumNumber
- func (x GetPendingCommandsRequest_Command) String() string
- func (GetPendingCommandsRequest_Command) Type() protoreflect.EnumType
- type GetResourceFromDeviceRequest
- func (*GetResourceFromDeviceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceFromDeviceRequest) GetResourceId() *commands.ResourceId
- func (x *GetResourceFromDeviceRequest) GetResourceInterface() string
- func (x *GetResourceFromDeviceRequest) GetTimeToLive() int64
- func (*GetResourceFromDeviceRequest) ProtoMessage()
- func (x *GetResourceFromDeviceRequest) ProtoReflect() protoreflect.Message
- func (x *GetResourceFromDeviceRequest) Reset()
- func (x *GetResourceFromDeviceRequest) String() string
- func (req *GetResourceFromDeviceRequest) ToRACommand(ctx context.Context) (*commands.RetrieveResourceRequest, error)
- type GetResourceFromDeviceResponse
- func (*GetResourceFromDeviceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceFromDeviceResponse) GetData() *events.ResourceRetrieved
- func (*GetResourceFromDeviceResponse) ProtoMessage()
- func (x *GetResourceFromDeviceResponse) ProtoReflect() protoreflect.Message
- func (x *GetResourceFromDeviceResponse) Reset()
- func (x *GetResourceFromDeviceResponse) String() string
- type GetResourceLinksRequest
- func (*GetResourceLinksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceLinksRequest) GetDeviceIdFilter() []string
- func (x *GetResourceLinksRequest) GetTypeFilter() []string
- func (*GetResourceLinksRequest) ProtoMessage()
- func (x *GetResourceLinksRequest) ProtoReflect() protoreflect.Message
- func (x *GetResourceLinksRequest) Reset()
- func (x *GetResourceLinksRequest) String() string
- type GetResourcesRequest
- func (*GetResourcesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourcesRequest) GetDeviceIdFilter() []string
- func (x *GetResourcesRequest) GetResourceIdFilter() []string
- func (x *GetResourcesRequest) GetTypeFilter() []string
- func (*GetResourcesRequest) ProtoMessage()
- func (x *GetResourcesRequest) ProtoReflect() protoreflect.Message
- func (x *GetResourcesRequest) Reset()
- func (x *GetResourcesRequest) String() string
- type GrpcGatewayClient
- type GrpcGatewayServer
- type GrpcGateway_GetDevicesClient
- type GrpcGateway_GetDevicesMetadataClient
- type GrpcGateway_GetDevicesMetadataServer
- type GrpcGateway_GetDevicesServer
- type GrpcGateway_GetEventsClient
- type GrpcGateway_GetEventsServer
- type GrpcGateway_GetPendingCommandsClient
- type GrpcGateway_GetPendingCommandsServer
- type GrpcGateway_GetResourceLinksClient
- type GrpcGateway_GetResourceLinksServer
- type GrpcGateway_GetResourcesClient
- type GrpcGateway_GetResourcesServer
- type GrpcGateway_SubscribeToEventsClient
- type GrpcGateway_SubscribeToEventsServer
- type HubConfigurationRequest
- type HubConfigurationResponse
- func (*HubConfigurationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HubConfigurationResponse) GetAuthorizationServer() string
- func (x *HubConfigurationResponse) GetCertificateAuthorities() string
- func (x *HubConfigurationResponse) GetCoapGateway() string
- func (x *HubConfigurationResponse) GetCurrentTime() int64
- func (x *HubConfigurationResponse) GetDefaultCommandTimeToLive() int64
- func (x *HubConfigurationResponse) GetId() string
- func (x *HubConfigurationResponse) GetJwtDeviceIdClaim() string
- func (x *HubConfigurationResponse) GetJwtOwnerClaim() string
- func (*HubConfigurationResponse) ProtoMessage()
- func (x *HubConfigurationResponse) ProtoReflect() protoreflect.Message
- func (x *HubConfigurationResponse) Reset()
- func (x *HubConfigurationResponse) String() string
- type LocalizedString
- func (*LocalizedString) Descriptor() ([]byte, []int)deprecated
- func (x *LocalizedString) GetLanguage() string
- func (x *LocalizedString) GetValue() string
- func (*LocalizedString) ProtoMessage()
- func (x *LocalizedString) ProtoReflect() protoreflect.Message
- func (x *LocalizedString) Reset()
- func (x *LocalizedString) String() string
- func (l *LocalizedString) ToSchema() device.LocalizedString
- type LocalizedStrings
- type PendingCommand
- func (*PendingCommand) Descriptor() ([]byte, []int)deprecated
- func (m *PendingCommand) GetCommand() isPendingCommand_Command
- func (x *PendingCommand) GetDeviceMetadataUpdatePending() *events.DeviceMetadataUpdatePending
- func (x *PendingCommand) GetResourceCreatePending() *events.ResourceCreatePending
- func (x *PendingCommand) GetResourceDeletePending() *events.ResourceDeletePending
- func (x *PendingCommand) GetResourceRetrievePending() *events.ResourceRetrievePending
- func (x *PendingCommand) GetResourceUpdatePending() *events.ResourceUpdatePending
- func (*PendingCommand) ProtoMessage()
- func (x *PendingCommand) ProtoReflect() protoreflect.Message
- func (x *PendingCommand) Reset()
- func (x *PendingCommand) String() string
- type PendingCommand_DeviceMetadataUpdatePending
- type PendingCommand_ResourceCreatePending
- type PendingCommand_ResourceDeletePending
- type PendingCommand_ResourceRetrievePending
- type PendingCommand_ResourceUpdatePending
- type Resource
- type SubscribeToEvents
- func (*SubscribeToEvents) Descriptor() ([]byte, []int)deprecated
- func (m *SubscribeToEvents) GetAction() isSubscribeToEvents_Action
- func (x *SubscribeToEvents) GetCancelSubscription() *SubscribeToEvents_CancelSubscription
- func (x *SubscribeToEvents) GetCorrelationId() string
- func (x *SubscribeToEvents) GetCreateSubscription() *SubscribeToEvents_CreateSubscription
- func (*SubscribeToEvents) ProtoMessage()
- func (x *SubscribeToEvents) ProtoReflect() protoreflect.Message
- func (x *SubscribeToEvents) Reset()
- func (x *SubscribeToEvents) String() string
- type SubscribeToEvents_CancelSubscription
- func (*SubscribeToEvents_CancelSubscription) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeToEvents_CancelSubscription) GetSubscriptionId() string
- func (*SubscribeToEvents_CancelSubscription) ProtoMessage()
- func (x *SubscribeToEvents_CancelSubscription) ProtoReflect() protoreflect.Message
- func (x *SubscribeToEvents_CancelSubscription) Reset()
- func (x *SubscribeToEvents_CancelSubscription) String() string
- type SubscribeToEvents_CancelSubscription_
- type SubscribeToEvents_CreateSubscription
- func (*SubscribeToEvents_CreateSubscription) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeToEvents_CreateSubscription) GetDeviceIdFilter() []string
- func (x *SubscribeToEvents_CreateSubscription) GetEventFilter() []SubscribeToEvents_CreateSubscription_Event
- func (x *SubscribeToEvents_CreateSubscription) GetResourceIdFilter() []string
- func (*SubscribeToEvents_CreateSubscription) ProtoMessage()
- func (x *SubscribeToEvents_CreateSubscription) ProtoReflect() protoreflect.Message
- func (x *SubscribeToEvents_CreateSubscription) Reset()
- func (x *SubscribeToEvents_CreateSubscription) String() string
- type SubscribeToEvents_CreateSubscription_
- type SubscribeToEvents_CreateSubscription_Event
- func (SubscribeToEvents_CreateSubscription_Event) Descriptor() protoreflect.EnumDescriptor
- func (x SubscribeToEvents_CreateSubscription_Event) Enum() *SubscribeToEvents_CreateSubscription_Event
- func (SubscribeToEvents_CreateSubscription_Event) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscribeToEvents_CreateSubscription_Event) Number() protoreflect.EnumNumber
- func (x SubscribeToEvents_CreateSubscription_Event) String() string
- func (SubscribeToEvents_CreateSubscription_Event) Type() protoreflect.EnumType
- type UnimplementedGrpcGatewayServer
- func (UnimplementedGrpcGatewayServer) CancelPendingCommands(context.Context, *CancelPendingCommandsRequest) (*CancelPendingCommandsResponse, error)
- func (UnimplementedGrpcGatewayServer) CancelPendingMetadataUpdates(context.Context, *CancelPendingMetadataUpdatesRequest) (*CancelPendingCommandsResponse, error)
- func (UnimplementedGrpcGatewayServer) CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
- func (UnimplementedGrpcGatewayServer) DeleteDevices(context.Context, *DeleteDevicesRequest) (*DeleteDevicesResponse, error)
- func (UnimplementedGrpcGatewayServer) DeleteResource(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)
- func (UnimplementedGrpcGatewayServer) GetDevices(*GetDevicesRequest, GrpcGateway_GetDevicesServer) error
- func (UnimplementedGrpcGatewayServer) GetDevicesMetadata(*GetDevicesMetadataRequest, GrpcGateway_GetDevicesMetadataServer) error
- func (UnimplementedGrpcGatewayServer) GetEvents(*GetEventsRequest, GrpcGateway_GetEventsServer) error
- func (UnimplementedGrpcGatewayServer) GetHubConfiguration(context.Context, *HubConfigurationRequest) (*HubConfigurationResponse, error)
- func (UnimplementedGrpcGatewayServer) GetPendingCommands(*GetPendingCommandsRequest, GrpcGateway_GetPendingCommandsServer) error
- func (UnimplementedGrpcGatewayServer) GetResourceFromDevice(context.Context, *GetResourceFromDeviceRequest) (*GetResourceFromDeviceResponse, error)
- func (UnimplementedGrpcGatewayServer) GetResourceLinks(*GetResourceLinksRequest, GrpcGateway_GetResourceLinksServer) error
- func (UnimplementedGrpcGatewayServer) GetResources(*GetResourcesRequest, GrpcGateway_GetResourcesServer) error
- func (UnimplementedGrpcGatewayServer) SubscribeToEvents(GrpcGateway_SubscribeToEventsServer) error
- func (UnimplementedGrpcGatewayServer) UpdateDeviceMetadata(context.Context, *UpdateDeviceMetadataRequest) (*UpdateDeviceMetadataResponse, error)
- func (UnimplementedGrpcGatewayServer) UpdateResource(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)
- type UnsafeGrpcGatewayServer
- type UpdateDeviceMetadataRequest
- func (*UpdateDeviceMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeviceMetadataRequest) GetDeviceId() string
- func (x *UpdateDeviceMetadataRequest) GetShadowSynchronization() UpdateDeviceMetadataRequest_ShadowSynchronization
- func (x *UpdateDeviceMetadataRequest) GetTimeToLive() int64
- func (*UpdateDeviceMetadataRequest) ProtoMessage()
- func (x *UpdateDeviceMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDeviceMetadataRequest) Reset()
- func (x *UpdateDeviceMetadataRequest) String() string
- func (req *UpdateDeviceMetadataRequest) ToRACommand(ctx context.Context) (*commands.UpdateDeviceMetadataRequest, error)
- type UpdateDeviceMetadataRequest_ShadowSynchronization
- func (UpdateDeviceMetadataRequest_ShadowSynchronization) Descriptor() protoreflect.EnumDescriptor
- func (x UpdateDeviceMetadataRequest_ShadowSynchronization) Enum() *UpdateDeviceMetadataRequest_ShadowSynchronization
- func (UpdateDeviceMetadataRequest_ShadowSynchronization) EnumDescriptor() ([]byte, []int)deprecated
- func (x UpdateDeviceMetadataRequest_ShadowSynchronization) Number() protoreflect.EnumNumber
- func (x UpdateDeviceMetadataRequest_ShadowSynchronization) String() string
- func (UpdateDeviceMetadataRequest_ShadowSynchronization) Type() protoreflect.EnumType
- type UpdateDeviceMetadataResponse
- func (*UpdateDeviceMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeviceMetadataResponse) GetData() *events.DeviceMetadataUpdated
- func (*UpdateDeviceMetadataResponse) ProtoMessage()
- func (x *UpdateDeviceMetadataResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDeviceMetadataResponse) Reset()
- func (x *UpdateDeviceMetadataResponse) String() string
- type UpdateResourceRequest
- func (*UpdateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceRequest) GetContent() *Content
- func (x *UpdateResourceRequest) GetResourceId() *commands.ResourceId
- func (x *UpdateResourceRequest) GetResourceInterface() string
- func (x *UpdateResourceRequest) GetTimeToLive() int64
- func (*UpdateResourceRequest) ProtoMessage()
- func (x *UpdateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceRequest) Reset()
- func (x *UpdateResourceRequest) String() string
- func (req *UpdateResourceRequest) ToRACommand(ctx context.Context) (*commands.UpdateResourceRequest, error)
- type UpdateResourceResponse
- func (*UpdateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceResponse) GetData() *events.ResourceUpdated
- func (*UpdateResourceResponse) ProtoMessage()
- func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceResponse) Reset()
- func (x *UpdateResourceResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( GetDevicesRequest_Status_name = map[int32]string{ 0: "ONLINE", 1: "OFFLINE", } GetDevicesRequest_Status_value = map[string]int32{ "ONLINE": 0, "OFFLINE": 1, } )
Enum value maps for GetDevicesRequest_Status.
var ( SubscribeToEvents_CreateSubscription_Event_name = map[int32]string{ 0: "REGISTERED", 1: "UNREGISTERED", 4: "DEVICE_METADATA_UPDATED", 5: "DEVICE_METADATA_UPDATE_PENDING", 6: "RESOURCE_PUBLISHED", 7: "RESOURCE_UNPUBLISHED", 8: "RESOURCE_UPDATE_PENDING", 9: "RESOURCE_UPDATED", 10: "RESOURCE_RETRIEVE_PENDING", 11: "RESOURCE_RETRIEVED", 12: "RESOURCE_DELETE_PENDING", 13: "RESOURCE_DELETED", 14: "RESOURCE_CREATE_PENDING", 15: "RESOURCE_CREATED", 16: "RESOURCE_CHANGED", } SubscribeToEvents_CreateSubscription_Event_value = map[string]int32{ "REGISTERED": 0, "UNREGISTERED": 1, "DEVICE_METADATA_UPDATED": 4, "DEVICE_METADATA_UPDATE_PENDING": 5, "RESOURCE_PUBLISHED": 6, "RESOURCE_UNPUBLISHED": 7, "RESOURCE_UPDATE_PENDING": 8, "RESOURCE_UPDATED": 9, "RESOURCE_RETRIEVE_PENDING": 10, "RESOURCE_RETRIEVED": 11, "RESOURCE_DELETE_PENDING": 12, "RESOURCE_DELETED": 13, "RESOURCE_CREATE_PENDING": 14, "RESOURCE_CREATED": 15, "RESOURCE_CHANGED": 16, } )
Enum value maps for SubscribeToEvents_CreateSubscription_Event.
var ( Event_OperationProcessed_ErrorStatus_Code_name = map[int32]string{ 0: "OK", 1: "ERROR", 2: "NOT_FOUND", } Event_OperationProcessed_ErrorStatus_Code_value = map[string]int32{ "OK": 0, "ERROR": 1, "NOT_FOUND": 2, } )
Enum value maps for Event_OperationProcessed_ErrorStatus_Code.
var ( GetPendingCommandsRequest_Command_name = map[int32]string{ 0: "RESOURCE_CREATE", 1: "RESOURCE_RETRIEVE", 2: "RESOURCE_UPDATE", 3: "RESOURCE_DELETE", 4: "DEVICE_METADATA_UPDATE", } GetPendingCommandsRequest_Command_value = map[string]int32{ "RESOURCE_CREATE": 0, "RESOURCE_RETRIEVE": 1, "RESOURCE_UPDATE": 2, "RESOURCE_DELETE": 3, "DEVICE_METADATA_UPDATE": 4, } )
Enum value maps for GetPendingCommandsRequest_Command.
var ( UpdateDeviceMetadataRequest_ShadowSynchronization_name = map[int32]string{ 0: "DISABLED", 1: "ENABLED", } UpdateDeviceMetadataRequest_ShadowSynchronization_value = map[string]int32{ "DISABLED": 0, "ENABLED": 1, } )
Enum value maps for UpdateDeviceMetadataRequest_ShadowSynchronization.
var File_github_com_plgd_dev_hub_grpc_gateway_pb_cancelCommands_proto protoreflect.FileDescriptor
var File_github_com_plgd_dev_hub_grpc_gateway_pb_devices_proto protoreflect.FileDescriptor
var File_github_com_plgd_dev_hub_grpc_gateway_pb_events_proto protoreflect.FileDescriptor
var File_github_com_plgd_dev_hub_grpc_gateway_pb_getDevicesMetadata_proto protoreflect.FileDescriptor
var File_github_com_plgd_dev_hub_grpc_gateway_pb_getPendingCommands_proto protoreflect.FileDescriptor
var File_github_com_plgd_dev_hub_grpc_gateway_pb_hubConfiguration_proto protoreflect.FileDescriptor
var File_github_com_plgd_dev_hub_grpc_gateway_pb_updateDeviceMetadata_proto protoreflect.FileDescriptor
var GrpcGateway_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpcgateway.pb.GrpcGateway", HandlerType: (*GrpcGatewayServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "DeleteDevices", Handler: _GrpcGateway_DeleteDevices_Handler, }, { MethodName: "GetResourceFromDevice", Handler: _GrpcGateway_GetResourceFromDevice_Handler, }, { MethodName: "UpdateResource", Handler: _GrpcGateway_UpdateResource_Handler, }, { MethodName: "GetHubConfiguration", Handler: _GrpcGateway_GetHubConfiguration_Handler, }, { MethodName: "DeleteResource", Handler: _GrpcGateway_DeleteResource_Handler, }, { MethodName: "CreateResource", Handler: _GrpcGateway_CreateResource_Handler, }, { MethodName: "UpdateDeviceMetadata", Handler: _GrpcGateway_UpdateDeviceMetadata_Handler, }, { MethodName: "CancelPendingCommands", Handler: _GrpcGateway_CancelPendingCommands_Handler, }, { MethodName: "CancelPendingMetadataUpdates", Handler: _GrpcGateway_CancelPendingMetadataUpdates_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetDevices", Handler: _GrpcGateway_GetDevices_Handler, ServerStreams: true, }, { StreamName: "GetResourceLinks", Handler: _GrpcGateway_GetResourceLinks_Handler, ServerStreams: true, }, { StreamName: "GetResources", Handler: _GrpcGateway_GetResources_Handler, ServerStreams: true, }, { StreamName: "SubscribeToEvents", Handler: _GrpcGateway_SubscribeToEvents_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "GetPendingCommands", Handler: _GrpcGateway_GetPendingCommands_Handler, ServerStreams: true, }, { StreamName: "GetDevicesMetadata", Handler: _GrpcGateway_GetDevicesMetadata_Handler, ServerStreams: true, }, { StreamName: "GetEvents", Handler: _GrpcGateway_GetEvents_Handler, ServerStreams: true, }, }, Metadata: "github.com/plgd-dev/hub/grpc-gateway/pb/service.proto", }
GrpcGateway_ServiceDesc is the grpc.ServiceDesc for GrpcGateway service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGrpcGatewayHandler ¶
func RegisterGrpcGatewayHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterGrpcGatewayHandler registers the http handlers for service GrpcGateway to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterGrpcGatewayHandlerClient ¶
func RegisterGrpcGatewayHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GrpcGatewayClient) error
RegisterGrpcGatewayHandlerClient registers the http handlers for service GrpcGateway to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "GrpcGatewayClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "GrpcGatewayClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "GrpcGatewayClient" to call the correct interceptors.
func RegisterGrpcGatewayHandlerFromEndpoint ¶
func RegisterGrpcGatewayHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterGrpcGatewayHandlerFromEndpoint is same as RegisterGrpcGatewayHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterGrpcGatewayHandlerServer ¶
func RegisterGrpcGatewayHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GrpcGatewayServer) error
RegisterGrpcGatewayHandlerServer registers the http handlers for service GrpcGateway to "mux". UnaryRPC :call GrpcGatewayServer 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 RegisterGrpcGatewayHandlerFromEndpoint instead.
func RegisterGrpcGatewayServer ¶
func RegisterGrpcGatewayServer(s grpc.ServiceRegistrar, srv GrpcGatewayServer)
Types ¶
type CancelPendingCommandsRequest ¶
type CancelPendingCommandsRequest struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationIdFilter []string `protobuf:"bytes,2,rep,name=correlation_id_filter,json=correlationIdFilter,proto3" json:"correlation_id_filter,omitempty"` // empty array means all. // contains filtered or unexported fields }
func (*CancelPendingCommandsRequest) Descriptor
deprecated
func (*CancelPendingCommandsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingCommandsRequest.ProtoReflect.Descriptor instead.
func (*CancelPendingCommandsRequest) GetCorrelationIdFilter ¶
func (x *CancelPendingCommandsRequest) GetCorrelationIdFilter() []string
func (*CancelPendingCommandsRequest) GetResourceId ¶
func (x *CancelPendingCommandsRequest) GetResourceId() *commands.ResourceId
func (*CancelPendingCommandsRequest) ProtoMessage ¶
func (*CancelPendingCommandsRequest) ProtoMessage()
func (*CancelPendingCommandsRequest) ProtoReflect ¶
func (x *CancelPendingCommandsRequest) ProtoReflect() protoreflect.Message
func (*CancelPendingCommandsRequest) Reset ¶
func (x *CancelPendingCommandsRequest) Reset()
func (*CancelPendingCommandsRequest) String ¶
func (x *CancelPendingCommandsRequest) String() string
type CancelPendingCommandsResponse ¶
type CancelPendingCommandsResponse struct { CorrelationIds []string `protobuf:"bytes,1,rep,name=correlation_ids,json=correlationIds,proto3" json:"correlation_ids,omitempty"` // contains filtered or unexported fields }
func (*CancelPendingCommandsResponse) Descriptor
deprecated
func (*CancelPendingCommandsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingCommandsResponse.ProtoReflect.Descriptor instead.
func (*CancelPendingCommandsResponse) GetCorrelationIds ¶
func (x *CancelPendingCommandsResponse) GetCorrelationIds() []string
func (*CancelPendingCommandsResponse) ProtoMessage ¶
func (*CancelPendingCommandsResponse) ProtoMessage()
func (*CancelPendingCommandsResponse) ProtoReflect ¶
func (x *CancelPendingCommandsResponse) ProtoReflect() protoreflect.Message
func (*CancelPendingCommandsResponse) Reset ¶
func (x *CancelPendingCommandsResponse) Reset()
func (*CancelPendingCommandsResponse) String ¶
func (x *CancelPendingCommandsResponse) String() string
type CancelPendingMetadataUpdatesRequest ¶
type CancelPendingMetadataUpdatesRequest struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` CorrelationIdFilter []string `protobuf:"bytes,2,rep,name=correlation_id_filter,json=correlationIdFilter,proto3" json:"correlation_id_filter,omitempty"` // contains filtered or unexported fields }
func (*CancelPendingMetadataUpdatesRequest) Descriptor
deprecated
func (*CancelPendingMetadataUpdatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingMetadataUpdatesRequest.ProtoReflect.Descriptor instead.
func (*CancelPendingMetadataUpdatesRequest) GetCorrelationIdFilter ¶
func (x *CancelPendingMetadataUpdatesRequest) GetCorrelationIdFilter() []string
func (*CancelPendingMetadataUpdatesRequest) GetDeviceId ¶
func (x *CancelPendingMetadataUpdatesRequest) GetDeviceId() string
func (*CancelPendingMetadataUpdatesRequest) ProtoMessage ¶
func (*CancelPendingMetadataUpdatesRequest) ProtoMessage()
func (*CancelPendingMetadataUpdatesRequest) ProtoReflect ¶
func (x *CancelPendingMetadataUpdatesRequest) ProtoReflect() protoreflect.Message
func (*CancelPendingMetadataUpdatesRequest) Reset ¶
func (x *CancelPendingMetadataUpdatesRequest) Reset()
func (*CancelPendingMetadataUpdatesRequest) String ¶
func (x *CancelPendingMetadataUpdatesRequest) String() string
type Content ¶
type Content struct { ContentType string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Content) Descriptor
deprecated
func (*Content) GetContentType ¶
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
func (*Content) ProtoReflect ¶
func (x *Content) ProtoReflect() protoreflect.Message
type CreateResourceRequest ¶
type CreateResourceRequest struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Content *Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` TimeToLive int64 `protobuf:"varint,3,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // command validity in nanoseconds. 0 means forever and minimal value is 100000000 (100ms). // contains filtered or unexported fields }
func (*CreateResourceRequest) Descriptor
deprecated
func (*CreateResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateResourceRequest.ProtoReflect.Descriptor instead.
func (*CreateResourceRequest) GetContent ¶
func (x *CreateResourceRequest) GetContent() *Content
func (*CreateResourceRequest) GetResourceId ¶
func (x *CreateResourceRequest) GetResourceId() *commands.ResourceId
func (*CreateResourceRequest) GetTimeToLive ¶
func (x *CreateResourceRequest) GetTimeToLive() int64
func (*CreateResourceRequest) ProtoMessage ¶
func (*CreateResourceRequest) ProtoMessage()
func (*CreateResourceRequest) ProtoReflect ¶
func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message
func (*CreateResourceRequest) Reset ¶
func (x *CreateResourceRequest) Reset()
func (*CreateResourceRequest) String ¶
func (x *CreateResourceRequest) String() string
func (*CreateResourceRequest) ToRACommand ¶
func (req *CreateResourceRequest) ToRACommand(ctx context.Context) (*commands.CreateResourceRequest, error)
type CreateResourceResponse ¶
type CreateResourceResponse struct { Data *events.ResourceCreated `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*CreateResourceResponse) Descriptor
deprecated
func (*CreateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResourceResponse.ProtoReflect.Descriptor instead.
func (*CreateResourceResponse) GetData ¶
func (x *CreateResourceResponse) GetData() *events.ResourceCreated
func (*CreateResourceResponse) ProtoMessage ¶
func (*CreateResourceResponse) ProtoMessage()
func (*CreateResourceResponse) ProtoReflect ¶
func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message
func (*CreateResourceResponse) Reset ¶
func (x *CreateResourceResponse) Reset()
func (*CreateResourceResponse) String ¶
func (x *CreateResourceResponse) String() string
type DeleteDevicesRequest ¶
type DeleteDevicesRequest struct { DeviceIdFilter []string `protobuf:"bytes,1,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` // contains filtered or unexported fields }
func (*DeleteDevicesRequest) Descriptor
deprecated
func (*DeleteDevicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDevicesRequest.ProtoReflect.Descriptor instead.
func (*DeleteDevicesRequest) GetDeviceIdFilter ¶
func (x *DeleteDevicesRequest) GetDeviceIdFilter() []string
func (*DeleteDevicesRequest) ProtoMessage ¶
func (*DeleteDevicesRequest) ProtoMessage()
func (*DeleteDevicesRequest) ProtoReflect ¶
func (x *DeleteDevicesRequest) ProtoReflect() protoreflect.Message
func (*DeleteDevicesRequest) Reset ¶
func (x *DeleteDevicesRequest) Reset()
func (*DeleteDevicesRequest) String ¶
func (x *DeleteDevicesRequest) String() string
type DeleteDevicesResponse ¶
type DeleteDevicesResponse struct { DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteDevicesResponse) Descriptor
deprecated
func (*DeleteDevicesResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDevicesResponse.ProtoReflect.Descriptor instead.
func (*DeleteDevicesResponse) GetDeviceIds ¶
func (x *DeleteDevicesResponse) GetDeviceIds() []string
func (*DeleteDevicesResponse) ProtoMessage ¶
func (*DeleteDevicesResponse) ProtoMessage()
func (*DeleteDevicesResponse) ProtoReflect ¶
func (x *DeleteDevicesResponse) ProtoReflect() protoreflect.Message
func (*DeleteDevicesResponse) Reset ¶
func (x *DeleteDevicesResponse) Reset()
func (*DeleteDevicesResponse) String ¶
func (x *DeleteDevicesResponse) String() string
type DeleteResourceRequest ¶
type DeleteResourceRequest struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` TimeToLive int64 `protobuf:"varint,2,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // command validity in nanoseconds. 0 means forever and minimal value is 100000000 (100ms). // contains filtered or unexported fields }
func (*DeleteResourceRequest) Descriptor
deprecated
func (*DeleteResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResourceRequest.ProtoReflect.Descriptor instead.
func (*DeleteResourceRequest) GetResourceId ¶
func (x *DeleteResourceRequest) GetResourceId() *commands.ResourceId
func (*DeleteResourceRequest) GetTimeToLive ¶
func (x *DeleteResourceRequest) GetTimeToLive() int64
func (*DeleteResourceRequest) ProtoMessage ¶
func (*DeleteResourceRequest) ProtoMessage()
func (*DeleteResourceRequest) ProtoReflect ¶
func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message
func (*DeleteResourceRequest) Reset ¶
func (x *DeleteResourceRequest) Reset()
func (*DeleteResourceRequest) String ¶
func (x *DeleteResourceRequest) String() string
func (*DeleteResourceRequest) ToRACommand ¶
func (req *DeleteResourceRequest) ToRACommand(ctx context.Context) (*commands.DeleteResourceRequest, error)
type DeleteResourceResponse ¶
type DeleteResourceResponse struct { Data *events.ResourceDeleted `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*DeleteResourceResponse) Descriptor
deprecated
func (*DeleteResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResourceResponse.ProtoReflect.Descriptor instead.
func (*DeleteResourceResponse) GetData ¶
func (x *DeleteResourceResponse) GetData() *events.ResourceDeleted
func (*DeleteResourceResponse) ProtoMessage ¶
func (*DeleteResourceResponse) ProtoMessage()
func (*DeleteResourceResponse) ProtoReflect ¶
func (x *DeleteResourceResponse) ProtoReflect() protoreflect.Message
func (*DeleteResourceResponse) Reset ¶
func (x *DeleteResourceResponse) Reset()
func (*DeleteResourceResponse) String ¶
func (x *DeleteResourceResponse) String() string
type Device ¶
type Device struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Types []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Metadata *Device_Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` ManufacturerName []*LocalizedString `protobuf:"bytes,5,rep,name=manufacturer_name,json=manufacturerName,proto3" json:"manufacturer_name,omitempty"` ModelNumber string `protobuf:"bytes,6,opt,name=model_number,json=modelNumber,proto3" json:"model_number,omitempty"` Interfaces []string `protobuf:"bytes,7,rep,name=interfaces,proto3" json:"interfaces,omitempty"` ProtocolIndependentId string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func SchemaDeviceToProto ¶
func (*Device) Descriptor
deprecated
func (*Device) GetInterfaces ¶
func (*Device) GetManufacturerName ¶
func (x *Device) GetManufacturerName() []*LocalizedString
func (*Device) GetMetadata ¶
func (x *Device) GetMetadata() *Device_Metadata
func (*Device) GetModelNumber ¶
func (*Device) GetProtocolIndependentId ¶
func (*Device) ProtoMessage ¶
func (*Device) ProtoMessage()
func (*Device) ProtoReflect ¶
func (x *Device) ProtoReflect() protoreflect.Message
type Device_Metadata ¶
type Device_Metadata struct { Status *commands.ConnectionStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` ShadowSynchronization commands.ShadowSynchronization `` /* 173-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Device_Metadata) Descriptor
deprecated
func (*Device_Metadata) Descriptor() ([]byte, []int)
Deprecated: Use Device_Metadata.ProtoReflect.Descriptor instead.
func (*Device_Metadata) GetShadowSynchronization ¶
func (x *Device_Metadata) GetShadowSynchronization() commands.ShadowSynchronization
func (*Device_Metadata) GetStatus ¶
func (x *Device_Metadata) GetStatus() *commands.ConnectionStatus
func (*Device_Metadata) ProtoMessage ¶
func (*Device_Metadata) ProtoMessage()
func (*Device_Metadata) ProtoReflect ¶
func (x *Device_Metadata) ProtoReflect() protoreflect.Message
func (*Device_Metadata) Reset ¶
func (x *Device_Metadata) Reset()
func (*Device_Metadata) String ¶
func (x *Device_Metadata) String() string
type Event ¶
type Event struct { SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"` // subscription id provided by grpc CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` // Types that are assignable to Type: // *Event_DeviceRegistered_ // *Event_DeviceUnregistered_ // *Event_ResourcePublished // *Event_ResourceUnpublished // *Event_ResourceChanged // *Event_OperationProcessed_ // *Event_SubscriptionCanceled_ // *Event_ResourceUpdatePending // *Event_ResourceUpdated // *Event_ResourceRetrievePending // *Event_ResourceRetrieved // *Event_ResourceDeletePending // *Event_ResourceDeleted // *Event_ResourceCreatePending // *Event_ResourceCreated // *Event_DeviceMetadataUpdatePending // *Event_DeviceMetadataUpdated Type isEvent_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetCorrelationId ¶
func (*Event) GetDeviceMetadataUpdatePending ¶
func (x *Event) GetDeviceMetadataUpdatePending() *events.DeviceMetadataUpdatePending
func (*Event) GetDeviceMetadataUpdated ¶
func (x *Event) GetDeviceMetadataUpdated() *events.DeviceMetadataUpdated
func (*Event) GetDeviceRegistered ¶
func (x *Event) GetDeviceRegistered() *Event_DeviceRegistered
func (*Event) GetDeviceUnregistered ¶
func (x *Event) GetDeviceUnregistered() *Event_DeviceUnregistered
func (*Event) GetOperationProcessed ¶
func (x *Event) GetOperationProcessed() *Event_OperationProcessed
func (*Event) GetResourceChanged ¶
func (x *Event) GetResourceChanged() *events.ResourceChanged
func (*Event) GetResourceCreatePending ¶
func (x *Event) GetResourceCreatePending() *events.ResourceCreatePending
func (*Event) GetResourceCreated ¶
func (x *Event) GetResourceCreated() *events.ResourceCreated
func (*Event) GetResourceDeletePending ¶
func (x *Event) GetResourceDeletePending() *events.ResourceDeletePending
func (*Event) GetResourceDeleted ¶
func (x *Event) GetResourceDeleted() *events.ResourceDeleted
func (*Event) GetResourcePublished ¶
func (x *Event) GetResourcePublished() *events.ResourceLinksPublished
func (*Event) GetResourceRetrievePending ¶
func (x *Event) GetResourceRetrievePending() *events.ResourceRetrievePending
func (*Event) GetResourceRetrieved ¶
func (x *Event) GetResourceRetrieved() *events.ResourceRetrieved
func (*Event) GetResourceUnpublished ¶
func (x *Event) GetResourceUnpublished() *events.ResourceLinksUnpublished
func (*Event) GetResourceUpdatePending ¶
func (x *Event) GetResourceUpdatePending() *events.ResourceUpdatePending
func (*Event) GetResourceUpdated ¶
func (x *Event) GetResourceUpdated() *events.ResourceUpdated
func (*Event) GetSubscriptionCanceled ¶
func (x *Event) GetSubscriptionCanceled() *Event_SubscriptionCanceled
func (*Event) GetSubscriptionId ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type Event_DeviceMetadataUpdatePending ¶
type Event_DeviceMetadataUpdatePending struct {
DeviceMetadataUpdatePending *events.DeviceMetadataUpdatePending `protobuf:"bytes,20,opt,name=device_metadata_update_pending,json=deviceMetadataUpdatePending,proto3,oneof"`
}
type Event_DeviceMetadataUpdated ¶
type Event_DeviceMetadataUpdated struct {
DeviceMetadataUpdated *events.DeviceMetadataUpdated `protobuf:"bytes,21,opt,name=device_metadata_updated,json=deviceMetadataUpdated,proto3,oneof"`
}
type Event_DeviceRegistered ¶
type Event_DeviceRegistered struct { DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Event_DeviceRegistered) Descriptor
deprecated
func (*Event_DeviceRegistered) Descriptor() ([]byte, []int)
Deprecated: Use Event_DeviceRegistered.ProtoReflect.Descriptor instead.
func (*Event_DeviceRegistered) GetDeviceIds ¶
func (x *Event_DeviceRegistered) GetDeviceIds() []string
func (*Event_DeviceRegistered) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *Event_DeviceRegistered) GetOpenTelemetryCarrier() map[string]string
func (*Event_DeviceRegistered) ProtoMessage ¶
func (*Event_DeviceRegistered) ProtoMessage()
func (*Event_DeviceRegistered) ProtoReflect ¶
func (x *Event_DeviceRegistered) ProtoReflect() protoreflect.Message
func (*Event_DeviceRegistered) Reset ¶
func (x *Event_DeviceRegistered) Reset()
func (*Event_DeviceRegistered) String ¶
func (x *Event_DeviceRegistered) String() string
type Event_DeviceRegistered_ ¶
type Event_DeviceRegistered_ struct {
DeviceRegistered *Event_DeviceRegistered `protobuf:"bytes,3,opt,name=device_registered,json=deviceRegistered,proto3,oneof"`
}
type Event_DeviceUnregistered ¶
type Event_DeviceUnregistered struct { DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Event_DeviceUnregistered) Descriptor
deprecated
func (*Event_DeviceUnregistered) Descriptor() ([]byte, []int)
Deprecated: Use Event_DeviceUnregistered.ProtoReflect.Descriptor instead.
func (*Event_DeviceUnregistered) GetDeviceIds ¶
func (x *Event_DeviceUnregistered) GetDeviceIds() []string
func (*Event_DeviceUnregistered) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *Event_DeviceUnregistered) GetOpenTelemetryCarrier() map[string]string
func (*Event_DeviceUnregistered) ProtoMessage ¶
func (*Event_DeviceUnregistered) ProtoMessage()
func (*Event_DeviceUnregistered) ProtoReflect ¶
func (x *Event_DeviceUnregistered) ProtoReflect() protoreflect.Message
func (*Event_DeviceUnregistered) Reset ¶
func (x *Event_DeviceUnregistered) Reset()
func (*Event_DeviceUnregistered) String ¶
func (x *Event_DeviceUnregistered) String() string
type Event_DeviceUnregistered_ ¶
type Event_DeviceUnregistered_ struct {
DeviceUnregistered *Event_DeviceUnregistered `protobuf:"bytes,4,opt,name=device_unregistered,json=deviceUnregistered,proto3,oneof"`
}
type Event_OperationProcessed ¶
type Event_OperationProcessed struct { ErrorStatus *Event_OperationProcessed_ErrorStatus `protobuf:"bytes,2,opt,name=error_status,json=errorStatus,proto3" json:"error_status,omitempty"` // contains filtered or unexported fields }
func (*Event_OperationProcessed) Descriptor
deprecated
func (*Event_OperationProcessed) Descriptor() ([]byte, []int)
Deprecated: Use Event_OperationProcessed.ProtoReflect.Descriptor instead.
func (*Event_OperationProcessed) GetErrorStatus ¶
func (x *Event_OperationProcessed) GetErrorStatus() *Event_OperationProcessed_ErrorStatus
func (*Event_OperationProcessed) ProtoMessage ¶
func (*Event_OperationProcessed) ProtoMessage()
func (*Event_OperationProcessed) ProtoReflect ¶
func (x *Event_OperationProcessed) ProtoReflect() protoreflect.Message
func (*Event_OperationProcessed) Reset ¶
func (x *Event_OperationProcessed) Reset()
func (*Event_OperationProcessed) String ¶
func (x *Event_OperationProcessed) String() string
type Event_OperationProcessed_ ¶
type Event_OperationProcessed_ struct {
OperationProcessed *Event_OperationProcessed `protobuf:"bytes,10,opt,name=operation_processed,json=operationProcessed,proto3,oneof"`
}
type Event_OperationProcessed_ErrorStatus ¶
type Event_OperationProcessed_ErrorStatus struct { Code Event_OperationProcessed_ErrorStatus_Code `protobuf:"varint,1,opt,name=code,proto3,enum=grpcgateway.pb.Event_OperationProcessed_ErrorStatus_Code" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Event_OperationProcessed_ErrorStatus) Descriptor
deprecated
func (*Event_OperationProcessed_ErrorStatus) Descriptor() ([]byte, []int)
Deprecated: Use Event_OperationProcessed_ErrorStatus.ProtoReflect.Descriptor instead.
func (*Event_OperationProcessed_ErrorStatus) GetCode ¶
func (x *Event_OperationProcessed_ErrorStatus) GetCode() Event_OperationProcessed_ErrorStatus_Code
func (*Event_OperationProcessed_ErrorStatus) GetMessage ¶
func (x *Event_OperationProcessed_ErrorStatus) GetMessage() string
func (*Event_OperationProcessed_ErrorStatus) ProtoMessage ¶
func (*Event_OperationProcessed_ErrorStatus) ProtoMessage()
func (*Event_OperationProcessed_ErrorStatus) ProtoReflect ¶
func (x *Event_OperationProcessed_ErrorStatus) ProtoReflect() protoreflect.Message
func (*Event_OperationProcessed_ErrorStatus) Reset ¶
func (x *Event_OperationProcessed_ErrorStatus) Reset()
func (*Event_OperationProcessed_ErrorStatus) String ¶
func (x *Event_OperationProcessed_ErrorStatus) String() string
type Event_OperationProcessed_ErrorStatus_Code ¶
type Event_OperationProcessed_ErrorStatus_Code int32
const ( Event_OperationProcessed_ErrorStatus_OK Event_OperationProcessed_ErrorStatus_Code = 0 Event_OperationProcessed_ErrorStatus_ERROR Event_OperationProcessed_ErrorStatus_Code = 1 Event_OperationProcessed_ErrorStatus_NOT_FOUND Event_OperationProcessed_ErrorStatus_Code = 2 )
func (Event_OperationProcessed_ErrorStatus_Code) Descriptor ¶
func (Event_OperationProcessed_ErrorStatus_Code) Descriptor() protoreflect.EnumDescriptor
func (Event_OperationProcessed_ErrorStatus_Code) EnumDescriptor
deprecated
func (Event_OperationProcessed_ErrorStatus_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use Event_OperationProcessed_ErrorStatus_Code.Descriptor instead.
func (Event_OperationProcessed_ErrorStatus_Code) Number ¶
func (x Event_OperationProcessed_ErrorStatus_Code) Number() protoreflect.EnumNumber
func (Event_OperationProcessed_ErrorStatus_Code) String ¶
func (x Event_OperationProcessed_ErrorStatus_Code) String() string
func (Event_OperationProcessed_ErrorStatus_Code) Type ¶
func (Event_OperationProcessed_ErrorStatus_Code) Type() protoreflect.EnumType
type Event_ResourceChanged ¶
type Event_ResourceChanged struct {
ResourceChanged *events.ResourceChanged `protobuf:"bytes,9,opt,name=resource_changed,json=resourceChanged,proto3,oneof"`
}
type Event_ResourceCreatePending ¶
type Event_ResourceCreatePending struct {
ResourceCreatePending *events.ResourceCreatePending `protobuf:"bytes,18,opt,name=resource_create_pending,json=resourceCreatePending,proto3,oneof"`
}
type Event_ResourceCreated ¶
type Event_ResourceCreated struct {
ResourceCreated *events.ResourceCreated `protobuf:"bytes,19,opt,name=resource_created,json=resourceCreated,proto3,oneof"`
}
type Event_ResourceDeletePending ¶
type Event_ResourceDeletePending struct {
ResourceDeletePending *events.ResourceDeletePending `protobuf:"bytes,16,opt,name=resource_delete_pending,json=resourceDeletePending,proto3,oneof"`
}
type Event_ResourceDeleted ¶
type Event_ResourceDeleted struct {
ResourceDeleted *events.ResourceDeleted `protobuf:"bytes,17,opt,name=resource_deleted,json=resourceDeleted,proto3,oneof"`
}
type Event_ResourcePublished ¶
type Event_ResourcePublished struct {
ResourcePublished *events.ResourceLinksPublished `protobuf:"bytes,7,opt,name=resource_published,json=resourcePublished,proto3,oneof"`
}
type Event_ResourceRetrievePending ¶
type Event_ResourceRetrievePending struct {
ResourceRetrievePending *events.ResourceRetrievePending `protobuf:"bytes,14,opt,name=resource_retrieve_pending,json=resourceRetrievePending,proto3,oneof"`
}
type Event_ResourceRetrieved ¶
type Event_ResourceRetrieved struct {
ResourceRetrieved *events.ResourceRetrieved `protobuf:"bytes,15,opt,name=resource_retrieved,json=resourceRetrieved,proto3,oneof"`
}
type Event_ResourceUnpublished ¶
type Event_ResourceUnpublished struct {
ResourceUnpublished *events.ResourceLinksUnpublished `protobuf:"bytes,8,opt,name=resource_unpublished,json=resourceUnpublished,proto3,oneof"`
}
type Event_ResourceUpdatePending ¶
type Event_ResourceUpdatePending struct {
ResourceUpdatePending *events.ResourceUpdatePending `protobuf:"bytes,12,opt,name=resource_update_pending,json=resourceUpdatePending,proto3,oneof"`
}
type Event_ResourceUpdated ¶
type Event_ResourceUpdated struct {
ResourceUpdated *events.ResourceUpdated `protobuf:"bytes,13,opt,name=resource_updated,json=resourceUpdated,proto3,oneof"`
}
type Event_SubscriptionCanceled ¶
type Event_SubscriptionCanceled struct { Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*Event_SubscriptionCanceled) Descriptor
deprecated
func (*Event_SubscriptionCanceled) Descriptor() ([]byte, []int)
Deprecated: Use Event_SubscriptionCanceled.ProtoReflect.Descriptor instead.
func (*Event_SubscriptionCanceled) GetReason ¶
func (x *Event_SubscriptionCanceled) GetReason() string
func (*Event_SubscriptionCanceled) ProtoMessage ¶
func (*Event_SubscriptionCanceled) ProtoMessage()
func (*Event_SubscriptionCanceled) ProtoReflect ¶
func (x *Event_SubscriptionCanceled) ProtoReflect() protoreflect.Message
func (*Event_SubscriptionCanceled) Reset ¶
func (x *Event_SubscriptionCanceled) Reset()
func (*Event_SubscriptionCanceled) String ¶
func (x *Event_SubscriptionCanceled) String() string
type Event_SubscriptionCanceled_ ¶
type Event_SubscriptionCanceled_ struct {
SubscriptionCanceled *Event_SubscriptionCanceled `protobuf:"bytes,11,opt,name=subscription_canceled,json=subscriptionCanceled,proto3,oneof"`
}
type GetDevicesMetadataRequest ¶
type GetDevicesMetadataRequest struct { DeviceIdFilter []string `protobuf:"bytes,1,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` TypeFilter []string `protobuf:"bytes,2,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"` // contains filtered or unexported fields }
func (*GetDevicesMetadataRequest) Descriptor
deprecated
func (*GetDevicesMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDevicesMetadataRequest.ProtoReflect.Descriptor instead.
func (*GetDevicesMetadataRequest) GetDeviceIdFilter ¶
func (x *GetDevicesMetadataRequest) GetDeviceIdFilter() []string
func (*GetDevicesMetadataRequest) GetTypeFilter ¶
func (x *GetDevicesMetadataRequest) GetTypeFilter() []string
func (*GetDevicesMetadataRequest) ProtoMessage ¶
func (*GetDevicesMetadataRequest) ProtoMessage()
func (*GetDevicesMetadataRequest) ProtoReflect ¶
func (x *GetDevicesMetadataRequest) ProtoReflect() protoreflect.Message
func (*GetDevicesMetadataRequest) Reset ¶
func (x *GetDevicesMetadataRequest) Reset()
func (*GetDevicesMetadataRequest) String ¶
func (x *GetDevicesMetadataRequest) String() string
type GetDevicesRequest ¶
type GetDevicesRequest struct { TypeFilter []string `protobuf:"bytes,1,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"` StatusFilter []GetDevicesRequest_Status `` /* 150-byte string literal not displayed */ DeviceIdFilter []string `protobuf:"bytes,3,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` // contains filtered or unexported fields }
func (*GetDevicesRequest) Descriptor
deprecated
func (*GetDevicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDevicesRequest.ProtoReflect.Descriptor instead.
func (*GetDevicesRequest) GetDeviceIdFilter ¶
func (x *GetDevicesRequest) GetDeviceIdFilter() []string
func (*GetDevicesRequest) GetStatusFilter ¶
func (x *GetDevicesRequest) GetStatusFilter() []GetDevicesRequest_Status
func (*GetDevicesRequest) GetTypeFilter ¶
func (x *GetDevicesRequest) GetTypeFilter() []string
func (*GetDevicesRequest) ProtoMessage ¶
func (*GetDevicesRequest) ProtoMessage()
func (*GetDevicesRequest) ProtoReflect ¶
func (x *GetDevicesRequest) ProtoReflect() protoreflect.Message
func (*GetDevicesRequest) Reset ¶
func (x *GetDevicesRequest) Reset()
func (*GetDevicesRequest) String ¶
func (x *GetDevicesRequest) String() string
type GetDevicesRequest_Status ¶
type GetDevicesRequest_Status int32
const ( GetDevicesRequest_ONLINE GetDevicesRequest_Status = 0 GetDevicesRequest_OFFLINE GetDevicesRequest_Status = 1 )
func (GetDevicesRequest_Status) Descriptor ¶
func (GetDevicesRequest_Status) Descriptor() protoreflect.EnumDescriptor
func (GetDevicesRequest_Status) Enum ¶
func (x GetDevicesRequest_Status) Enum() *GetDevicesRequest_Status
func (GetDevicesRequest_Status) EnumDescriptor
deprecated
func (GetDevicesRequest_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use GetDevicesRequest_Status.Descriptor instead.
func (GetDevicesRequest_Status) Number ¶
func (x GetDevicesRequest_Status) Number() protoreflect.EnumNumber
func (GetDevicesRequest_Status) String ¶
func (x GetDevicesRequest_Status) String() string
func (GetDevicesRequest_Status) Type ¶
func (GetDevicesRequest_Status) Type() protoreflect.EnumType
type GetEventsRequest ¶
type GetEventsRequest struct { DeviceIdFilter []string `protobuf:"bytes,1,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` // format {deviceID}{href}. eg "ae424c58-e517-4494-6de7-583536c48213/oic/d" ResourceIdFilter []string `protobuf:"bytes,2,rep,name=resource_id_filter,json=resourceIdFilter,proto3" json:"resource_id_filter,omitempty"` // filter events with timestamp > than given value TimestampFilter int64 `protobuf:"varint,3,opt,name=timestamp_filter,json=timestampFilter,proto3" json:"timestamp_filter,omitempty"` // contains filtered or unexported fields }
func (*GetEventsRequest) Descriptor
deprecated
func (*GetEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.
func (*GetEventsRequest) GetDeviceIdFilter ¶
func (x *GetEventsRequest) GetDeviceIdFilter() []string
func (*GetEventsRequest) GetResourceIdFilter ¶
func (x *GetEventsRequest) GetResourceIdFilter() []string
func (*GetEventsRequest) GetTimestampFilter ¶
func (x *GetEventsRequest) GetTimestampFilter() int64
func (*GetEventsRequest) ProtoMessage ¶
func (*GetEventsRequest) ProtoMessage()
func (*GetEventsRequest) ProtoReflect ¶
func (x *GetEventsRequest) ProtoReflect() protoreflect.Message
func (*GetEventsRequest) Reset ¶
func (x *GetEventsRequest) Reset()
func (*GetEventsRequest) String ¶
func (x *GetEventsRequest) String() string
type GetEventsResponse ¶
type GetEventsResponse struct { // Types that are assignable to Type: // *GetEventsResponse_ResourceLinksPublished // *GetEventsResponse_ResourceLinksUnpublished // *GetEventsResponse_ResourceLinksSnapshotTaken // *GetEventsResponse_ResourceChanged // *GetEventsResponse_ResourceUpdatePending // *GetEventsResponse_ResourceUpdated // *GetEventsResponse_ResourceRetrievePending // *GetEventsResponse_ResourceRetrieved // *GetEventsResponse_ResourceDeletePending // *GetEventsResponse_ResourceDeleted // *GetEventsResponse_ResourceCreatePending // *GetEventsResponse_ResourceCreated // *GetEventsResponse_ResourceStateSnapshotTaken // *GetEventsResponse_DeviceMetadataUpdatePending // *GetEventsResponse_DeviceMetadataUpdated // *GetEventsResponse_DeviceMetadataSnapshotTaken Type isGetEventsResponse_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*GetEventsResponse) Descriptor
deprecated
func (*GetEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEventsResponse.ProtoReflect.Descriptor instead.
func (*GetEventsResponse) GetDeviceMetadataSnapshotTaken ¶
func (x *GetEventsResponse) GetDeviceMetadataSnapshotTaken() *events.DeviceMetadataSnapshotTaken
func (*GetEventsResponse) GetDeviceMetadataUpdatePending ¶
func (x *GetEventsResponse) GetDeviceMetadataUpdatePending() *events.DeviceMetadataUpdatePending
func (*GetEventsResponse) GetDeviceMetadataUpdated ¶
func (x *GetEventsResponse) GetDeviceMetadataUpdated() *events.DeviceMetadataUpdated
func (*GetEventsResponse) GetResourceChanged ¶
func (x *GetEventsResponse) GetResourceChanged() *events.ResourceChanged
func (*GetEventsResponse) GetResourceCreatePending ¶
func (x *GetEventsResponse) GetResourceCreatePending() *events.ResourceCreatePending
func (*GetEventsResponse) GetResourceCreated ¶
func (x *GetEventsResponse) GetResourceCreated() *events.ResourceCreated
func (*GetEventsResponse) GetResourceDeletePending ¶
func (x *GetEventsResponse) GetResourceDeletePending() *events.ResourceDeletePending
func (*GetEventsResponse) GetResourceDeleted ¶
func (x *GetEventsResponse) GetResourceDeleted() *events.ResourceDeleted
func (*GetEventsResponse) GetResourceLinksPublished ¶
func (x *GetEventsResponse) GetResourceLinksPublished() *events.ResourceLinksPublished
func (*GetEventsResponse) GetResourceLinksSnapshotTaken ¶
func (x *GetEventsResponse) GetResourceLinksSnapshotTaken() *events.ResourceLinksSnapshotTaken
func (*GetEventsResponse) GetResourceLinksUnpublished ¶
func (x *GetEventsResponse) GetResourceLinksUnpublished() *events.ResourceLinksUnpublished
func (*GetEventsResponse) GetResourceRetrievePending ¶
func (x *GetEventsResponse) GetResourceRetrievePending() *events.ResourceRetrievePending
func (*GetEventsResponse) GetResourceRetrieved ¶
func (x *GetEventsResponse) GetResourceRetrieved() *events.ResourceRetrieved
func (*GetEventsResponse) GetResourceStateSnapshotTaken ¶
func (x *GetEventsResponse) GetResourceStateSnapshotTaken() *events.ResourceStateSnapshotTaken
func (*GetEventsResponse) GetResourceUpdatePending ¶
func (x *GetEventsResponse) GetResourceUpdatePending() *events.ResourceUpdatePending
func (*GetEventsResponse) GetResourceUpdated ¶
func (x *GetEventsResponse) GetResourceUpdated() *events.ResourceUpdated
func (*GetEventsResponse) GetType ¶
func (m *GetEventsResponse) GetType() isGetEventsResponse_Type
func (*GetEventsResponse) ProtoMessage ¶
func (*GetEventsResponse) ProtoMessage()
func (*GetEventsResponse) ProtoReflect ¶
func (x *GetEventsResponse) ProtoReflect() protoreflect.Message
func (*GetEventsResponse) Reset ¶
func (x *GetEventsResponse) Reset()
func (*GetEventsResponse) String ¶
func (x *GetEventsResponse) String() string
type GetEventsResponse_DeviceMetadataSnapshotTaken ¶
type GetEventsResponse_DeviceMetadataSnapshotTaken struct {
DeviceMetadataSnapshotTaken *events.DeviceMetadataSnapshotTaken `protobuf:"bytes,16,opt,name=device_metadata_snapshot_taken,json=deviceMetadataSnapshotTaken,proto3,oneof"`
}
type GetEventsResponse_DeviceMetadataUpdatePending ¶
type GetEventsResponse_DeviceMetadataUpdatePending struct {
DeviceMetadataUpdatePending *events.DeviceMetadataUpdatePending `protobuf:"bytes,14,opt,name=device_metadata_update_pending,json=deviceMetadataUpdatePending,proto3,oneof"`
}
type GetEventsResponse_DeviceMetadataUpdated ¶
type GetEventsResponse_DeviceMetadataUpdated struct {
DeviceMetadataUpdated *events.DeviceMetadataUpdated `protobuf:"bytes,15,opt,name=device_metadata_updated,json=deviceMetadataUpdated,proto3,oneof"`
}
type GetEventsResponse_ResourceChanged ¶
type GetEventsResponse_ResourceChanged struct {
ResourceChanged *events.ResourceChanged `protobuf:"bytes,4,opt,name=resource_changed,json=resourceChanged,proto3,oneof"`
}
type GetEventsResponse_ResourceCreatePending ¶
type GetEventsResponse_ResourceCreatePending struct {
ResourceCreatePending *events.ResourceCreatePending `protobuf:"bytes,11,opt,name=resource_create_pending,json=resourceCreatePending,proto3,oneof"`
}
type GetEventsResponse_ResourceCreated ¶
type GetEventsResponse_ResourceCreated struct {
ResourceCreated *events.ResourceCreated `protobuf:"bytes,12,opt,name=resource_created,json=resourceCreated,proto3,oneof"`
}
type GetEventsResponse_ResourceDeletePending ¶
type GetEventsResponse_ResourceDeletePending struct {
ResourceDeletePending *events.ResourceDeletePending `protobuf:"bytes,9,opt,name=resource_delete_pending,json=resourceDeletePending,proto3,oneof"`
}
type GetEventsResponse_ResourceDeleted ¶
type GetEventsResponse_ResourceDeleted struct {
ResourceDeleted *events.ResourceDeleted `protobuf:"bytes,10,opt,name=resource_deleted,json=resourceDeleted,proto3,oneof"`
}
type GetEventsResponse_ResourceLinksPublished ¶
type GetEventsResponse_ResourceLinksPublished struct {
ResourceLinksPublished *events.ResourceLinksPublished `protobuf:"bytes,1,opt,name=resource_links_published,json=resourceLinksPublished,proto3,oneof"`
}
type GetEventsResponse_ResourceLinksSnapshotTaken ¶
type GetEventsResponse_ResourceLinksSnapshotTaken struct {
ResourceLinksSnapshotTaken *events.ResourceLinksSnapshotTaken `protobuf:"bytes,3,opt,name=resource_links_snapshot_taken,json=resourceLinksSnapshotTaken,proto3,oneof"`
}
type GetEventsResponse_ResourceLinksUnpublished ¶
type GetEventsResponse_ResourceLinksUnpublished struct {
ResourceLinksUnpublished *events.ResourceLinksUnpublished `protobuf:"bytes,2,opt,name=resource_links_unpublished,json=resourceLinksUnpublished,proto3,oneof"`
}
type GetEventsResponse_ResourceRetrievePending ¶
type GetEventsResponse_ResourceRetrievePending struct {
ResourceRetrievePending *events.ResourceRetrievePending `protobuf:"bytes,7,opt,name=resource_retrieve_pending,json=resourceRetrievePending,proto3,oneof"`
}
type GetEventsResponse_ResourceRetrieved ¶
type GetEventsResponse_ResourceRetrieved struct {
ResourceRetrieved *events.ResourceRetrieved `protobuf:"bytes,8,opt,name=resource_retrieved,json=resourceRetrieved,proto3,oneof"`
}
type GetEventsResponse_ResourceStateSnapshotTaken ¶
type GetEventsResponse_ResourceStateSnapshotTaken struct {
ResourceStateSnapshotTaken *events.ResourceStateSnapshotTaken `protobuf:"bytes,13,opt,name=resource_state_snapshot_taken,json=resourceStateSnapshotTaken,proto3,oneof"`
}
type GetEventsResponse_ResourceUpdatePending ¶
type GetEventsResponse_ResourceUpdatePending struct {
ResourceUpdatePending *events.ResourceUpdatePending `protobuf:"bytes,5,opt,name=resource_update_pending,json=resourceUpdatePending,proto3,oneof"`
}
type GetEventsResponse_ResourceUpdated ¶
type GetEventsResponse_ResourceUpdated struct {
ResourceUpdated *events.ResourceUpdated `protobuf:"bytes,6,opt,name=resource_updated,json=resourceUpdated,proto3,oneof"`
}
type GetPendingCommandsRequest ¶
type GetPendingCommandsRequest struct { CommandFilter []GetPendingCommandsRequest_Command `` /* 162-byte string literal not displayed */ ResourceIdFilter []string `protobuf:"bytes,2,rep,name=resource_id_filter,json=resourceIdFilter,proto3" json:"resource_id_filter,omitempty"` DeviceIdFilter []string `protobuf:"bytes,3,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` TypeFilter []string `protobuf:"bytes,4,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"` // contains filtered or unexported fields }
func (*GetPendingCommandsRequest) Descriptor
deprecated
func (*GetPendingCommandsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPendingCommandsRequest.ProtoReflect.Descriptor instead.
func (*GetPendingCommandsRequest) GetCommandFilter ¶
func (x *GetPendingCommandsRequest) GetCommandFilter() []GetPendingCommandsRequest_Command
func (*GetPendingCommandsRequest) GetDeviceIdFilter ¶
func (x *GetPendingCommandsRequest) GetDeviceIdFilter() []string
func (*GetPendingCommandsRequest) GetResourceIdFilter ¶
func (x *GetPendingCommandsRequest) GetResourceIdFilter() []string
func (*GetPendingCommandsRequest) GetTypeFilter ¶
func (x *GetPendingCommandsRequest) GetTypeFilter() []string
func (*GetPendingCommandsRequest) ProtoMessage ¶
func (*GetPendingCommandsRequest) ProtoMessage()
func (*GetPendingCommandsRequest) ProtoReflect ¶
func (x *GetPendingCommandsRequest) ProtoReflect() protoreflect.Message
func (*GetPendingCommandsRequest) Reset ¶
func (x *GetPendingCommandsRequest) Reset()
func (*GetPendingCommandsRequest) String ¶
func (x *GetPendingCommandsRequest) String() string
type GetPendingCommandsRequest_Command ¶
type GetPendingCommandsRequest_Command int32
const ( GetPendingCommandsRequest_RESOURCE_CREATE GetPendingCommandsRequest_Command = 0 GetPendingCommandsRequest_RESOURCE_RETRIEVE GetPendingCommandsRequest_Command = 1 GetPendingCommandsRequest_RESOURCE_UPDATE GetPendingCommandsRequest_Command = 2 GetPendingCommandsRequest_RESOURCE_DELETE GetPendingCommandsRequest_Command = 3 GetPendingCommandsRequest_DEVICE_METADATA_UPDATE GetPendingCommandsRequest_Command = 4 )
func (GetPendingCommandsRequest_Command) Descriptor ¶
func (GetPendingCommandsRequest_Command) Descriptor() protoreflect.EnumDescriptor
func (GetPendingCommandsRequest_Command) Enum ¶
func (x GetPendingCommandsRequest_Command) Enum() *GetPendingCommandsRequest_Command
func (GetPendingCommandsRequest_Command) EnumDescriptor
deprecated
func (GetPendingCommandsRequest_Command) EnumDescriptor() ([]byte, []int)
Deprecated: Use GetPendingCommandsRequest_Command.Descriptor instead.
func (GetPendingCommandsRequest_Command) Number ¶
func (x GetPendingCommandsRequest_Command) Number() protoreflect.EnumNumber
func (GetPendingCommandsRequest_Command) String ¶
func (x GetPendingCommandsRequest_Command) String() string
func (GetPendingCommandsRequest_Command) Type ¶
func (GetPendingCommandsRequest_Command) Type() protoreflect.EnumType
type GetResourceFromDeviceRequest ¶
type GetResourceFromDeviceRequest struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ResourceInterface string `protobuf:"bytes,2,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"` TimeToLive int64 `protobuf:"varint,3,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // command validity in nanoseconds. 0 means forever and minimal value is 100000000 (100ms). // contains filtered or unexported fields }
func (*GetResourceFromDeviceRequest) Descriptor
deprecated
func (*GetResourceFromDeviceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceFromDeviceRequest.ProtoReflect.Descriptor instead.
func (*GetResourceFromDeviceRequest) GetResourceId ¶
func (x *GetResourceFromDeviceRequest) GetResourceId() *commands.ResourceId
func (*GetResourceFromDeviceRequest) GetResourceInterface ¶
func (x *GetResourceFromDeviceRequest) GetResourceInterface() string
func (*GetResourceFromDeviceRequest) GetTimeToLive ¶
func (x *GetResourceFromDeviceRequest) GetTimeToLive() int64
func (*GetResourceFromDeviceRequest) ProtoMessage ¶
func (*GetResourceFromDeviceRequest) ProtoMessage()
func (*GetResourceFromDeviceRequest) ProtoReflect ¶
func (x *GetResourceFromDeviceRequest) ProtoReflect() protoreflect.Message
func (*GetResourceFromDeviceRequest) Reset ¶
func (x *GetResourceFromDeviceRequest) Reset()
func (*GetResourceFromDeviceRequest) String ¶
func (x *GetResourceFromDeviceRequest) String() string
func (*GetResourceFromDeviceRequest) ToRACommand ¶
func (req *GetResourceFromDeviceRequest) ToRACommand(ctx context.Context) (*commands.RetrieveResourceRequest, error)
type GetResourceFromDeviceResponse ¶
type GetResourceFromDeviceResponse struct { Data *events.ResourceRetrieved `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*GetResourceFromDeviceResponse) Descriptor
deprecated
func (*GetResourceFromDeviceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceFromDeviceResponse.ProtoReflect.Descriptor instead.
func (*GetResourceFromDeviceResponse) GetData ¶
func (x *GetResourceFromDeviceResponse) GetData() *events.ResourceRetrieved
func (*GetResourceFromDeviceResponse) ProtoMessage ¶
func (*GetResourceFromDeviceResponse) ProtoMessage()
func (*GetResourceFromDeviceResponse) ProtoReflect ¶
func (x *GetResourceFromDeviceResponse) ProtoReflect() protoreflect.Message
func (*GetResourceFromDeviceResponse) Reset ¶
func (x *GetResourceFromDeviceResponse) Reset()
func (*GetResourceFromDeviceResponse) String ¶
func (x *GetResourceFromDeviceResponse) String() string
type GetResourceLinksRequest ¶
type GetResourceLinksRequest struct { TypeFilter []string `protobuf:"bytes,1,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"` DeviceIdFilter []string `protobuf:"bytes,2,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` // contains filtered or unexported fields }
func (*GetResourceLinksRequest) Descriptor
deprecated
func (*GetResourceLinksRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceLinksRequest.ProtoReflect.Descriptor instead.
func (*GetResourceLinksRequest) GetDeviceIdFilter ¶
func (x *GetResourceLinksRequest) GetDeviceIdFilter() []string
func (*GetResourceLinksRequest) GetTypeFilter ¶
func (x *GetResourceLinksRequest) GetTypeFilter() []string
func (*GetResourceLinksRequest) ProtoMessage ¶
func (*GetResourceLinksRequest) ProtoMessage()
func (*GetResourceLinksRequest) ProtoReflect ¶
func (x *GetResourceLinksRequest) ProtoReflect() protoreflect.Message
func (*GetResourceLinksRequest) Reset ¶
func (x *GetResourceLinksRequest) Reset()
func (*GetResourceLinksRequest) String ¶
func (x *GetResourceLinksRequest) String() string
type GetResourcesRequest ¶
type GetResourcesRequest struct { ResourceIdFilter []string `protobuf:"bytes,1,rep,name=resource_id_filter,json=resourceIdFilter,proto3" json:"resource_id_filter,omitempty"` // format {deviceID}{href}. eg "ae424c58-e517-4494-6de7-583536c48213/oic/d" DeviceIdFilter []string `protobuf:"bytes,2,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` TypeFilter []string `protobuf:"bytes,3,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"` // contains filtered or unexported fields }
func (*GetResourcesRequest) Descriptor
deprecated
func (*GetResourcesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetResourcesRequest.ProtoReflect.Descriptor instead.
func (*GetResourcesRequest) GetDeviceIdFilter ¶
func (x *GetResourcesRequest) GetDeviceIdFilter() []string
func (*GetResourcesRequest) GetResourceIdFilter ¶
func (x *GetResourcesRequest) GetResourceIdFilter() []string
func (*GetResourcesRequest) GetTypeFilter ¶
func (x *GetResourcesRequest) GetTypeFilter() []string
func (*GetResourcesRequest) ProtoMessage ¶
func (*GetResourcesRequest) ProtoMessage()
func (*GetResourcesRequest) ProtoReflect ¶
func (x *GetResourcesRequest) ProtoReflect() protoreflect.Message
func (*GetResourcesRequest) Reset ¶
func (x *GetResourcesRequest) Reset()
func (*GetResourcesRequest) String ¶
func (x *GetResourcesRequest) String() string
type GrpcGatewayClient ¶
type GrpcGatewayClient interface { // Get all devices GetDevices(ctx context.Context, in *GetDevicesRequest, opts ...grpc.CallOption) (GrpcGateway_GetDevicesClient, error) // Delete selected devices. DeleteDevices(ctx context.Context, in *DeleteDevicesRequest, opts ...grpc.CallOption) (*DeleteDevicesResponse, error) // Get resource links of devices. GetResourceLinks(ctx context.Context, in *GetResourceLinksRequest, opts ...grpc.CallOption) (GrpcGateway_GetResourceLinksClient, error) // Get resource from the device. GetResourceFromDevice(ctx context.Context, in *GetResourceFromDeviceRequest, opts ...grpc.CallOption) (*GetResourceFromDeviceResponse, error) // Get resources from the resource shadow. GetResources(ctx context.Context, in *GetResourcesRequest, opts ...grpc.CallOption) (GrpcGateway_GetResourcesClient, error) // Update resource at the device. UpdateResource(ctx context.Context, in *UpdateResourceRequest, opts ...grpc.CallOption) (*UpdateResourceResponse, error) // When the client creates a subscription. // Subscription doesn't guarantee that all events will be sent to the client. The client is responsible for synchronize events. SubscribeToEvents(ctx context.Context, opts ...grpc.CallOption) (GrpcGateway_SubscribeToEventsClient, error) // Get cloud configuration GetHubConfiguration(ctx context.Context, in *HubConfigurationRequest, opts ...grpc.CallOption) (*HubConfigurationResponse, error) // Delete resource at the device. DeleteResource(ctx context.Context, in *DeleteResourceRequest, opts ...grpc.CallOption) (*DeleteResourceResponse, error) // Create resource at the device. CreateResource(ctx context.Context, in *CreateResourceRequest, opts ...grpc.CallOption) (*CreateResourceResponse, error) // Enables/disables shadow synchronization for device. UpdateDeviceMetadata(ctx context.Context, in *UpdateDeviceMetadataRequest, opts ...grpc.CallOption) (*UpdateDeviceMetadataResponse, error) // Gets pending commands for devices . GetPendingCommands(ctx context.Context, in *GetPendingCommandsRequest, opts ...grpc.CallOption) (GrpcGateway_GetPendingCommandsClient, error) // Cancels resource commands. CancelPendingCommands(ctx context.Context, in *CancelPendingCommandsRequest, opts ...grpc.CallOption) (*CancelPendingCommandsResponse, error) // Cancels device metadata updates. CancelPendingMetadataUpdates(ctx context.Context, in *CancelPendingMetadataUpdatesRequest, opts ...grpc.CallOption) (*CancelPendingCommandsResponse, error) // Gets metadata of the devices. Is contains online/offline or shadown synchronization status. GetDevicesMetadata(ctx context.Context, in *GetDevicesMetadataRequest, opts ...grpc.CallOption) (GrpcGateway_GetDevicesMetadataClient, error) // Get events for given combination of device id, resource id and timestamp GetEvents(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (GrpcGateway_GetEventsClient, error) }
GrpcGatewayClient is the client API for GrpcGateway 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 NewGrpcGatewayClient ¶
func NewGrpcGatewayClient(cc grpc.ClientConnInterface) GrpcGatewayClient
type GrpcGatewayServer ¶
type GrpcGatewayServer interface { // Get all devices GetDevices(*GetDevicesRequest, GrpcGateway_GetDevicesServer) error // Delete selected devices. DeleteDevices(context.Context, *DeleteDevicesRequest) (*DeleteDevicesResponse, error) // Get resource links of devices. GetResourceLinks(*GetResourceLinksRequest, GrpcGateway_GetResourceLinksServer) error // Get resource from the device. GetResourceFromDevice(context.Context, *GetResourceFromDeviceRequest) (*GetResourceFromDeviceResponse, error) // Get resources from the resource shadow. GetResources(*GetResourcesRequest, GrpcGateway_GetResourcesServer) error // Update resource at the device. UpdateResource(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error) // When the client creates a subscription. // Subscription doesn't guarantee that all events will be sent to the client. The client is responsible for synchronize events. SubscribeToEvents(GrpcGateway_SubscribeToEventsServer) error // Get cloud configuration GetHubConfiguration(context.Context, *HubConfigurationRequest) (*HubConfigurationResponse, error) // Delete resource at the device. DeleteResource(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error) // Create resource at the device. CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error) // Enables/disables shadow synchronization for device. UpdateDeviceMetadata(context.Context, *UpdateDeviceMetadataRequest) (*UpdateDeviceMetadataResponse, error) // Gets pending commands for devices . GetPendingCommands(*GetPendingCommandsRequest, GrpcGateway_GetPendingCommandsServer) error // Cancels resource commands. CancelPendingCommands(context.Context, *CancelPendingCommandsRequest) (*CancelPendingCommandsResponse, error) // Cancels device metadata updates. CancelPendingMetadataUpdates(context.Context, *CancelPendingMetadataUpdatesRequest) (*CancelPendingCommandsResponse, error) // Gets metadata of the devices. Is contains online/offline or shadown synchronization status. GetDevicesMetadata(*GetDevicesMetadataRequest, GrpcGateway_GetDevicesMetadataServer) error // Get events for given combination of device id, resource id and timestamp GetEvents(*GetEventsRequest, GrpcGateway_GetEventsServer) error // contains filtered or unexported methods }
GrpcGatewayServer is the server API for GrpcGateway service. All implementations must embed UnimplementedGrpcGatewayServer for forward compatibility
type GrpcGateway_GetDevicesClient ¶
type GrpcGateway_GetDevicesClient interface { Recv() (*Device, error) grpc.ClientStream }
type GrpcGateway_GetDevicesMetadataClient ¶
type GrpcGateway_GetDevicesMetadataClient interface { Recv() (*events.DeviceMetadataUpdated, error) grpc.ClientStream }
type GrpcGateway_GetDevicesMetadataServer ¶
type GrpcGateway_GetDevicesMetadataServer interface { Send(*events.DeviceMetadataUpdated) error grpc.ServerStream }
type GrpcGateway_GetDevicesServer ¶
type GrpcGateway_GetDevicesServer interface { Send(*Device) error grpc.ServerStream }
type GrpcGateway_GetEventsClient ¶
type GrpcGateway_GetEventsClient interface { Recv() (*GetEventsResponse, error) grpc.ClientStream }
type GrpcGateway_GetEventsServer ¶
type GrpcGateway_GetEventsServer interface { Send(*GetEventsResponse) error grpc.ServerStream }
type GrpcGateway_GetPendingCommandsClient ¶
type GrpcGateway_GetPendingCommandsClient interface { Recv() (*PendingCommand, error) grpc.ClientStream }
type GrpcGateway_GetPendingCommandsServer ¶
type GrpcGateway_GetPendingCommandsServer interface { Send(*PendingCommand) error grpc.ServerStream }
type GrpcGateway_GetResourceLinksClient ¶
type GrpcGateway_GetResourceLinksClient interface { Recv() (*events.ResourceLinksPublished, error) grpc.ClientStream }
type GrpcGateway_GetResourceLinksServer ¶
type GrpcGateway_GetResourceLinksServer interface { Send(*events.ResourceLinksPublished) error grpc.ServerStream }
type GrpcGateway_GetResourcesClient ¶
type GrpcGateway_GetResourcesClient interface { Recv() (*Resource, error) grpc.ClientStream }
type GrpcGateway_GetResourcesServer ¶
type GrpcGateway_GetResourcesServer interface { Send(*Resource) error grpc.ServerStream }
type GrpcGateway_SubscribeToEventsClient ¶
type GrpcGateway_SubscribeToEventsClient interface { Send(*SubscribeToEvents) error Recv() (*Event, error) grpc.ClientStream }
type GrpcGateway_SubscribeToEventsServer ¶
type GrpcGateway_SubscribeToEventsServer interface { Send(*Event) error Recv() (*SubscribeToEvents, error) grpc.ServerStream }
type HubConfigurationRequest ¶
type HubConfigurationRequest struct {
// contains filtered or unexported fields
}
func (*HubConfigurationRequest) Descriptor
deprecated
func (*HubConfigurationRequest) Descriptor() ([]byte, []int)
Deprecated: Use HubConfigurationRequest.ProtoReflect.Descriptor instead.
func (*HubConfigurationRequest) ProtoMessage ¶
func (*HubConfigurationRequest) ProtoMessage()
func (*HubConfigurationRequest) ProtoReflect ¶
func (x *HubConfigurationRequest) ProtoReflect() protoreflect.Message
func (*HubConfigurationRequest) Reset ¶
func (x *HubConfigurationRequest) Reset()
func (*HubConfigurationRequest) String ¶
func (x *HubConfigurationRequest) String() string
type HubConfigurationResponse ¶
type HubConfigurationResponse struct { // provides a current time of server in nanoseconds. CurrentTime int64 `protobuf:"varint,1,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"` JwtOwnerClaim string `protobuf:"bytes,2,opt,name=jwt_owner_claim,json=jwtOwnerClaim,proto3" json:"jwt_owner_claim,omitempty"` JwtDeviceIdClaim string `protobuf:"bytes,3,opt,name=jwt_device_id_claim,json=jwtDeviceIdClaim,proto3" json:"jwt_device_id_claim,omitempty"` Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` CoapGateway string `protobuf:"bytes,5,opt,name=coap_gateway,json=coapGateway,proto3" json:"coap_gateway,omitempty"` CertificateAuthorities string `` /* 127-byte string literal not displayed */ AuthorizationServer string `protobuf:"bytes,7,opt,name=authorization_server,json=authorizationServer,proto3" json:"authorization_server,omitempty"` // exposes default command time to live in nanoseconds for CreateResource, RetrieveResource, UpdateResource, DeleteResource, and UpdateDeviceMetadata commands when it is not set in the request. 0 - means forever. DefaultCommandTimeToLive int64 `` /* 140-byte string literal not displayed */ // contains filtered or unexported fields }
func (*HubConfigurationResponse) Descriptor
deprecated
func (*HubConfigurationResponse) Descriptor() ([]byte, []int)
Deprecated: Use HubConfigurationResponse.ProtoReflect.Descriptor instead.
func (*HubConfigurationResponse) GetAuthorizationServer ¶
func (x *HubConfigurationResponse) GetAuthorizationServer() string
func (*HubConfigurationResponse) GetCertificateAuthorities ¶
func (x *HubConfigurationResponse) GetCertificateAuthorities() string
func (*HubConfigurationResponse) GetCoapGateway ¶
func (x *HubConfigurationResponse) GetCoapGateway() string
func (*HubConfigurationResponse) GetCurrentTime ¶
func (x *HubConfigurationResponse) GetCurrentTime() int64
func (*HubConfigurationResponse) GetDefaultCommandTimeToLive ¶
func (x *HubConfigurationResponse) GetDefaultCommandTimeToLive() int64
func (*HubConfigurationResponse) GetId ¶
func (x *HubConfigurationResponse) GetId() string
func (*HubConfigurationResponse) GetJwtDeviceIdClaim ¶
func (x *HubConfigurationResponse) GetJwtDeviceIdClaim() string
func (*HubConfigurationResponse) GetJwtOwnerClaim ¶
func (x *HubConfigurationResponse) GetJwtOwnerClaim() string
func (*HubConfigurationResponse) ProtoMessage ¶
func (*HubConfigurationResponse) ProtoMessage()
func (*HubConfigurationResponse) ProtoReflect ¶
func (x *HubConfigurationResponse) ProtoReflect() protoreflect.Message
func (*HubConfigurationResponse) Reset ¶
func (x *HubConfigurationResponse) Reset()
func (*HubConfigurationResponse) String ¶
func (x *HubConfigurationResponse) String() string
type LocalizedString ¶
type LocalizedString struct { Language string `protobuf:"bytes,1,opt,name=language,proto3" json:"language,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func SchemaLocalizedStringToProto ¶
func SchemaLocalizedStringToProto(s device.LocalizedString) *LocalizedString
func SchemaLocalizedStringsToProto ¶
func SchemaLocalizedStringsToProto(s []device.LocalizedString) []*LocalizedString
func (*LocalizedString) Descriptor
deprecated
func (*LocalizedString) Descriptor() ([]byte, []int)
Deprecated: Use LocalizedString.ProtoReflect.Descriptor instead.
func (*LocalizedString) GetLanguage ¶
func (x *LocalizedString) GetLanguage() string
func (*LocalizedString) GetValue ¶
func (x *LocalizedString) GetValue() string
func (*LocalizedString) ProtoMessage ¶
func (*LocalizedString) ProtoMessage()
func (*LocalizedString) ProtoReflect ¶
func (x *LocalizedString) ProtoReflect() protoreflect.Message
func (*LocalizedString) Reset ¶
func (x *LocalizedString) Reset()
func (*LocalizedString) String ¶
func (x *LocalizedString) String() string
func (*LocalizedString) ToSchema ¶
func (l *LocalizedString) ToSchema() device.LocalizedString
type LocalizedStrings ¶
type LocalizedStrings []*LocalizedString
func (LocalizedStrings) ToSchema ¶
func (s LocalizedStrings) ToSchema() []device.LocalizedString
type PendingCommand ¶
type PendingCommand struct { // Types that are assignable to Command: // *PendingCommand_ResourceCreatePending // *PendingCommand_ResourceRetrievePending // *PendingCommand_ResourceUpdatePending // *PendingCommand_ResourceDeletePending // *PendingCommand_DeviceMetadataUpdatePending Command isPendingCommand_Command `protobuf_oneof:"command"` // contains filtered or unexported fields }
func (*PendingCommand) Descriptor
deprecated
func (*PendingCommand) Descriptor() ([]byte, []int)
Deprecated: Use PendingCommand.ProtoReflect.Descriptor instead.
func (*PendingCommand) GetCommand ¶
func (m *PendingCommand) GetCommand() isPendingCommand_Command
func (*PendingCommand) GetDeviceMetadataUpdatePending ¶
func (x *PendingCommand) GetDeviceMetadataUpdatePending() *events.DeviceMetadataUpdatePending
func (*PendingCommand) GetResourceCreatePending ¶
func (x *PendingCommand) GetResourceCreatePending() *events.ResourceCreatePending
func (*PendingCommand) GetResourceDeletePending ¶
func (x *PendingCommand) GetResourceDeletePending() *events.ResourceDeletePending
func (*PendingCommand) GetResourceRetrievePending ¶
func (x *PendingCommand) GetResourceRetrievePending() *events.ResourceRetrievePending
func (*PendingCommand) GetResourceUpdatePending ¶
func (x *PendingCommand) GetResourceUpdatePending() *events.ResourceUpdatePending
func (*PendingCommand) ProtoMessage ¶
func (*PendingCommand) ProtoMessage()
func (*PendingCommand) ProtoReflect ¶
func (x *PendingCommand) ProtoReflect() protoreflect.Message
func (*PendingCommand) Reset ¶
func (x *PendingCommand) Reset()
func (*PendingCommand) String ¶
func (x *PendingCommand) String() string
type PendingCommand_DeviceMetadataUpdatePending ¶
type PendingCommand_DeviceMetadataUpdatePending struct {
DeviceMetadataUpdatePending *events.DeviceMetadataUpdatePending `protobuf:"bytes,5,opt,name=device_metadata_update_pending,json=deviceMetadataUpdatePending,proto3,oneof"`
}
type PendingCommand_ResourceCreatePending ¶
type PendingCommand_ResourceCreatePending struct {
ResourceCreatePending *events.ResourceCreatePending `protobuf:"bytes,1,opt,name=resource_create_pending,json=resourceCreatePending,proto3,oneof"`
}
type PendingCommand_ResourceDeletePending ¶
type PendingCommand_ResourceDeletePending struct {
ResourceDeletePending *events.ResourceDeletePending `protobuf:"bytes,4,opt,name=resource_delete_pending,json=resourceDeletePending,proto3,oneof"`
}
type PendingCommand_ResourceRetrievePending ¶
type PendingCommand_ResourceRetrievePending struct {
ResourceRetrievePending *events.ResourceRetrievePending `protobuf:"bytes,2,opt,name=resource_retrieve_pending,json=resourceRetrievePending,proto3,oneof"`
}
type PendingCommand_ResourceUpdatePending ¶
type PendingCommand_ResourceUpdatePending struct {
ResourceUpdatePending *events.ResourceUpdatePending `protobuf:"bytes,3,opt,name=resource_update_pending,json=resourceUpdatePending,proto3,oneof"`
}
type Resource ¶
type Resource struct { Types []string `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"` Data *events.ResourceChanged `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Resource) Descriptor
deprecated
func (*Resource) GetData ¶
func (x *Resource) GetData() *events.ResourceChanged
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type SubscribeToEvents ¶
type SubscribeToEvents struct { // Types that are assignable to Action: // *SubscribeToEvents_CreateSubscription_ // *SubscribeToEvents_CancelSubscription_ Action isSubscribeToEvents_Action `protobuf_oneof:"action"` CorrelationId string `protobuf:"bytes,101,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` // for pairing request SubscribeToEvents with Event.OperationProcessed // contains filtered or unexported fields }
func (*SubscribeToEvents) Descriptor
deprecated
func (*SubscribeToEvents) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToEvents.ProtoReflect.Descriptor instead.
func (*SubscribeToEvents) GetAction ¶
func (m *SubscribeToEvents) GetAction() isSubscribeToEvents_Action
func (*SubscribeToEvents) GetCancelSubscription ¶
func (x *SubscribeToEvents) GetCancelSubscription() *SubscribeToEvents_CancelSubscription
func (*SubscribeToEvents) GetCorrelationId ¶
func (x *SubscribeToEvents) GetCorrelationId() string
func (*SubscribeToEvents) GetCreateSubscription ¶
func (x *SubscribeToEvents) GetCreateSubscription() *SubscribeToEvents_CreateSubscription
func (*SubscribeToEvents) ProtoMessage ¶
func (*SubscribeToEvents) ProtoMessage()
func (*SubscribeToEvents) ProtoReflect ¶
func (x *SubscribeToEvents) ProtoReflect() protoreflect.Message
func (*SubscribeToEvents) Reset ¶
func (x *SubscribeToEvents) Reset()
func (*SubscribeToEvents) String ¶
func (x *SubscribeToEvents) String() string
type SubscribeToEvents_CancelSubscription ¶
type SubscribeToEvents_CancelSubscription struct { SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"` // contains filtered or unexported fields }
func (*SubscribeToEvents_CancelSubscription) Descriptor
deprecated
func (*SubscribeToEvents_CancelSubscription) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToEvents_CancelSubscription.ProtoReflect.Descriptor instead.
func (*SubscribeToEvents_CancelSubscription) GetSubscriptionId ¶
func (x *SubscribeToEvents_CancelSubscription) GetSubscriptionId() string
func (*SubscribeToEvents_CancelSubscription) ProtoMessage ¶
func (*SubscribeToEvents_CancelSubscription) ProtoMessage()
func (*SubscribeToEvents_CancelSubscription) ProtoReflect ¶
func (x *SubscribeToEvents_CancelSubscription) ProtoReflect() protoreflect.Message
func (*SubscribeToEvents_CancelSubscription) Reset ¶
func (x *SubscribeToEvents_CancelSubscription) Reset()
func (*SubscribeToEvents_CancelSubscription) String ¶
func (x *SubscribeToEvents_CancelSubscription) String() string
type SubscribeToEvents_CancelSubscription_ ¶
type SubscribeToEvents_CancelSubscription_ struct {
CancelSubscription *SubscribeToEvents_CancelSubscription `protobuf:"bytes,2,opt,name=cancel_subscription,json=cancelSubscription,proto3,oneof"`
}
type SubscribeToEvents_CreateSubscription ¶
type SubscribeToEvents_CreateSubscription struct { EventFilter []SubscribeToEvents_CreateSubscription_Event `` /* 165-byte string literal not displayed */ DeviceIdFilter []string `protobuf:"bytes,2,rep,name=device_id_filter,json=deviceIdFilter,proto3" json:"device_id_filter,omitempty"` ResourceIdFilter []string `protobuf:"bytes,3,rep,name=resource_id_filter,json=resourceIdFilter,proto3" json:"resource_id_filter,omitempty"` // format {deviceID}{href}. eg "ae424c58-e517-4494-6de7-583536c48213/oic/d" // contains filtered or unexported fields }
func (*SubscribeToEvents_CreateSubscription) Descriptor
deprecated
func (*SubscribeToEvents_CreateSubscription) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToEvents_CreateSubscription.ProtoReflect.Descriptor instead.
func (*SubscribeToEvents_CreateSubscription) GetDeviceIdFilter ¶
func (x *SubscribeToEvents_CreateSubscription) GetDeviceIdFilter() []string
func (*SubscribeToEvents_CreateSubscription) GetEventFilter ¶
func (x *SubscribeToEvents_CreateSubscription) GetEventFilter() []SubscribeToEvents_CreateSubscription_Event
func (*SubscribeToEvents_CreateSubscription) GetResourceIdFilter ¶
func (x *SubscribeToEvents_CreateSubscription) GetResourceIdFilter() []string
func (*SubscribeToEvents_CreateSubscription) ProtoMessage ¶
func (*SubscribeToEvents_CreateSubscription) ProtoMessage()
func (*SubscribeToEvents_CreateSubscription) ProtoReflect ¶
func (x *SubscribeToEvents_CreateSubscription) ProtoReflect() protoreflect.Message
func (*SubscribeToEvents_CreateSubscription) Reset ¶
func (x *SubscribeToEvents_CreateSubscription) Reset()
func (*SubscribeToEvents_CreateSubscription) String ¶
func (x *SubscribeToEvents_CreateSubscription) String() string
type SubscribeToEvents_CreateSubscription_ ¶
type SubscribeToEvents_CreateSubscription_ struct {
CreateSubscription *SubscribeToEvents_CreateSubscription `protobuf:"bytes,1,opt,name=create_subscription,json=createSubscription,proto3,oneof"`
}
type SubscribeToEvents_CreateSubscription_Event ¶
type SubscribeToEvents_CreateSubscription_Event int32
const ( SubscribeToEvents_CreateSubscription_REGISTERED SubscribeToEvents_CreateSubscription_Event = 0 SubscribeToEvents_CreateSubscription_UNREGISTERED SubscribeToEvents_CreateSubscription_Event = 1 SubscribeToEvents_CreateSubscription_DEVICE_METADATA_UPDATED SubscribeToEvents_CreateSubscription_Event = 4 SubscribeToEvents_CreateSubscription_DEVICE_METADATA_UPDATE_PENDING SubscribeToEvents_CreateSubscription_Event = 5 SubscribeToEvents_CreateSubscription_RESOURCE_PUBLISHED SubscribeToEvents_CreateSubscription_Event = 6 SubscribeToEvents_CreateSubscription_RESOURCE_UNPUBLISHED SubscribeToEvents_CreateSubscription_Event = 7 SubscribeToEvents_CreateSubscription_RESOURCE_UPDATE_PENDING SubscribeToEvents_CreateSubscription_Event = 8 SubscribeToEvents_CreateSubscription_RESOURCE_UPDATED SubscribeToEvents_CreateSubscription_Event = 9 SubscribeToEvents_CreateSubscription_RESOURCE_RETRIEVE_PENDING SubscribeToEvents_CreateSubscription_Event = 10 SubscribeToEvents_CreateSubscription_RESOURCE_RETRIEVED SubscribeToEvents_CreateSubscription_Event = 11 SubscribeToEvents_CreateSubscription_RESOURCE_DELETE_PENDING SubscribeToEvents_CreateSubscription_Event = 12 SubscribeToEvents_CreateSubscription_RESOURCE_DELETED SubscribeToEvents_CreateSubscription_Event = 13 SubscribeToEvents_CreateSubscription_RESOURCE_CREATE_PENDING SubscribeToEvents_CreateSubscription_Event = 14 SubscribeToEvents_CreateSubscription_RESOURCE_CREATED SubscribeToEvents_CreateSubscription_Event = 15 SubscribeToEvents_CreateSubscription_RESOURCE_CHANGED SubscribeToEvents_CreateSubscription_Event = 16 )
func (SubscribeToEvents_CreateSubscription_Event) Descriptor ¶
func (SubscribeToEvents_CreateSubscription_Event) Descriptor() protoreflect.EnumDescriptor
func (SubscribeToEvents_CreateSubscription_Event) EnumDescriptor
deprecated
func (SubscribeToEvents_CreateSubscription_Event) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscribeToEvents_CreateSubscription_Event.Descriptor instead.
func (SubscribeToEvents_CreateSubscription_Event) Number ¶
func (x SubscribeToEvents_CreateSubscription_Event) Number() protoreflect.EnumNumber
func (SubscribeToEvents_CreateSubscription_Event) String ¶
func (x SubscribeToEvents_CreateSubscription_Event) String() string
func (SubscribeToEvents_CreateSubscription_Event) Type ¶
func (SubscribeToEvents_CreateSubscription_Event) Type() protoreflect.EnumType
type UnimplementedGrpcGatewayServer ¶
type UnimplementedGrpcGatewayServer struct { }
UnimplementedGrpcGatewayServer must be embedded to have forward compatible implementations.
func (UnimplementedGrpcGatewayServer) CancelPendingCommands ¶
func (UnimplementedGrpcGatewayServer) CancelPendingCommands(context.Context, *CancelPendingCommandsRequest) (*CancelPendingCommandsResponse, error)
func (UnimplementedGrpcGatewayServer) CancelPendingMetadataUpdates ¶
func (UnimplementedGrpcGatewayServer) CancelPendingMetadataUpdates(context.Context, *CancelPendingMetadataUpdatesRequest) (*CancelPendingCommandsResponse, error)
func (UnimplementedGrpcGatewayServer) CreateResource ¶
func (UnimplementedGrpcGatewayServer) CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
func (UnimplementedGrpcGatewayServer) DeleteDevices ¶
func (UnimplementedGrpcGatewayServer) DeleteDevices(context.Context, *DeleteDevicesRequest) (*DeleteDevicesResponse, error)
func (UnimplementedGrpcGatewayServer) DeleteResource ¶
func (UnimplementedGrpcGatewayServer) DeleteResource(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)
func (UnimplementedGrpcGatewayServer) GetDevices ¶
func (UnimplementedGrpcGatewayServer) GetDevices(*GetDevicesRequest, GrpcGateway_GetDevicesServer) error
func (UnimplementedGrpcGatewayServer) GetDevicesMetadata ¶
func (UnimplementedGrpcGatewayServer) GetDevicesMetadata(*GetDevicesMetadataRequest, GrpcGateway_GetDevicesMetadataServer) error
func (UnimplementedGrpcGatewayServer) GetEvents ¶
func (UnimplementedGrpcGatewayServer) GetEvents(*GetEventsRequest, GrpcGateway_GetEventsServer) error
func (UnimplementedGrpcGatewayServer) GetHubConfiguration ¶
func (UnimplementedGrpcGatewayServer) GetHubConfiguration(context.Context, *HubConfigurationRequest) (*HubConfigurationResponse, error)
func (UnimplementedGrpcGatewayServer) GetPendingCommands ¶
func (UnimplementedGrpcGatewayServer) GetPendingCommands(*GetPendingCommandsRequest, GrpcGateway_GetPendingCommandsServer) error
func (UnimplementedGrpcGatewayServer) GetResourceFromDevice ¶
func (UnimplementedGrpcGatewayServer) GetResourceFromDevice(context.Context, *GetResourceFromDeviceRequest) (*GetResourceFromDeviceResponse, error)
func (UnimplementedGrpcGatewayServer) GetResourceLinks ¶
func (UnimplementedGrpcGatewayServer) GetResourceLinks(*GetResourceLinksRequest, GrpcGateway_GetResourceLinksServer) error
func (UnimplementedGrpcGatewayServer) GetResources ¶
func (UnimplementedGrpcGatewayServer) GetResources(*GetResourcesRequest, GrpcGateway_GetResourcesServer) error
func (UnimplementedGrpcGatewayServer) SubscribeToEvents ¶
func (UnimplementedGrpcGatewayServer) SubscribeToEvents(GrpcGateway_SubscribeToEventsServer) error
func (UnimplementedGrpcGatewayServer) UpdateDeviceMetadata ¶
func (UnimplementedGrpcGatewayServer) UpdateDeviceMetadata(context.Context, *UpdateDeviceMetadataRequest) (*UpdateDeviceMetadataResponse, error)
func (UnimplementedGrpcGatewayServer) UpdateResource ¶
func (UnimplementedGrpcGatewayServer) UpdateResource(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)
type UnsafeGrpcGatewayServer ¶
type UnsafeGrpcGatewayServer interface {
// contains filtered or unexported methods
}
UnsafeGrpcGatewayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GrpcGatewayServer will result in compilation errors.
type UpdateDeviceMetadataRequest ¶
type UpdateDeviceMetadataRequest struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` ShadowSynchronization UpdateDeviceMetadataRequest_ShadowSynchronization `` /* 195-byte string literal not displayed */ TimeToLive int64 `protobuf:"varint,3,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // command validity in nanoseconds. 0 means forever and minimal value is 100000000 (100ms). // contains filtered or unexported fields }
func (*UpdateDeviceMetadataRequest) Descriptor
deprecated
func (*UpdateDeviceMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDeviceMetadataRequest.ProtoReflect.Descriptor instead.
func (*UpdateDeviceMetadataRequest) GetDeviceId ¶
func (x *UpdateDeviceMetadataRequest) GetDeviceId() string
func (*UpdateDeviceMetadataRequest) GetShadowSynchronization ¶
func (x *UpdateDeviceMetadataRequest) GetShadowSynchronization() UpdateDeviceMetadataRequest_ShadowSynchronization
func (*UpdateDeviceMetadataRequest) GetTimeToLive ¶
func (x *UpdateDeviceMetadataRequest) GetTimeToLive() int64
func (*UpdateDeviceMetadataRequest) ProtoMessage ¶
func (*UpdateDeviceMetadataRequest) ProtoMessage()
func (*UpdateDeviceMetadataRequest) ProtoReflect ¶
func (x *UpdateDeviceMetadataRequest) ProtoReflect() protoreflect.Message
func (*UpdateDeviceMetadataRequest) Reset ¶
func (x *UpdateDeviceMetadataRequest) Reset()
func (*UpdateDeviceMetadataRequest) String ¶
func (x *UpdateDeviceMetadataRequest) String() string
func (*UpdateDeviceMetadataRequest) ToRACommand ¶
func (req *UpdateDeviceMetadataRequest) ToRACommand(ctx context.Context) (*commands.UpdateDeviceMetadataRequest, error)
type UpdateDeviceMetadataRequest_ShadowSynchronization ¶
type UpdateDeviceMetadataRequest_ShadowSynchronization int32
const ( UpdateDeviceMetadataRequest_DISABLED UpdateDeviceMetadataRequest_ShadowSynchronization = 0 UpdateDeviceMetadataRequest_ENABLED UpdateDeviceMetadataRequest_ShadowSynchronization = 1 )
func (UpdateDeviceMetadataRequest_ShadowSynchronization) Descriptor ¶
func (UpdateDeviceMetadataRequest_ShadowSynchronization) Descriptor() protoreflect.EnumDescriptor
func (UpdateDeviceMetadataRequest_ShadowSynchronization) EnumDescriptor
deprecated
func (UpdateDeviceMetadataRequest_ShadowSynchronization) EnumDescriptor() ([]byte, []int)
Deprecated: Use UpdateDeviceMetadataRequest_ShadowSynchronization.Descriptor instead.
func (UpdateDeviceMetadataRequest_ShadowSynchronization) Number ¶
func (x UpdateDeviceMetadataRequest_ShadowSynchronization) Number() protoreflect.EnumNumber
func (UpdateDeviceMetadataRequest_ShadowSynchronization) String ¶
func (x UpdateDeviceMetadataRequest_ShadowSynchronization) String() string
type UpdateDeviceMetadataResponse ¶
type UpdateDeviceMetadataResponse struct { Data *events.DeviceMetadataUpdated `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*UpdateDeviceMetadataResponse) Descriptor
deprecated
func (*UpdateDeviceMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDeviceMetadataResponse.ProtoReflect.Descriptor instead.
func (*UpdateDeviceMetadataResponse) GetData ¶
func (x *UpdateDeviceMetadataResponse) GetData() *events.DeviceMetadataUpdated
func (*UpdateDeviceMetadataResponse) ProtoMessage ¶
func (*UpdateDeviceMetadataResponse) ProtoMessage()
func (*UpdateDeviceMetadataResponse) ProtoReflect ¶
func (x *UpdateDeviceMetadataResponse) ProtoReflect() protoreflect.Message
func (*UpdateDeviceMetadataResponse) Reset ¶
func (x *UpdateDeviceMetadataResponse) Reset()
func (*UpdateDeviceMetadataResponse) String ¶
func (x *UpdateDeviceMetadataResponse) String() string
type UpdateResourceRequest ¶
type UpdateResourceRequest struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ResourceInterface string `protobuf:"bytes,3,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"` TimeToLive int64 `protobuf:"varint,4,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // command validity in nanoseconds. 0 means forever and minimal value is 100000000 (100ms). Content *Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*UpdateResourceRequest) Descriptor
deprecated
func (*UpdateResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceRequest.ProtoReflect.Descriptor instead.
func (*UpdateResourceRequest) GetContent ¶
func (x *UpdateResourceRequest) GetContent() *Content
func (*UpdateResourceRequest) GetResourceId ¶
func (x *UpdateResourceRequest) GetResourceId() *commands.ResourceId
func (*UpdateResourceRequest) GetResourceInterface ¶
func (x *UpdateResourceRequest) GetResourceInterface() string
func (*UpdateResourceRequest) GetTimeToLive ¶
func (x *UpdateResourceRequest) GetTimeToLive() int64
func (*UpdateResourceRequest) ProtoMessage ¶
func (*UpdateResourceRequest) ProtoMessage()
func (*UpdateResourceRequest) ProtoReflect ¶
func (x *UpdateResourceRequest) ProtoReflect() protoreflect.Message
func (*UpdateResourceRequest) Reset ¶
func (x *UpdateResourceRequest) Reset()
func (*UpdateResourceRequest) String ¶
func (x *UpdateResourceRequest) String() string
func (*UpdateResourceRequest) ToRACommand ¶
func (req *UpdateResourceRequest) ToRACommand(ctx context.Context) (*commands.UpdateResourceRequest, error)
type UpdateResourceResponse ¶
type UpdateResourceResponse struct { Data *events.ResourceUpdated `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*UpdateResourceResponse) Descriptor
deprecated
func (*UpdateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceResponse.ProtoReflect.Descriptor instead.
func (*UpdateResourceResponse) GetData ¶
func (x *UpdateResourceResponse) GetData() *events.ResourceUpdated
func (*UpdateResourceResponse) ProtoMessage ¶
func (*UpdateResourceResponse) ProtoMessage()
func (*UpdateResourceResponse) ProtoReflect ¶
func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
func (*UpdateResourceResponse) Reset ¶
func (x *UpdateResourceResponse) Reset()
func (*UpdateResourceResponse) String ¶
func (x *UpdateResourceResponse) String() string
Source Files
¶
- cancelCommands.pb.go
- createResource.go
- deleteResource.go
- deviceconv.go
- devices.pb.go
- events.pb.go
- getDevicesMetadata.pb.go
- getPendingCommands.pb.go
- getResourceFromDevice.go
- hubConfiguration.pb.go
- service.pb.gw.go
- service_grpc.pb.go
- updateDeviceMetadata.go
- updateDeviceMetadata.pb.go
- updateResource.go