pb

package

Go to main page

Versions in this module

v2

v2.24.2

Sep 12, 2024

v2.24.1

Sep 9, 2024

v2.24.0

Aug 22, 2024

v2.23.0

Aug 12, 2024

Changes in this version

+ var File_grpc_gateway_pb_service_proto protoreflect.FileDescriptor

type Resource

+ func (r *Resource) Clone() *Resource

v2.22.0

Jul 23, 2024

Changes in this version

type SubscribeToEvents_CreateSubscription

+ LeadResourceTypeFilter []string

+ func (x *SubscribeToEvents_CreateSubscription) GetLeadResourceTypeFilter() []string

v2.21.3

Jul 15, 2024

v2.21.2

Jul 12, 2024

v2.21.1

Jul 11, 2024

Changes in this version

type UIVisibility_MainSidebar

+ SnippetService bool

+ func (x *UIVisibility_MainSidebar) GetSnippetService() bool

v2.21.0

Jul 9, 2024

Changes in this version

type CreateResourceRequest

+ Async bool

+ Force bool

+ func (x *CreateResourceRequest) GetAsync() bool

+ func (x *CreateResourceRequest) GetForce() bool

type CreateResourceResponse

+ func (x *CreateResourceResponse) SetData(data *events.ResourceCreated)

type DeleteResourceRequest

+ Async bool

+ Force bool

+ func (x *DeleteResourceRequest) GetAsync() bool

+ func (x *DeleteResourceRequest) GetForce() bool

type DeleteResourceResponse

+ func (x *DeleteResourceResponse) SetData(data *events.ResourceDeleted)

type GetPendingCommandsRequest

+ IncludeHiddenResources bool

+ func (x *GetPendingCommandsRequest) GetIncludeHiddenResources() bool

type HubConfigurationResponse

+ M2MOauthClient *OAuthClient

+ func (x *HubConfigurationResponse) GetM2MOauthClient() *OAuthClient

+ type OAuthClient struct

+ Audience string

+ Authority string

+ ClientAssertionType string

+ ClientId string

+ GrantType string

+ ProviderName string

+ Scopes []string

+ func (*OAuthClient) Descriptor() ([]byte, []int)

+ func (*OAuthClient) ProtoMessage()

+ func (r *OAuthClient) Clone() *OAuthClient

+ func (x *OAuthClient) GetAudience() string

+ func (x *OAuthClient) GetAuthority() string

+ func (x *OAuthClient) GetClientAssertionType() string

+ func (x *OAuthClient) GetClientId() string

+ func (x *OAuthClient) GetGrantType() string

+ func (x *OAuthClient) GetProviderName() string

+ func (x *OAuthClient) GetScopes() []string

+ func (x *OAuthClient) ProtoReflect() protoreflect.Message

+ func (x *OAuthClient) Reset()

+ func (x *OAuthClient) String() string

type UIConfiguration

+ SnippetService string

+ func (x *UIConfiguration) GetSnippetService() string

type UpdateResourceRequest

+ Async bool

+ Force bool

+ func (x *UpdateResourceRequest) GetAsync() bool

+ func (x *UpdateResourceRequest) GetForce() bool

type UpdateResourceResponse

+ func (x *UpdateResourceResponse) SetData(data *events.ResourceUpdated)

v2.20.0

Jun 27, 2024

v2.19.1

Jun 3, 2024

v2.19.0

May 15, 2024

v2.18.0

Apr 17, 2024

v2.17.3

Mar 27, 2024

v2.17.2

Mar 26, 2024

v2.17.1

Mar 22, 2024

v2.17.0

Mar 8, 2024

v2.16.4

Feb 16, 2024

v2.16.3

Jan 28, 2024

Changes in this version

type HubConfigurationResponse

+ Ui *UIConfiguration

+ func (x *HubConfigurationResponse) GetUi() *UIConfiguration

+ type UIConfiguration struct

+ DeviceProvisioningService string

+ Visibility *UIVisibility

+ func (*UIConfiguration) Descriptor() ([]byte, []int)

+ func (*UIConfiguration) ProtoMessage()

+ func (x *UIConfiguration) GetDeviceProvisioningService() string

+ func (x *UIConfiguration) GetVisibility() *UIVisibility

+ func (x *UIConfiguration) ProtoReflect() protoreflect.Message

+ func (x *UIConfiguration) Reset()

+ func (x *UIConfiguration) String() string

+ type UIVisibility struct

+ MainSidebar *UIVisibility_MainSidebar

+ func (*UIVisibility) Descriptor() ([]byte, []int)

+ func (*UIVisibility) ProtoMessage()

+ func (x *UIVisibility) GetMainSidebar() *UIVisibility_MainSidebar

+ func (x *UIVisibility) ProtoReflect() protoreflect.Message

+ func (x *UIVisibility) Reset()

+ func (x *UIVisibility) String() string

+ type UIVisibility_MainSidebar struct

+ ApiTokens bool

+ Certificates bool

+ ChatRoom bool

+ Configuration bool

+ Dashboard bool

+ DeviceFirmwareUpdate bool

+ DeviceLogs bool

+ DeviceProvisioning bool

+ Devices bool

+ Docs bool

+ Integrations bool

+ PendingCommands bool

+ RemoteClients bool

+ SchemaHub bool

+ func (*UIVisibility_MainSidebar) Descriptor() ([]byte, []int)

+ func (*UIVisibility_MainSidebar) ProtoMessage()

+ func (x *UIVisibility_MainSidebar) GetApiTokens() bool

+ func (x *UIVisibility_MainSidebar) GetCertificates() bool

+ func (x *UIVisibility_MainSidebar) GetChatRoom() bool

+ func (x *UIVisibility_MainSidebar) GetConfiguration() bool

+ func (x *UIVisibility_MainSidebar) GetDashboard() bool

+ func (x *UIVisibility_MainSidebar) GetDeviceFirmwareUpdate() bool

+ func (x *UIVisibility_MainSidebar) GetDeviceLogs() bool

+ func (x *UIVisibility_MainSidebar) GetDeviceProvisioning() bool

+ func (x *UIVisibility_MainSidebar) GetDevices() bool

+ func (x *UIVisibility_MainSidebar) GetDocs() bool

+ func (x *UIVisibility_MainSidebar) GetIntegrations() bool

+ func (x *UIVisibility_MainSidebar) GetPendingCommands() bool

+ func (x *UIVisibility_MainSidebar) GetRemoteClients() bool

+ func (x *UIVisibility_MainSidebar) GetSchemaHub() bool

+ func (x *UIVisibility_MainSidebar) ProtoReflect() protoreflect.Message

+ func (x *UIVisibility_MainSidebar) Reset()

+ func (x *UIVisibility_MainSidebar) String() string

v2.16.2

Jan 13, 2024

v2.16.1

Dec 22, 2023

v2.16.0

Dec 15, 2023

v2.15.0

Dec 7, 2023

v2.14.0

Nov 18, 2023

v2.13.1

Nov 18, 2023

Changes in this version

type DeleteResourceRequest

+ ResourceInterface string

+ func (x *DeleteResourceRequest) GetResourceInterface() string

v2.13.0

Oct 25, 2023

Changes in this version

type GetEventsRequest

+ HttpResourceIdFilter []string

+ func (r *GetEventsRequest) ConvertHTTPResourceIDFilter() []*ResourceIdFilter

+ func (x *GetEventsRequest) GetHttpResourceIdFilter() []string

type GetPendingCommandsRequest

+ HttpResourceIdFilter []string

+ func (r *GetPendingCommandsRequest) ConvertHTTPResourceIDFilter() []*ResourceIdFilter

+ func (x *GetPendingCommandsRequest) GetHttpResourceIdFilter() []string

type GetResourceFromDeviceRequest

+ Etag [][]byte

+ func (x *GetResourceFromDeviceRequest) GetEtag() [][]byte

type GetResourcesRequest

+ HttpResourceIdFilter []string

+ func (r *GetResourcesRequest) ConvertHTTPResourceIDFilter() []*ResourceIdFilter

+ func (x *GetResourcesRequest) GetHttpResourceIdFilter() []string

+ type ResourceIdFilter struct

+ Etag [][]byte

+ ResourceId *commands.ResourceId

+ func ResourceIdFilterFromString(filter []string) []*ResourceIdFilter

+ func (*ResourceIdFilter) Descriptor() ([]byte, []int)

+ func (*ResourceIdFilter) ProtoMessage()

+ func (f *ResourceIdFilter) ToString() string

+ func (x *ResourceIdFilter) GetEtag() [][]byte

+ func (x *ResourceIdFilter) GetResourceId() *commands.ResourceId

+ func (x *ResourceIdFilter) ProtoReflect() protoreflect.Message

+ func (x *ResourceIdFilter) Reset()

+ func (x *ResourceIdFilter) String() string

type SubscribeToEvents_CreateSubscription

+ HttpResourceIdFilter []string

+ func (c *SubscribeToEvents_CreateSubscription) ConvertHTTPResourceIDFilter() []*ResourceIdFilter

+ func (x *SubscribeToEvents_CreateSubscription) GetHttpResourceIdFilter() []string

v2.12.1

Oct 3, 2023

v2.12.0

Sep 29, 2023

v2.11.0

Sep 22, 2023

v2.10.1

Sep 7, 2023

v2.10.0

Sep 6, 2023

Changes in this version

type UpdateDeviceMetadataRequest

+ TwinForceSynchronization bool

+ func (x *UpdateDeviceMetadataRequest) GetTwinForceSynchronization() bool

v2.9.0

Aug 30, 2023

Changes in this version

type Event_DeviceRegistered

+ EventMetadata *events1.EventMetadata

+ func (x *Event_DeviceRegistered) GetEventMetadata() *events1.EventMetadata

type Event_DeviceUnregistered

+ EventMetadata *events1.EventMetadata

+ func (x *Event_DeviceUnregistered) GetEventMetadata() *events1.EventMetadata

type HubConfigurationResponse

+ CertificateAuthority string

+ func (x *HubConfigurationResponse) GetCertificateAuthority() string

v2.8.1

Aug 20, 2023

v2.8.0

Jul 11, 2023

Changes in this version

+ type BuildInfo struct

+ BuildDate string

+ CommitDate string

+ CommitHash string

+ ReleaseUrl string

+ Version string

+ func (*BuildInfo) Descriptor() ([]byte, []int)

+ func (*BuildInfo) ProtoMessage()

+ func (x *BuildInfo) GetBuildDate() string

+ func (x *BuildInfo) GetCommitDate() string

+ func (x *BuildInfo) GetCommitHash() string

+ func (x *BuildInfo) GetReleaseUrl() string

+ func (x *BuildInfo) GetVersion() string

+ func (x *BuildInfo) ProtoReflect() protoreflect.Message

+ func (x *BuildInfo) Reset()

+ func (x *BuildInfo) String() string

type Event_ResourceChanged

+ func (e *Event_ResourceChanged) GetResourceId() *commands.ResourceId

type Event_ResourceCreatePending

+ func (e *Event_ResourceCreatePending) GetResourceId() *commands.ResourceId

type Event_ResourceCreated

+ func (e *Event_ResourceCreated) GetResourceId() *commands.ResourceId

type Event_ResourceDeletePending

+ func (e *Event_ResourceDeletePending) GetResourceId() *commands.ResourceId

type Event_ResourceDeleted

+ func (e *Event_ResourceDeleted) GetResourceId() *commands.ResourceId

type Event_ResourceRetrievePending

+ func (e *Event_ResourceRetrievePending) GetResourceId() *commands.ResourceId

type Event_ResourceRetrieved

+ func (e *Event_ResourceRetrieved) GetResourceId() *commands.ResourceId

type Event_ResourceUpdatePending

+ func (e *Event_ResourceUpdatePending) GetResourceId() *commands.ResourceId

type Event_ResourceUpdated

+ func (e *Event_ResourceUpdated) GetResourceId() *commands.ResourceId

type HubConfigurationResponse

+ BuildInfo *BuildInfo

+ func (x *HubConfigurationResponse) GetBuildInfo() *BuildInfo

type SubscribeToEvents_CreateSubscription

+ HrefFilter []string

+ func (x *SubscribeToEvents_CreateSubscription) GetHrefFilter() []string

v2.7.19

Jun 19, 2023

v2.7.19-test

Jul 6, 2023

v2.7.18

Jun 14, 2023

v2.7.17

Jun 13, 2023

Changes in this version

+ const GrpcGateway_CancelPendingCommands_FullMethodName

+ const GrpcGateway_CancelPendingMetadataUpdates_FullMethodName

+ const GrpcGateway_CreateResource_FullMethodName

+ const GrpcGateway_DeleteDevices_FullMethodName

+ const GrpcGateway_DeleteResource_FullMethodName

+ const GrpcGateway_GetDevicesMetadata_FullMethodName

+ const GrpcGateway_GetDevices_FullMethodName

+ const GrpcGateway_GetEvents_FullMethodName

+ const GrpcGateway_GetHubConfiguration_FullMethodName

+ const GrpcGateway_GetPendingCommands_FullMethodName

+ const GrpcGateway_GetResourceFromDevice_FullMethodName

+ const GrpcGateway_GetResourceLinks_FullMethodName

+ const GrpcGateway_GetResources_FullMethodName

+ const GrpcGateway_SubscribeToEvents_FullMethodName

+ const GrpcGateway_UpdateDeviceMetadata_FullMethodName

+ const GrpcGateway_UpdateResource_FullMethodName

v2.7.16

May 23, 2023

v2.7.15

May 6, 2023

v2.7.14

Apr 27, 2023

v2.7.13

Mar 14, 2023

v2.7.12

Feb 27, 2023

v2.7.11

Feb 8, 2023

v2.7.10

Feb 6, 2023

v2.7.9

Feb 2, 2023

v2.7.8

Feb 1, 2023

v2.7.7

Jan 26, 2023

v2.7.6

Jan 25, 2023

v2.7.5

Jan 17, 2023

v2.7.4

Dec 14, 2022

Changes in this version

type DeviceOAuthClient

+ func (r *DeviceOAuthClient) Clone() *DeviceOAuthClient

type WebOAuthClient

+ func (r *WebOAuthClient) Clone() *WebOAuthClient

v2.7.3

Dec 8, 2022

v2.7.2

Dec 5, 2022

v2.7.1

Nov 29, 2022

v2.7.0

Nov 24, 2022

v2.6.2

Nov 14, 2022

v2.6.1

Nov 10, 2022

v2.6.0

Nov 8, 2022

Changes in this version

type Device_Metadata

+ Connection *commands.Connection

+ TwinEnabled bool

+ TwinSynchronization *commands.TwinSynchronization

+ func (x *Device_Metadata) GetConnection() *commands.Connection

+ func (x *Device_Metadata) GetTwinEnabled() bool

+ func (x *Device_Metadata) GetTwinSynchronization() *commands.TwinSynchronization

type UpdateDeviceMetadataRequest

+ TwinEnabled bool

+ func (x *UpdateDeviceMetadataRequest) GetTwinEnabled() bool

v2.5.1

Oct 9, 2022

v2.5.0

Sep 27, 2022

Changes in this version

+ type DeviceOAuthClient struct

+ Audience string

+ ClientId string

+ ProviderName string

+ Scopes []string

+ func (*DeviceOAuthClient) Descriptor() ([]byte, []int)

+ func (*DeviceOAuthClient) ProtoMessage()

+ func (x *DeviceOAuthClient) GetAudience() string

+ func (x *DeviceOAuthClient) GetClientId() string

+ func (x *DeviceOAuthClient) GetProviderName() string

+ func (x *DeviceOAuthClient) GetScopes() []string

+ func (x *DeviceOAuthClient) ProtoReflect() protoreflect.Message

+ func (x *DeviceOAuthClient) Reset()

+ func (x *DeviceOAuthClient) String() string

type HubConfigurationResponse

+ Authority string

+ DeviceOauthClient *DeviceOAuthClient

+ HttpGatewayAddress string

+ WebOauthClient *WebOAuthClient

+ func (x *HubConfigurationResponse) GetAuthority() string

+ func (x *HubConfigurationResponse) GetDeviceOauthClient() *DeviceOAuthClient

+ func (x *HubConfigurationResponse) GetHttpGatewayAddress() string

+ func (x *HubConfigurationResponse) GetWebOauthClient() *WebOAuthClient

+ type WebOAuthClient struct

+ Audience string

+ ClientId string

+ Scopes []string

+ func (*WebOAuthClient) Descriptor() ([]byte, []int)

+ func (*WebOAuthClient) ProtoMessage()

+ func (x *WebOAuthClient) GetAudience() string

+ func (x *WebOAuthClient) GetClientId() string

+ func (x *WebOAuthClient) GetScopes() []string

+ func (x *WebOAuthClient) ProtoReflect() protoreflect.Message

+ func (x *WebOAuthClient) Reset()

+ func (x *WebOAuthClient) String() string

v2.4.8

Sep 7, 2022

v2.4.7

Aug 16, 2022

v2.4.6

Aug 15, 2022

v2.4.5

Jun 30, 2022

v2.4.4

Jun 15, 2022

Changes in this version

+ var Device_OwnershipStatus_name = map[int32]string

+ var Device_OwnershipStatus_value = map[string]int32

+ var File_grpc_gateway_pb_cancelCommands_proto protoreflect.FileDescriptor

+ var File_grpc_gateway_pb_devices_proto protoreflect.FileDescriptor

+ var File_grpc_gateway_pb_events_proto protoreflect.FileDescriptor

+ var File_grpc_gateway_pb_getDevicesMetadata_proto protoreflect.FileDescriptor

+ var File_grpc_gateway_pb_getPendingCommands_proto protoreflect.FileDescriptor

+ var File_grpc_gateway_pb_hubConfiguration_proto protoreflect.FileDescriptor

+ var File_grpc_gateway_pb_updateDeviceMetadata_proto protoreflect.FileDescriptor

type Device

+ Data *events.ResourceChanged

+ Endpoints []string

+ OwnershipStatus Device_OwnershipStatus

+ func (x *Device) GetData() *events.ResourceChanged

+ func (x *Device) GetEndpoints() []string

+ func (x *Device) GetOwnershipStatus() Device_OwnershipStatus

+ type Device_OwnershipStatus int32

+ const Device_OWNED

+ const Device_UNKNOWN

+ const Device_UNOWNED

+ const Device_UNSUPPORTED

+ func (Device_OwnershipStatus) Descriptor() protoreflect.EnumDescriptor

+ func (Device_OwnershipStatus) EnumDescriptor() ([]byte, []int)

+ func (Device_OwnershipStatus) Type() protoreflect.EnumType

+ func (x Device_OwnershipStatus) Enum() *Device_OwnershipStatus

+ func (x Device_OwnershipStatus) Number() protoreflect.EnumNumber

+ func (x Device_OwnershipStatus) String() string

v2.4.3

May 31, 2022

v2.4.2

May 27, 2022

v2.4.1

May 26, 2022

v2.4.0

May 24, 2022

Changes in this version

type Event_DeviceRegistered

+ OpenTelemetryCarrier map[string]string

+ func (x *Event_DeviceRegistered) GetOpenTelemetryCarrier() map[string]string

type Event_DeviceUnregistered

+ OpenTelemetryCarrier map[string]string

+ func (x *Event_DeviceUnregistered) GetOpenTelemetryCarrier() map[string]string

v2.3.10

May 18, 2022

v2.3.9

May 5, 2022

v2.3.8

Apr 22, 2022

v2.3.7

Apr 21, 2022

v2.3.6

Apr 19, 2022

v2.3.5

Mar 30, 2022

v2.3.4

Mar 30, 2022

v2.3.3

Mar 28, 2022

v2.3.2

Mar 28, 2022

v2.3.1

Mar 17, 2022

v2.3.0

Mar 8, 2022

v2.2.4

Mar 8, 2022

v2.2.3

Jan 12, 2022

Changes in this version

+ var Event_OperationProcessed_ErrorStatus_Code_name = map[int32]string

+ var Event_OperationProcessed_ErrorStatus_Code_value = map[string]int32

+ 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 GetDevicesRequest_Status_name = map[int32]string

+ var GetDevicesRequest_Status_value = map[string]int32

+ var GetPendingCommandsRequest_Command_name = map[int32]string

+ var GetPendingCommandsRequest_Command_value = map[string]int32

+ var GrpcGateway_ServiceDesc = grpc.ServiceDesc

+ var SubscribeToEvents_CreateSubscription_Event_name = map[int32]string

+ var SubscribeToEvents_CreateSubscription_Event_value = map[string]int32

+ var UpdateDeviceMetadataRequest_ShadowSynchronization_name = map[int32]string

+ var UpdateDeviceMetadataRequest_ShadowSynchronization_value = map[string]int32

+ 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 struct

+ CorrelationIdFilter []string

+ ResourceId *commands.ResourceId

+ func (*CancelPendingCommandsRequest) Descriptor() ([]byte, []int)

+ func (*CancelPendingCommandsRequest) ProtoMessage()

+ func (x *CancelPendingCommandsRequest) GetCorrelationIdFilter() []string

+ func (x *CancelPendingCommandsRequest) GetResourceId() *commands.ResourceId

+ func (x *CancelPendingCommandsRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelPendingCommandsRequest) Reset()

+ func (x *CancelPendingCommandsRequest) String() string

+ type CancelPendingCommandsResponse struct

+ CorrelationIds []string

+ func (*CancelPendingCommandsResponse) Descriptor() ([]byte, []int)

+ func (*CancelPendingCommandsResponse) ProtoMessage()

+ func (x *CancelPendingCommandsResponse) GetCorrelationIds() []string

+ func (x *CancelPendingCommandsResponse) ProtoReflect() protoreflect.Message

+ func (x *CancelPendingCommandsResponse) Reset()

+ func (x *CancelPendingCommandsResponse) String() string

+ type CancelPendingMetadataUpdatesRequest struct

+ CorrelationIdFilter []string

+ DeviceId string

+ func (*CancelPendingMetadataUpdatesRequest) Descriptor() ([]byte, []int)

+ func (*CancelPendingMetadataUpdatesRequest) ProtoMessage()

+ func (x *CancelPendingMetadataUpdatesRequest) GetCorrelationIdFilter() []string

+ func (x *CancelPendingMetadataUpdatesRequest) GetDeviceId() string

+ func (x *CancelPendingMetadataUpdatesRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelPendingMetadataUpdatesRequest) Reset()

+ func (x *CancelPendingMetadataUpdatesRequest) String() string

+ type Content struct

+ ContentType string

+ Data []byte

+ func (*Content) Descriptor() ([]byte, []int)

+ func (*Content) ProtoMessage()

+ func (x *Content) GetContentType() string

+ func (x *Content) GetData() []byte

+ func (x *Content) ProtoReflect() protoreflect.Message

+ func (x *Content) Reset()

+ func (x *Content) String() string

+ type CreateResourceRequest struct

+ Content *Content

+ ResourceId *commands.ResourceId

+ TimeToLive int64

+ func (*CreateResourceRequest) Descriptor() ([]byte, []int)

+ func (*CreateResourceRequest) ProtoMessage()

+ func (req *CreateResourceRequest) ToRACommand(ctx context.Context) (*commands.CreateResourceRequest, error)

+ func (x *CreateResourceRequest) GetContent() *Content

+ func (x *CreateResourceRequest) GetResourceId() *commands.ResourceId

+ func (x *CreateResourceRequest) GetTimeToLive() int64

+ func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateResourceRequest) Reset()

+ func (x *CreateResourceRequest) String() string

+ type CreateResourceResponse struct

+ Data *events.ResourceCreated

+ func (*CreateResourceResponse) Descriptor() ([]byte, []int)

+ func (*CreateResourceResponse) ProtoMessage()

+ func (x *CreateResourceResponse) GetData() *events.ResourceCreated

+ func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateResourceResponse) Reset()

+ func (x *CreateResourceResponse) String() string

+ type DeleteDevicesRequest struct

+ DeviceIdFilter []string

+ func (*DeleteDevicesRequest) Descriptor() ([]byte, []int)

+ func (*DeleteDevicesRequest) ProtoMessage()

+ func (x *DeleteDevicesRequest) GetDeviceIdFilter() []string

+ func (x *DeleteDevicesRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteDevicesRequest) Reset()

+ func (x *DeleteDevicesRequest) String() string

+ type DeleteDevicesResponse struct

+ DeviceIds []string

+ func (*DeleteDevicesResponse) Descriptor() ([]byte, []int)

+ func (*DeleteDevicesResponse) ProtoMessage()

+ func (x *DeleteDevicesResponse) GetDeviceIds() []string

+ func (x *DeleteDevicesResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteDevicesResponse) Reset()

+ func (x *DeleteDevicesResponse) String() string

+ type DeleteResourceRequest struct

+ ResourceId *commands.ResourceId

+ TimeToLive int64

+ func (*DeleteResourceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteResourceRequest) ProtoMessage()

+ func (req *DeleteResourceRequest) ToRACommand(ctx context.Context) (*commands.DeleteResourceRequest, error)

+ func (x *DeleteResourceRequest) GetResourceId() *commands.ResourceId

+ func (x *DeleteResourceRequest) GetTimeToLive() int64

+ func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteResourceRequest) Reset()

+ func (x *DeleteResourceRequest) String() string

+ type DeleteResourceResponse struct

+ Data *events.ResourceDeleted

+ func (*DeleteResourceResponse) Descriptor() ([]byte, []int)

+ func (*DeleteResourceResponse) ProtoMessage()

+ func (x *DeleteResourceResponse) GetData() *events.ResourceDeleted

+ func (x *DeleteResourceResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteResourceResponse) Reset()

+ func (x *DeleteResourceResponse) String() string

+ type Device struct

+ Id string

+ Interfaces []string

+ ManufacturerName []*LocalizedString

+ Metadata *Device_Metadata

+ ModelNumber string

+ Name string

+ ProtocolIndependentId string

+ Types []string

+ func SchemaDeviceToProto(d *device.Device) *Device

+ func (*Device) Descriptor() ([]byte, []int)

+ func (*Device) ProtoMessage()

+ func (d *Device) ToSchema() device.Device

+ 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 (x *Device) ProtoReflect() protoreflect.Message

+ func (x *Device) Reset()

+ func (x *Device) String() string

+ type Device_Metadata struct

+ ShadowSynchronization commands.ShadowSynchronization

+ Status *commands.ConnectionStatus

+ func (*Device_Metadata) Descriptor() ([]byte, []int)

+ func (*Device_Metadata) ProtoMessage()

+ func (x *Device_Metadata) GetShadowSynchronization() commands.ShadowSynchronization

+ func (x *Device_Metadata) GetStatus() *commands.ConnectionStatus

+ func (x *Device_Metadata) ProtoReflect() protoreflect.Message

+ func (x *Device_Metadata) Reset()

+ func (x *Device_Metadata) String() string

+ type Event struct

+ CorrelationId string

+ SubscriptionId string

+ Type isEvent_Type

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (m *Event) GetType() isEvent_Type

+ 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 (x *Event) ProtoReflect() protoreflect.Message

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ type Event_DeviceMetadataUpdatePending struct

+ DeviceMetadataUpdatePending *events.DeviceMetadataUpdatePending

+ type Event_DeviceMetadataUpdated struct

+ DeviceMetadataUpdated *events.DeviceMetadataUpdated

+ type Event_DeviceRegistered struct

+ DeviceIds []string

+ func (*Event_DeviceRegistered) Descriptor() ([]byte, []int)

+ func (*Event_DeviceRegistered) ProtoMessage()

+ func (x *Event_DeviceRegistered) GetDeviceIds() []string

+ func (x *Event_DeviceRegistered) ProtoReflect() protoreflect.Message

+ func (x *Event_DeviceRegistered) Reset()

+ func (x *Event_DeviceRegistered) String() string

+ type Event_DeviceRegistered_ struct

+ DeviceRegistered *Event_DeviceRegistered

+ type Event_DeviceUnregistered struct

+ DeviceIds []string

+ func (*Event_DeviceUnregistered) Descriptor() ([]byte, []int)

+ func (*Event_DeviceUnregistered) ProtoMessage()

+ func (x *Event_DeviceUnregistered) GetDeviceIds() []string

+ func (x *Event_DeviceUnregistered) ProtoReflect() protoreflect.Message

+ func (x *Event_DeviceUnregistered) Reset()

+ func (x *Event_DeviceUnregistered) String() string

+ type Event_DeviceUnregistered_ struct

+ DeviceUnregistered *Event_DeviceUnregistered

+ type Event_OperationProcessed struct

+ ErrorStatus *Event_OperationProcessed_ErrorStatus

+ func (*Event_OperationProcessed) Descriptor() ([]byte, []int)

+ func (*Event_OperationProcessed) ProtoMessage()

+ func (x *Event_OperationProcessed) GetErrorStatus() *Event_OperationProcessed_ErrorStatus

+ func (x *Event_OperationProcessed) ProtoReflect() protoreflect.Message

+ func (x *Event_OperationProcessed) Reset()

+ func (x *Event_OperationProcessed) String() string

+ type Event_OperationProcessed_ struct

+ OperationProcessed *Event_OperationProcessed

+ type Event_OperationProcessed_ErrorStatus struct

+ Code Event_OperationProcessed_ErrorStatus_Code

+ Message string

+ func (*Event_OperationProcessed_ErrorStatus) Descriptor() ([]byte, []int)

+ func (*Event_OperationProcessed_ErrorStatus) ProtoMessage()

+ func (x *Event_OperationProcessed_ErrorStatus) GetCode() Event_OperationProcessed_ErrorStatus_Code

+ func (x *Event_OperationProcessed_ErrorStatus) GetMessage() string

+ 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 int32

+ const Event_OperationProcessed_ErrorStatus_ERROR

+ const Event_OperationProcessed_ErrorStatus_NOT_FOUND

+ const Event_OperationProcessed_ErrorStatus_OK

+ func (Event_OperationProcessed_ErrorStatus_Code) Descriptor() protoreflect.EnumDescriptor

+ func (Event_OperationProcessed_ErrorStatus_Code) EnumDescriptor() ([]byte, []int)

+ func (Event_OperationProcessed_ErrorStatus_Code) Type() protoreflect.EnumType

+ func (x Event_OperationProcessed_ErrorStatus_Code) Enum() *Event_OperationProcessed_ErrorStatus_Code

+ func (x Event_OperationProcessed_ErrorStatus_Code) Number() protoreflect.EnumNumber

+ func (x Event_OperationProcessed_ErrorStatus_Code) String() string

+ type Event_ResourceChanged struct

+ ResourceChanged *events.ResourceChanged

+ type Event_ResourceCreatePending struct

+ ResourceCreatePending *events.ResourceCreatePending

+ type Event_ResourceCreated struct

+ ResourceCreated *events.ResourceCreated

+ type Event_ResourceDeletePending struct

+ ResourceDeletePending *events.ResourceDeletePending

+ type Event_ResourceDeleted struct

+ ResourceDeleted *events.ResourceDeleted

+ type Event_ResourcePublished struct

+ ResourcePublished *events.ResourceLinksPublished

+ type Event_ResourceRetrievePending struct

+ ResourceRetrievePending *events.ResourceRetrievePending

+ type Event_ResourceRetrieved struct

+ ResourceRetrieved *events.ResourceRetrieved

+ type Event_ResourceUnpublished struct

+ ResourceUnpublished *events.ResourceLinksUnpublished

+ type Event_ResourceUpdatePending struct

+ ResourceUpdatePending *events.ResourceUpdatePending

+ type Event_ResourceUpdated struct

+ ResourceUpdated *events.ResourceUpdated

+ type Event_SubscriptionCanceled struct

+ Reason string

+ func (*Event_SubscriptionCanceled) Descriptor() ([]byte, []int)

+ func (*Event_SubscriptionCanceled) ProtoMessage()

+ func (x *Event_SubscriptionCanceled) GetReason() string

+ func (x *Event_SubscriptionCanceled) ProtoReflect() protoreflect.Message

+ func (x *Event_SubscriptionCanceled) Reset()

+ func (x *Event_SubscriptionCanceled) String() string

+ type Event_SubscriptionCanceled_ struct

+ SubscriptionCanceled *Event_SubscriptionCanceled

+ type GetDevicesMetadataRequest struct

+ DeviceIdFilter []string

+ TypeFilter []string

+ func (*GetDevicesMetadataRequest) Descriptor() ([]byte, []int)

+ func (*GetDevicesMetadataRequest) ProtoMessage()

+ func (x *GetDevicesMetadataRequest) GetDeviceIdFilter() []string

+ func (x *GetDevicesMetadataRequest) GetTypeFilter() []string

+ func (x *GetDevicesMetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *GetDevicesMetadataRequest) Reset()

+ func (x *GetDevicesMetadataRequest) String() string

+ type GetDevicesRequest struct

+ DeviceIdFilter []string

+ StatusFilter []GetDevicesRequest_Status

+ TypeFilter []string

+ func (*GetDevicesRequest) Descriptor() ([]byte, []int)

+ func (*GetDevicesRequest) ProtoMessage()

+ func (x *GetDevicesRequest) GetDeviceIdFilter() []string

+ func (x *GetDevicesRequest) GetStatusFilter() []GetDevicesRequest_Status

+ func (x *GetDevicesRequest) GetTypeFilter() []string

+ func (x *GetDevicesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetDevicesRequest) Reset()

+ func (x *GetDevicesRequest) String() string

+ type GetDevicesRequest_Status int32

+ const GetDevicesRequest_OFFLINE

+ const GetDevicesRequest_ONLINE

+ func (GetDevicesRequest_Status) Descriptor() protoreflect.EnumDescriptor

+ func (GetDevicesRequest_Status) EnumDescriptor() ([]byte, []int)

+ func (GetDevicesRequest_Status) Type() protoreflect.EnumType

+ func (x GetDevicesRequest_Status) Enum() *GetDevicesRequest_Status

+ func (x GetDevicesRequest_Status) Number() protoreflect.EnumNumber

+ func (x GetDevicesRequest_Status) String() string

+ type GetEventsRequest struct

+ DeviceIdFilter []string

+ ResourceIdFilter []string

+ TimestampFilter int64

+ func (*GetEventsRequest) Descriptor() ([]byte, []int)

+ func (*GetEventsRequest) ProtoMessage()

+ func (x *GetEventsRequest) GetDeviceIdFilter() []string

+ func (x *GetEventsRequest) GetResourceIdFilter() []string

+ func (x *GetEventsRequest) GetTimestampFilter() int64

+ func (x *GetEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetEventsRequest) Reset()

+ func (x *GetEventsRequest) String() string

+ type GetEventsResponse struct

+ Type isGetEventsResponse_Type

+ func (*GetEventsResponse) Descriptor() ([]byte, []int)

+ func (*GetEventsResponse) ProtoMessage()

+ func (m *GetEventsResponse) GetType() isGetEventsResponse_Type

+ 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 (x *GetEventsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetEventsResponse) Reset()

+ func (x *GetEventsResponse) String() string

+ type GetEventsResponse_DeviceMetadataSnapshotTaken struct

+ DeviceMetadataSnapshotTaken *events.DeviceMetadataSnapshotTaken

+ type GetEventsResponse_DeviceMetadataUpdatePending struct

+ DeviceMetadataUpdatePending *events.DeviceMetadataUpdatePending

+ type GetEventsResponse_DeviceMetadataUpdated struct

+ DeviceMetadataUpdated *events.DeviceMetadataUpdated

+ type GetEventsResponse_ResourceChanged struct

+ ResourceChanged *events.ResourceChanged

+ type GetEventsResponse_ResourceCreatePending struct

+ ResourceCreatePending *events.ResourceCreatePending

+ type GetEventsResponse_ResourceCreated struct

+ ResourceCreated *events.ResourceCreated

+ type GetEventsResponse_ResourceDeletePending struct

+ ResourceDeletePending *events.ResourceDeletePending

+ type GetEventsResponse_ResourceDeleted struct

+ ResourceDeleted *events.ResourceDeleted

+ type GetEventsResponse_ResourceLinksPublished struct

+ ResourceLinksPublished *events.ResourceLinksPublished

+ type GetEventsResponse_ResourceLinksSnapshotTaken struct

+ ResourceLinksSnapshotTaken *events.ResourceLinksSnapshotTaken

+ type GetEventsResponse_ResourceLinksUnpublished struct

+ ResourceLinksUnpublished *events.ResourceLinksUnpublished

+ type GetEventsResponse_ResourceRetrievePending struct

+ ResourceRetrievePending *events.ResourceRetrievePending

+ type GetEventsResponse_ResourceRetrieved struct

+ ResourceRetrieved *events.ResourceRetrieved

+ type GetEventsResponse_ResourceStateSnapshotTaken struct

+ ResourceStateSnapshotTaken *events.ResourceStateSnapshotTaken

+ type GetEventsResponse_ResourceUpdatePending struct

+ ResourceUpdatePending *events.ResourceUpdatePending

+ type GetEventsResponse_ResourceUpdated struct

+ ResourceUpdated *events.ResourceUpdated

+ type GetPendingCommandsRequest struct

+ CommandFilter []GetPendingCommandsRequest_Command

+ DeviceIdFilter []string

+ ResourceIdFilter []string

+ TypeFilter []string

+ func (*GetPendingCommandsRequest) Descriptor() ([]byte, []int)

+ func (*GetPendingCommandsRequest) ProtoMessage()

+ func (x *GetPendingCommandsRequest) GetCommandFilter() []GetPendingCommandsRequest_Command

+ func (x *GetPendingCommandsRequest) GetDeviceIdFilter() []string

+ func (x *GetPendingCommandsRequest) GetResourceIdFilter() []string

+ func (x *GetPendingCommandsRequest) GetTypeFilter() []string

+ func (x *GetPendingCommandsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetPendingCommandsRequest) Reset()

+ func (x *GetPendingCommandsRequest) String() string

+ type GetPendingCommandsRequest_Command int32

+ const GetPendingCommandsRequest_DEVICE_METADATA_UPDATE

+ const GetPendingCommandsRequest_RESOURCE_CREATE

+ const GetPendingCommandsRequest_RESOURCE_DELETE

+ const GetPendingCommandsRequest_RESOURCE_RETRIEVE

+ const GetPendingCommandsRequest_RESOURCE_UPDATE

+ func (GetPendingCommandsRequest_Command) Descriptor() protoreflect.EnumDescriptor

+ func (GetPendingCommandsRequest_Command) EnumDescriptor() ([]byte, []int)

+ func (GetPendingCommandsRequest_Command) Type() protoreflect.EnumType

+ func (x GetPendingCommandsRequest_Command) Enum() *GetPendingCommandsRequest_Command

+ func (x GetPendingCommandsRequest_Command) Number() protoreflect.EnumNumber

+ func (x GetPendingCommandsRequest_Command) String() string

+ type GetResourceFromDeviceRequest struct

+ ResourceId *commands.ResourceId

+ ResourceInterface string

+ TimeToLive int64

+ func (*GetResourceFromDeviceRequest) Descriptor() ([]byte, []int)

+ func (*GetResourceFromDeviceRequest) ProtoMessage()

+ func (req *GetResourceFromDeviceRequest) ToRACommand(ctx context.Context) (*commands.RetrieveResourceRequest, error)

+ func (x *GetResourceFromDeviceRequest) GetResourceId() *commands.ResourceId

+ func (x *GetResourceFromDeviceRequest) GetResourceInterface() string

+ func (x *GetResourceFromDeviceRequest) GetTimeToLive() int64

+ func (x *GetResourceFromDeviceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetResourceFromDeviceRequest) Reset()

+ func (x *GetResourceFromDeviceRequest) String() string

+ type GetResourceFromDeviceResponse struct

+ Data *events.ResourceRetrieved

+ func (*GetResourceFromDeviceResponse) Descriptor() ([]byte, []int)

+ func (*GetResourceFromDeviceResponse) ProtoMessage()

+ func (x *GetResourceFromDeviceResponse) GetData() *events.ResourceRetrieved

+ func (x *GetResourceFromDeviceResponse) ProtoReflect() protoreflect.Message

+ func (x *GetResourceFromDeviceResponse) Reset()

+ func (x *GetResourceFromDeviceResponse) String() string

+ type GetResourceLinksRequest struct

+ DeviceIdFilter []string

+ TypeFilter []string

+ func (*GetResourceLinksRequest) Descriptor() ([]byte, []int)

+ func (*GetResourceLinksRequest) ProtoMessage()

+ func (x *GetResourceLinksRequest) GetDeviceIdFilter() []string

+ func (x *GetResourceLinksRequest) GetTypeFilter() []string

+ func (x *GetResourceLinksRequest) ProtoReflect() protoreflect.Message

+ func (x *GetResourceLinksRequest) Reset()

+ func (x *GetResourceLinksRequest) String() string

+ type GetResourcesRequest struct

+ DeviceIdFilter []string

+ ResourceIdFilter []string

+ TypeFilter []string

+ func (*GetResourcesRequest) Descriptor() ([]byte, []int)

+ func (*GetResourcesRequest) ProtoMessage()

+ func (x *GetResourcesRequest) GetDeviceIdFilter() []string

+ func (x *GetResourcesRequest) GetResourceIdFilter() []string

+ func (x *GetResourcesRequest) GetTypeFilter() []string

+ func (x *GetResourcesRequest) ProtoReflect() protoreflect.Message

+ func (x *GetResourcesRequest) Reset()

+ func (x *GetResourcesRequest) String() string

+ type GrpcGatewayClient interface

+ CancelPendingCommands func(ctx context.Context, in *CancelPendingCommandsRequest, opts ...grpc.CallOption) (*CancelPendingCommandsResponse, error)

+ CancelPendingMetadataUpdates func(ctx context.Context, in *CancelPendingMetadataUpdatesRequest, ...) (*CancelPendingCommandsResponse, error)

+ CreateResource func(ctx context.Context, in *CreateResourceRequest, opts ...grpc.CallOption) (*CreateResourceResponse, error)

+ DeleteDevices func(ctx context.Context, in *DeleteDevicesRequest, opts ...grpc.CallOption) (*DeleteDevicesResponse, error)

+ DeleteResource func(ctx context.Context, in *DeleteResourceRequest, opts ...grpc.CallOption) (*DeleteResourceResponse, error)

+ GetDevices func(ctx context.Context, in *GetDevicesRequest, opts ...grpc.CallOption) (GrpcGateway_GetDevicesClient, error)

+ GetDevicesMetadata func(ctx context.Context, in *GetDevicesMetadataRequest, opts ...grpc.CallOption) (GrpcGateway_GetDevicesMetadataClient, error)

+ GetEvents func(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (GrpcGateway_GetEventsClient, error)

+ GetHubConfiguration func(ctx context.Context, in *HubConfigurationRequest, opts ...grpc.CallOption) (*HubConfigurationResponse, error)

+ GetPendingCommands func(ctx context.Context, in *GetPendingCommandsRequest, opts ...grpc.CallOption) (GrpcGateway_GetPendingCommandsClient, error)

+ GetResourceFromDevice func(ctx context.Context, in *GetResourceFromDeviceRequest, opts ...grpc.CallOption) (*GetResourceFromDeviceResponse, error)

+ GetResourceLinks func(ctx context.Context, in *GetResourceLinksRequest, opts ...grpc.CallOption) (GrpcGateway_GetResourceLinksClient, error)

+ GetResources func(ctx context.Context, in *GetResourcesRequest, opts ...grpc.CallOption) (GrpcGateway_GetResourcesClient, error)

+ SubscribeToEvents func(ctx context.Context, opts ...grpc.CallOption) (GrpcGateway_SubscribeToEventsClient, error)

+ UpdateDeviceMetadata func(ctx context.Context, in *UpdateDeviceMetadataRequest, opts ...grpc.CallOption) (*UpdateDeviceMetadataResponse, error)

+ UpdateResource func(ctx context.Context, in *UpdateResourceRequest, opts ...grpc.CallOption) (*UpdateResourceResponse, error)

+ func NewGrpcGatewayClient(cc grpc.ClientConnInterface) GrpcGatewayClient

+ type GrpcGatewayServer interface

+ CancelPendingCommands func(context.Context, *CancelPendingCommandsRequest) (*CancelPendingCommandsResponse, error)

+ CancelPendingMetadataUpdates func(context.Context, *CancelPendingMetadataUpdatesRequest) (*CancelPendingCommandsResponse, error)

+ CreateResource func(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)

+ DeleteDevices func(context.Context, *DeleteDevicesRequest) (*DeleteDevicesResponse, error)

+ DeleteResource func(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)

+ GetDevices func(*GetDevicesRequest, GrpcGateway_GetDevicesServer) error

+ GetDevicesMetadata func(*GetDevicesMetadataRequest, GrpcGateway_GetDevicesMetadataServer) error

+ GetEvents func(*GetEventsRequest, GrpcGateway_GetEventsServer) error

+ GetHubConfiguration func(context.Context, *HubConfigurationRequest) (*HubConfigurationResponse, error)

+ GetPendingCommands func(*GetPendingCommandsRequest, GrpcGateway_GetPendingCommandsServer) error

+ GetResourceFromDevice func(context.Context, *GetResourceFromDeviceRequest) (*GetResourceFromDeviceResponse, error)

+ GetResourceLinks func(*GetResourceLinksRequest, GrpcGateway_GetResourceLinksServer) error

+ GetResources func(*GetResourcesRequest, GrpcGateway_GetResourcesServer) error

+ SubscribeToEvents func(GrpcGateway_SubscribeToEventsServer) error

+ UpdateDeviceMetadata func(context.Context, *UpdateDeviceMetadataRequest) (*UpdateDeviceMetadataResponse, error)

+ UpdateResource func(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)

+ type GrpcGateway_GetDevicesClient interface

+ Recv func() (*Device, error)

+ type GrpcGateway_GetDevicesMetadataClient interface

+ Recv func() (*events.DeviceMetadataUpdated, error)

+ type GrpcGateway_GetDevicesMetadataServer interface

+ Send func(*events.DeviceMetadataUpdated) error

+ type GrpcGateway_GetDevicesServer interface

+ Send func(*Device) error

+ type GrpcGateway_GetEventsClient interface

+ Recv func() (*GetEventsResponse, error)

+ type GrpcGateway_GetEventsServer interface

+ Send func(*GetEventsResponse) error

+ type GrpcGateway_GetPendingCommandsClient interface

+ Recv func() (*PendingCommand, error)

+ type GrpcGateway_GetPendingCommandsServer interface

+ Send func(*PendingCommand) error

+ type GrpcGateway_GetResourceLinksClient interface

+ Recv func() (*events.ResourceLinksPublished, error)

+ type GrpcGateway_GetResourceLinksServer interface

+ Send func(*events.ResourceLinksPublished) error

+ type GrpcGateway_GetResourcesClient interface

+ Recv func() (*Resource, error)

+ type GrpcGateway_GetResourcesServer interface

+ Send func(*Resource) error

+ type GrpcGateway_SubscribeToEventsClient interface

+ Recv func() (*Event, error)

+ Send func(*SubscribeToEvents) error

+ type GrpcGateway_SubscribeToEventsServer interface

+ Recv func() (*SubscribeToEvents, error)

+ Send func(*Event) error

+ type HubConfigurationRequest struct

+ func (*HubConfigurationRequest) Descriptor() ([]byte, []int)

+ func (*HubConfigurationRequest) ProtoMessage()

+ func (x *HubConfigurationRequest) ProtoReflect() protoreflect.Message

+ func (x *HubConfigurationRequest) Reset()

+ func (x *HubConfigurationRequest) String() string

+ type HubConfigurationResponse struct

+ AuthorizationServer string

+ CertificateAuthorities string

+ CoapGateway string

+ CurrentTime int64

+ DefaultCommandTimeToLive int64

+ Id string

+ JwtDeviceIdClaim string

+ JwtOwnerClaim string

+ func (*HubConfigurationResponse) Descriptor() ([]byte, []int)

+ func (*HubConfigurationResponse) ProtoMessage()

+ 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 (x *HubConfigurationResponse) ProtoReflect() protoreflect.Message

+ func (x *HubConfigurationResponse) Reset()

+ func (x *HubConfigurationResponse) String() string

+ type LocalizedString struct

+ Language string

+ Value string

+ func SchemaLocalizedStringToProto(s device.LocalizedString) *LocalizedString

+ func SchemaLocalizedStringsToProto(s []device.LocalizedString) []*LocalizedString

+ func (*LocalizedString) Descriptor() ([]byte, []int)

+ func (*LocalizedString) ProtoMessage()

+ func (l *LocalizedString) ToSchema() device.LocalizedString

+ func (x *LocalizedString) GetLanguage() string

+ func (x *LocalizedString) GetValue() string

+ func (x *LocalizedString) ProtoReflect() protoreflect.Message

+ func (x *LocalizedString) Reset()

+ func (x *LocalizedString) String() string

+ type LocalizedStrings []*LocalizedString

+ func (s LocalizedStrings) ToSchema() []device.LocalizedString

+ type PendingCommand struct

+ Command isPendingCommand_Command

+ func (*PendingCommand) Descriptor() ([]byte, []int)

+ func (*PendingCommand) ProtoMessage()

+ 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 (x *PendingCommand) ProtoReflect() protoreflect.Message

+ func (x *PendingCommand) Reset()

+ func (x *PendingCommand) String() string

+ type PendingCommand_DeviceMetadataUpdatePending struct

+ DeviceMetadataUpdatePending *events.DeviceMetadataUpdatePending

+ type PendingCommand_ResourceCreatePending struct

+ ResourceCreatePending *events.ResourceCreatePending

+ type PendingCommand_ResourceDeletePending struct

+ ResourceDeletePending *events.ResourceDeletePending

+ type PendingCommand_ResourceRetrievePending struct

+ ResourceRetrievePending *events.ResourceRetrievePending

+ type PendingCommand_ResourceUpdatePending struct

+ ResourceUpdatePending *events.ResourceUpdatePending

+ type Resource struct

+ Data *events.ResourceChanged

+ Types []string

+ func (*Resource) Descriptor() ([]byte, []int)

+ func (*Resource) ProtoMessage()

+ func (x *Resource) GetData() *events.ResourceChanged

+ func (x *Resource) GetTypes() []string

+ func (x *Resource) ProtoReflect() protoreflect.Message

+ func (x *Resource) Reset()

+ func (x *Resource) String() string

+ type SubscribeToEvents struct

+ Action isSubscribeToEvents_Action

+ CorrelationId string

+ func (*SubscribeToEvents) Descriptor() ([]byte, []int)

+ func (*SubscribeToEvents) ProtoMessage()

+ func (m *SubscribeToEvents) GetAction() isSubscribeToEvents_Action

+ func (x *SubscribeToEvents) GetCancelSubscription() *SubscribeToEvents_CancelSubscription

+ func (x *SubscribeToEvents) GetCorrelationId() string

+ func (x *SubscribeToEvents) GetCreateSubscription() *SubscribeToEvents_CreateSubscription

+ func (x *SubscribeToEvents) ProtoReflect() protoreflect.Message

+ func (x *SubscribeToEvents) Reset()

+ func (x *SubscribeToEvents) String() string

+ type SubscribeToEvents_CancelSubscription struct

+ SubscriptionId string

+ func (*SubscribeToEvents_CancelSubscription) Descriptor() ([]byte, []int)

+ func (*SubscribeToEvents_CancelSubscription) ProtoMessage()

+ func (x *SubscribeToEvents_CancelSubscription) GetSubscriptionId() string

+ func (x *SubscribeToEvents_CancelSubscription) ProtoReflect() protoreflect.Message

+ func (x *SubscribeToEvents_CancelSubscription) Reset()

+ func (x *SubscribeToEvents_CancelSubscription) String() string

+ type SubscribeToEvents_CancelSubscription_ struct

+ CancelSubscription *SubscribeToEvents_CancelSubscription

+ type SubscribeToEvents_CreateSubscription struct

+ DeviceIdFilter []string

+ EventFilter []SubscribeToEvents_CreateSubscription_Event

+ ResourceIdFilter []string

+ func (*SubscribeToEvents_CreateSubscription) Descriptor() ([]byte, []int)

+ func (*SubscribeToEvents_CreateSubscription) ProtoMessage()

+ func (x *SubscribeToEvents_CreateSubscription) GetDeviceIdFilter() []string

+ func (x *SubscribeToEvents_CreateSubscription) GetEventFilter() []SubscribeToEvents_CreateSubscription_Event

+ func (x *SubscribeToEvents_CreateSubscription) GetResourceIdFilter() []string

+ func (x *SubscribeToEvents_CreateSubscription) ProtoReflect() protoreflect.Message

+ func (x *SubscribeToEvents_CreateSubscription) Reset()

+ func (x *SubscribeToEvents_CreateSubscription) String() string

+ type SubscribeToEvents_CreateSubscription_ struct

+ CreateSubscription *SubscribeToEvents_CreateSubscription

+ type SubscribeToEvents_CreateSubscription_Event int32

+ const SubscribeToEvents_CreateSubscription_DEVICE_METADATA_UPDATED

+ const SubscribeToEvents_CreateSubscription_DEVICE_METADATA_UPDATE_PENDING

+ const SubscribeToEvents_CreateSubscription_REGISTERED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_CHANGED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_CREATED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_CREATE_PENDING

+ const SubscribeToEvents_CreateSubscription_RESOURCE_DELETED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_DELETE_PENDING

+ const SubscribeToEvents_CreateSubscription_RESOURCE_PUBLISHED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_RETRIEVED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_RETRIEVE_PENDING

+ const SubscribeToEvents_CreateSubscription_RESOURCE_UNPUBLISHED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_UPDATED

+ const SubscribeToEvents_CreateSubscription_RESOURCE_UPDATE_PENDING

+ const SubscribeToEvents_CreateSubscription_UNREGISTERED

+ func (SubscribeToEvents_CreateSubscription_Event) Descriptor() protoreflect.EnumDescriptor

+ func (SubscribeToEvents_CreateSubscription_Event) EnumDescriptor() ([]byte, []int)

+ func (SubscribeToEvents_CreateSubscription_Event) Type() protoreflect.EnumType

+ func (x SubscribeToEvents_CreateSubscription_Event) Enum() *SubscribeToEvents_CreateSubscription_Event

+ func (x SubscribeToEvents_CreateSubscription_Event) Number() protoreflect.EnumNumber

+ func (x SubscribeToEvents_CreateSubscription_Event) String() string

+ type UnimplementedGrpcGatewayServer struct

+ 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 interface

+ type UpdateDeviceMetadataRequest struct

+ DeviceId string

+ ShadowSynchronization UpdateDeviceMetadataRequest_ShadowSynchronization

+ TimeToLive int64

+ func (*UpdateDeviceMetadataRequest) Descriptor() ([]byte, []int)

+ func (*UpdateDeviceMetadataRequest) ProtoMessage()

+ func (req *UpdateDeviceMetadataRequest) ToRACommand(ctx context.Context) (*commands.UpdateDeviceMetadataRequest, error)

+ func (x *UpdateDeviceMetadataRequest) GetDeviceId() string

+ func (x *UpdateDeviceMetadataRequest) GetShadowSynchronization() UpdateDeviceMetadataRequest_ShadowSynchronization

+ func (x *UpdateDeviceMetadataRequest) GetTimeToLive() int64

+ func (x *UpdateDeviceMetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateDeviceMetadataRequest) Reset()

+ func (x *UpdateDeviceMetadataRequest) String() string

+ type UpdateDeviceMetadataRequest_ShadowSynchronization int32

+ const UpdateDeviceMetadataRequest_DISABLED

+ const UpdateDeviceMetadataRequest_ENABLED

+ func (UpdateDeviceMetadataRequest_ShadowSynchronization) Descriptor() protoreflect.EnumDescriptor

+ func (UpdateDeviceMetadataRequest_ShadowSynchronization) EnumDescriptor() ([]byte, []int)

+ func (UpdateDeviceMetadataRequest_ShadowSynchronization) Type() protoreflect.EnumType

+ func (x UpdateDeviceMetadataRequest_ShadowSynchronization) Enum() *UpdateDeviceMetadataRequest_ShadowSynchronization

+ func (x UpdateDeviceMetadataRequest_ShadowSynchronization) Number() protoreflect.EnumNumber

+ func (x UpdateDeviceMetadataRequest_ShadowSynchronization) String() string

+ type UpdateDeviceMetadataResponse struct

+ Data *events.DeviceMetadataUpdated

+ func (*UpdateDeviceMetadataResponse) Descriptor() ([]byte, []int)

+ func (*UpdateDeviceMetadataResponse) ProtoMessage()

+ func (x *UpdateDeviceMetadataResponse) GetData() *events.DeviceMetadataUpdated

+ func (x *UpdateDeviceMetadataResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateDeviceMetadataResponse) Reset()

+ func (x *UpdateDeviceMetadataResponse) String() string

+ type UpdateResourceRequest struct

+ Content *Content

+ ResourceId *commands.ResourceId

+ ResourceInterface string

+ TimeToLive int64

+ func (*UpdateResourceRequest) Descriptor() ([]byte, []int)

+ func (*UpdateResourceRequest) ProtoMessage()

+ func (req *UpdateResourceRequest) ToRACommand(ctx context.Context) (*commands.UpdateResourceRequest, error)

+ func (x *UpdateResourceRequest) GetContent() *Content

+ func (x *UpdateResourceRequest) GetResourceId() *commands.ResourceId

+ func (x *UpdateResourceRequest) GetResourceInterface() string

+ func (x *UpdateResourceRequest) GetTimeToLive() int64

+ func (x *UpdateResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateResourceRequest) Reset()

+ func (x *UpdateResourceRequest) String() string

+ type UpdateResourceResponse struct

+ Data *events.ResourceUpdated

+ func (*UpdateResourceResponse) Descriptor() ([]byte, []int)

+ func (*UpdateResourceResponse) ProtoMessage()

+ func (x *UpdateResourceResponse) GetData() *events.ResourceUpdated

+ func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateResourceResponse) Reset()

+ func (x *UpdateResourceResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL