Documentation
¶
Index ¶
- Constants
- Variables
- func CheckEventContent(ec EventContent) error
- func CloneResourcesMap(resources map[string]*Resource) map[string]*Resource
- func MakeLinksResourceUUID(deviceID string) uuid.UUID
- func MakeStatusResourceUUID(deviceID string) uuid.UUID
- func ResourcesToResourceLinks(resources []*Resource) []schema.ResourceLink
- type AuditContext
- func (c *AuditContext) Clone() *AuditContext
- func (*AuditContext) Descriptor() ([]byte, []int)deprecated
- func (x *AuditContext) GetCorrelationId() string
- func (x *AuditContext) GetUserId() string
- func (*AuditContext) ProtoMessage()
- func (x *AuditContext) ProtoReflect() protoreflect.Message
- func (x *AuditContext) Reset()
- func (x *AuditContext) String() string
- type BatchNotifyResourceChangedRequest
- func (*BatchNotifyResourceChangedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BatchNotifyResourceChangedRequest) GetBatch() []*NotifyResourceChangedRequest
- func (*BatchNotifyResourceChangedRequest) ProtoMessage()
- func (x *BatchNotifyResourceChangedRequest) ProtoReflect() protoreflect.Message
- func (x *BatchNotifyResourceChangedRequest) Reset()
- func (x *BatchNotifyResourceChangedRequest) String() string
- type BatchNotifyResourceChangedResponse
- func (*BatchNotifyResourceChangedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BatchNotifyResourceChangedResponse) GetAuditContext() *AuditContext
- func (*BatchNotifyResourceChangedResponse) ProtoMessage()
- func (x *BatchNotifyResourceChangedResponse) ProtoReflect() protoreflect.Message
- func (x *BatchNotifyResourceChangedResponse) Reset()
- func (x *BatchNotifyResourceChangedResponse) String() string
- type CancelPendingCommandsRequest
- func (*CancelPendingCommandsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelPendingCommandsRequest) GetCommandMetadata() *CommandMetadata
- func (x *CancelPendingCommandsRequest) GetCorrelationIdFilter() []string
- func (x *CancelPendingCommandsRequest) GetResourceId() *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) GetAuditContext() *AuditContext
- 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) GetCommandMetadata() *CommandMetadata
- 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 CancelPendingMetadataUpdatesResponse
- func (*CancelPendingMetadataUpdatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CancelPendingMetadataUpdatesResponse) GetAuditContext() *AuditContext
- func (x *CancelPendingMetadataUpdatesResponse) GetCorrelationIds() []string
- func (*CancelPendingMetadataUpdatesResponse) ProtoMessage()
- func (x *CancelPendingMetadataUpdatesResponse) ProtoReflect() protoreflect.Message
- func (x *CancelPendingMetadataUpdatesResponse) Reset()
- func (x *CancelPendingMetadataUpdatesResponse) String() string
- type CommandMetadata
- func (*CommandMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CommandMetadata) GetConnectionId() string
- func (x *CommandMetadata) GetSequence() uint64
- func (*CommandMetadata) ProtoMessage()
- func (x *CommandMetadata) ProtoReflect() protoreflect.Message
- func (x *CommandMetadata) Reset()
- func (x *CommandMetadata) String() string
- type ConfirmDeviceMetadataUpdateRequest
- func (*ConfirmDeviceMetadataUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmDeviceMetadataUpdateRequest) GetCommandMetadata() *CommandMetadata
- func (m *ConfirmDeviceMetadataUpdateRequest) GetConfirm() isConfirmDeviceMetadataUpdateRequest_Confirm
- func (x *ConfirmDeviceMetadataUpdateRequest) GetCorrelationId() string
- func (x *ConfirmDeviceMetadataUpdateRequest) GetDeviceId() string
- func (x *ConfirmDeviceMetadataUpdateRequest) GetStatus() Status
- func (x *ConfirmDeviceMetadataUpdateRequest) GetTwinEnabled() bool
- func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage()
- func (x *ConfirmDeviceMetadataUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *ConfirmDeviceMetadataUpdateRequest) Reset()
- func (x *ConfirmDeviceMetadataUpdateRequest) String() string
- type ConfirmDeviceMetadataUpdateRequest_TwinEnabled
- type ConfirmDeviceMetadataUpdateResponse
- func (*ConfirmDeviceMetadataUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmDeviceMetadataUpdateResponse) GetAuditContext() *AuditContext
- func (*ConfirmDeviceMetadataUpdateResponse) ProtoMessage()
- func (x *ConfirmDeviceMetadataUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *ConfirmDeviceMetadataUpdateResponse) Reset()
- func (x *ConfirmDeviceMetadataUpdateResponse) String() string
- type ConfirmResourceCreateRequest
- func (*ConfirmResourceCreateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceCreateRequest) GetCommandMetadata() *CommandMetadata
- func (x *ConfirmResourceCreateRequest) GetContent() *Content
- func (x *ConfirmResourceCreateRequest) GetCorrelationId() string
- func (x *ConfirmResourceCreateRequest) GetResourceId() *ResourceId
- func (x *ConfirmResourceCreateRequest) GetStatus() Status
- func (*ConfirmResourceCreateRequest) ProtoMessage()
- func (x *ConfirmResourceCreateRequest) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceCreateRequest) Reset()
- func (x *ConfirmResourceCreateRequest) String() string
- type ConfirmResourceCreateResponse
- func (*ConfirmResourceCreateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceCreateResponse) GetAuditContext() *AuditContext
- func (*ConfirmResourceCreateResponse) ProtoMessage()
- func (x *ConfirmResourceCreateResponse) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceCreateResponse) Reset()
- func (x *ConfirmResourceCreateResponse) String() string
- type ConfirmResourceDeleteRequest
- func (*ConfirmResourceDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceDeleteRequest) GetCommandMetadata() *CommandMetadata
- func (x *ConfirmResourceDeleteRequest) GetContent() *Content
- func (x *ConfirmResourceDeleteRequest) GetCorrelationId() string
- func (x *ConfirmResourceDeleteRequest) GetResourceId() *ResourceId
- func (x *ConfirmResourceDeleteRequest) GetStatus() Status
- func (*ConfirmResourceDeleteRequest) ProtoMessage()
- func (x *ConfirmResourceDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceDeleteRequest) Reset()
- func (x *ConfirmResourceDeleteRequest) String() string
- type ConfirmResourceDeleteResponse
- func (*ConfirmResourceDeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceDeleteResponse) GetAuditContext() *AuditContext
- func (*ConfirmResourceDeleteResponse) ProtoMessage()
- func (x *ConfirmResourceDeleteResponse) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceDeleteResponse) Reset()
- func (x *ConfirmResourceDeleteResponse) String() string
- type ConfirmResourceRetrieveRequest
- func (*ConfirmResourceRetrieveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceRetrieveRequest) GetCommandMetadata() *CommandMetadata
- func (x *ConfirmResourceRetrieveRequest) GetContent() *Content
- func (x *ConfirmResourceRetrieveRequest) GetCorrelationId() string
- func (x *ConfirmResourceRetrieveRequest) GetResourceId() *ResourceId
- func (x *ConfirmResourceRetrieveRequest) GetStatus() Status
- func (*ConfirmResourceRetrieveRequest) ProtoMessage()
- func (x *ConfirmResourceRetrieveRequest) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceRetrieveRequest) Reset()
- func (x *ConfirmResourceRetrieveRequest) String() string
- type ConfirmResourceRetrieveResponse
- func (*ConfirmResourceRetrieveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceRetrieveResponse) GetAuditContext() *AuditContext
- func (*ConfirmResourceRetrieveResponse) ProtoMessage()
- func (x *ConfirmResourceRetrieveResponse) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceRetrieveResponse) Reset()
- func (x *ConfirmResourceRetrieveResponse) String() string
- type ConfirmResourceUpdateRequest
- func (*ConfirmResourceUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceUpdateRequest) GetCommandMetadata() *CommandMetadata
- func (x *ConfirmResourceUpdateRequest) GetContent() *Content
- func (x *ConfirmResourceUpdateRequest) GetCorrelationId() string
- func (x *ConfirmResourceUpdateRequest) GetResourceId() *ResourceId
- func (x *ConfirmResourceUpdateRequest) GetStatus() Status
- func (*ConfirmResourceUpdateRequest) ProtoMessage()
- func (x *ConfirmResourceUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceUpdateRequest) Reset()
- func (x *ConfirmResourceUpdateRequest) String() string
- type ConfirmResourceUpdateResponse
- func (*ConfirmResourceUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfirmResourceUpdateResponse) GetAuditContext() *AuditContext
- func (*ConfirmResourceUpdateResponse) ProtoMessage()
- func (x *ConfirmResourceUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *ConfirmResourceUpdateResponse) Reset()
- func (x *ConfirmResourceUpdateResponse) String() string
- type Connection
- func (c *Connection) Clone() *Connection
- func (*Connection) Descriptor() ([]byte, []int)deprecated
- func (x *Connection) GetConnectedAt() int64
- func (x *Connection) GetId() string
- func (x *Connection) GetOnlineValidUntil() int64
- func (x *Connection) GetProtocol() Connection_Protocol
- func (x *Connection) GetStatus() Connection_Status
- func (c *Connection) IsOnline() bool
- func (*Connection) ProtoMessage()
- func (x *Connection) ProtoReflect() protoreflect.Message
- func (x *Connection) Reset()
- func (x *Connection) String() string
- type Connection_Protocol
- func (Connection_Protocol) Descriptor() protoreflect.EnumDescriptor
- func (x Connection_Protocol) Enum() *Connection_Protocol
- func (Connection_Protocol) EnumDescriptor() ([]byte, []int)deprecated
- func (x Connection_Protocol) Number() protoreflect.EnumNumber
- func (x Connection_Protocol) String() string
- func (Connection_Protocol) Type() protoreflect.EnumType
- type Connection_Status
- func (Connection_Status) Descriptor() protoreflect.EnumDescriptor
- func (x Connection_Status) Enum() *Connection_Status
- func (Connection_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x Connection_Status) Number() protoreflect.EnumNumber
- func (x Connection_Status) String() string
- func (Connection_Status) Type() protoreflect.EnumType
- type Content
- func (*Content) Descriptor() ([]byte, []int)deprecated
- func (x *Content) GetCoapContentFormat() int32
- func (x *Content) GetContentType() string
- func (x *Content) GetData() []byte
- func (*Content) ProtoMessage()
- func (x *Content) ProtoReflect() protoreflect.Message
- func (x *Content) Reset()
- func (x *Content) String() string
- type CreateResourceRequest
- func (*CreateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceRequest) GetCommandMetadata() *CommandMetadata
- func (x *CreateResourceRequest) GetContent() *Content
- func (x *CreateResourceRequest) GetCorrelationId() string
- func (x *CreateResourceRequest) GetResourceId() *ResourceId
- func (x *CreateResourceRequest) GetTimeToLive() int64
- func (*CreateResourceRequest) ProtoMessage()
- func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateResourceRequest) Reset()
- func (x *CreateResourceRequest) String() string
- type CreateResourceResponse
- func (*CreateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceResponse) GetAuditContext() *AuditContext
- func (x *CreateResourceResponse) GetValidUntil() int64
- 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) GetDeviceIds() []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) GetAuditContext() *AuditContext
- 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) GetCommandMetadata() *CommandMetadata
- func (x *DeleteResourceRequest) GetCorrelationId() string
- func (x *DeleteResourceRequest) GetResourceId() *ResourceId
- func (x *DeleteResourceRequest) GetTimeToLive() int64
- func (*DeleteResourceRequest) ProtoMessage()
- func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteResourceRequest) Reset()
- func (x *DeleteResourceRequest) String() string
- type DeleteResourceResponse
- func (*DeleteResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteResourceResponse) GetAuditContext() *AuditContext
- func (x *DeleteResourceResponse) GetValidUntil() int64
- func (*DeleteResourceResponse) ProtoMessage()
- func (x *DeleteResourceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteResourceResponse) Reset()
- func (x *DeleteResourceResponse) String() string
- type EndpointInformation
- func (e *EndpointInformation) Clone() *EndpointInformation
- func (*EndpointInformation) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointInformation) GetEndpoint() string
- func (x *EndpointInformation) GetPriority() int64
- func (*EndpointInformation) ProtoMessage()
- func (x *EndpointInformation) ProtoReflect() protoreflect.Message
- func (x *EndpointInformation) Reset()
- func (x *EndpointInformation) String() string
- func (e *EndpointInformation) ToSchema() schema.Endpoint
- type EndpointInformations
- type EventContent
- type NotifyResourceChangedRequest
- func (*NotifyResourceChangedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyResourceChangedRequest) GetCommandMetadata() *CommandMetadata
- func (x *NotifyResourceChangedRequest) GetContent() *Content
- func (x *NotifyResourceChangedRequest) GetResourceId() *ResourceId
- func (x *NotifyResourceChangedRequest) GetStatus() Status
- func (*NotifyResourceChangedRequest) ProtoMessage()
- func (x *NotifyResourceChangedRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyResourceChangedRequest) Reset()
- func (x *NotifyResourceChangedRequest) String() string
- type NotifyResourceChangedResponse
- func (*NotifyResourceChangedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyResourceChangedResponse) GetAuditContext() *AuditContext
- func (*NotifyResourceChangedResponse) ProtoMessage()
- func (x *NotifyResourceChangedResponse) ProtoReflect() protoreflect.Message
- func (x *NotifyResourceChangedResponse) Reset()
- func (x *NotifyResourceChangedResponse) String() string
- type Policy
- type PublishResourceLinksRequest
- func (*PublishResourceLinksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResourceLinksRequest) GetCommandMetadata() *CommandMetadata
- func (x *PublishResourceLinksRequest) GetDeviceId() string
- func (x *PublishResourceLinksRequest) GetResources() []*Resource
- func (*PublishResourceLinksRequest) ProtoMessage()
- func (x *PublishResourceLinksRequest) ProtoReflect() protoreflect.Message
- func (x *PublishResourceLinksRequest) Reset()
- func (x *PublishResourceLinksRequest) String() string
- type PublishResourceLinksResponse
- func (*PublishResourceLinksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResourceLinksResponse) GetAuditContext() *AuditContext
- func (x *PublishResourceLinksResponse) GetDeviceId() string
- func (x *PublishResourceLinksResponse) GetPublishedResources() []*Resource
- func (*PublishResourceLinksResponse) ProtoMessage()
- func (x *PublishResourceLinksResponse) ProtoReflect() protoreflect.Message
- func (x *PublishResourceLinksResponse) Reset()
- func (x *PublishResourceLinksResponse) String() string
- type Resource
- func (r *Resource) Clone() *Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetAnchor() string
- func (x *Resource) GetDeviceId() string
- func (x *Resource) GetEndpointInformations() []*EndpointInformation
- func (x *Resource) GetHref() string
- func (x *Resource) GetInterfaces() []string
- func (x *Resource) GetPolicy() *Policy
- func (r *Resource) GetResourceID() *ResourceId
- func (x *Resource) GetResourceTypes() []string
- func (x *Resource) GetSupportedContentTypes() []string
- func (x *Resource) GetTitle() string
- func (x *Resource) GetValidUntil() int64
- func (r *Resource) IsObservable() bool
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- func (r *Resource) ToSchema() schema.ResourceLink
- func (r *Resource) ToUUID() uuid.UUID
- type ResourceId
- func (*ResourceId) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceId) GetDeviceId() string
- func (x *ResourceId) GetHref() string
- func (*ResourceId) ProtoMessage()
- func (x *ResourceId) ProtoReflect() protoreflect.Message
- func (x *ResourceId) Reset()
- func (x *ResourceId) String() string
- func (r *ResourceId) ToString() string
- func (r *ResourceId) ToUUID() uuid.UUID
- type Resources
- type RetrieveResourceRequest
- func (*RetrieveResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RetrieveResourceRequest) GetCommandMetadata() *CommandMetadata
- func (x *RetrieveResourceRequest) GetCorrelationId() string
- func (x *RetrieveResourceRequest) GetResourceId() *ResourceId
- func (x *RetrieveResourceRequest) GetResourceInterface() string
- func (x *RetrieveResourceRequest) GetTimeToLive() int64
- func (*RetrieveResourceRequest) ProtoMessage()
- func (x *RetrieveResourceRequest) ProtoReflect() protoreflect.Message
- func (x *RetrieveResourceRequest) Reset()
- func (x *RetrieveResourceRequest) String() string
- type RetrieveResourceResponse
- func (*RetrieveResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RetrieveResourceResponse) GetAuditContext() *AuditContext
- func (x *RetrieveResourceResponse) GetValidUntil() int64
- func (*RetrieveResourceResponse) ProtoMessage()
- func (x *RetrieveResourceResponse) ProtoReflect() protoreflect.Message
- func (x *RetrieveResourceResponse) Reset()
- func (x *RetrieveResourceResponse) String() string
- type Status
- func (Status) Descriptor() protoreflect.EnumDescriptor
- func (x Status) Enum() *Status
- func (Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x Status) Number() protoreflect.EnumNumber
- func (x Status) String() string
- func (s Status) ToGrpcCode() codes.Code
- func (s Status) ToHTTPCode() int
- func (Status) Type() protoreflect.EnumType
- type TwinSynchronization
- func (*TwinSynchronization) Descriptor() ([]byte, []int)deprecated
- func (x *TwinSynchronization) GetCommandMetadata() *CommandMetadata
- func (x *TwinSynchronization) GetInSyncAt() int64
- func (x *TwinSynchronization) GetState() TwinSynchronization_State
- func (x *TwinSynchronization) GetSyncingAt() int64
- func (*TwinSynchronization) ProtoMessage()
- func (x *TwinSynchronization) ProtoReflect() protoreflect.Message
- func (x *TwinSynchronization) Reset()
- func (x *TwinSynchronization) String() string
- type TwinSynchronization_State
- func (TwinSynchronization_State) Descriptor() protoreflect.EnumDescriptor
- func (x TwinSynchronization_State) Enum() *TwinSynchronization_State
- func (TwinSynchronization_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x TwinSynchronization_State) Number() protoreflect.EnumNumber
- func (x TwinSynchronization_State) String() string
- func (TwinSynchronization_State) Type() protoreflect.EnumType
- type UnpublishResourceLinksRequest
- func (*UnpublishResourceLinksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnpublishResourceLinksRequest) GetCommandMetadata() *CommandMetadata
- func (x *UnpublishResourceLinksRequest) GetDeviceId() string
- func (x *UnpublishResourceLinksRequest) GetHrefs() []string
- func (x *UnpublishResourceLinksRequest) GetInstanceIds() []int64
- func (*UnpublishResourceLinksRequest) ProtoMessage()
- func (x *UnpublishResourceLinksRequest) ProtoReflect() protoreflect.Message
- func (x *UnpublishResourceLinksRequest) Reset()
- func (x *UnpublishResourceLinksRequest) String() string
- type UnpublishResourceLinksResponse
- func (*UnpublishResourceLinksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnpublishResourceLinksResponse) GetAuditContext() *AuditContext
- func (x *UnpublishResourceLinksResponse) GetDeviceId() string
- func (x *UnpublishResourceLinksResponse) GetUnpublishedHrefs() []string
- func (*UnpublishResourceLinksResponse) ProtoMessage()
- func (x *UnpublishResourceLinksResponse) ProtoReflect() protoreflect.Message
- func (x *UnpublishResourceLinksResponse) Reset()
- func (x *UnpublishResourceLinksResponse) String() string
- type UpdateDeviceMetadataRequest
- func (*UpdateDeviceMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeviceMetadataRequest) GetCommandMetadata() *CommandMetadata
- func (x *UpdateDeviceMetadataRequest) GetConnection() *Connection
- func (x *UpdateDeviceMetadataRequest) GetCorrelationId() string
- func (x *UpdateDeviceMetadataRequest) GetDeviceId() string
- func (x *UpdateDeviceMetadataRequest) GetTimeToLive() int64
- func (x *UpdateDeviceMetadataRequest) GetTwinEnabled() bool
- func (x *UpdateDeviceMetadataRequest) GetTwinSynchronization() *TwinSynchronization
- func (m *UpdateDeviceMetadataRequest) GetUpdate() isUpdateDeviceMetadataRequest_Update
- func (*UpdateDeviceMetadataRequest) ProtoMessage()
- func (x *UpdateDeviceMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDeviceMetadataRequest) Reset()
- func (x *UpdateDeviceMetadataRequest) String() string
- type UpdateDeviceMetadataRequest_Connection
- type UpdateDeviceMetadataRequest_TwinEnabled
- type UpdateDeviceMetadataRequest_TwinSynchronization
- type UpdateDeviceMetadataResponse
- func (*UpdateDeviceMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeviceMetadataResponse) GetAuditContext() *AuditContext
- func (x *UpdateDeviceMetadataResponse) GetTwinEnabled() bool
- func (x *UpdateDeviceMetadataResponse) GetValidUntil() int64
- 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) GetCommandMetadata() *CommandMetadata
- func (x *UpdateResourceRequest) GetContent() *Content
- func (x *UpdateResourceRequest) GetCorrelationId() string
- func (x *UpdateResourceRequest) GetResourceId() *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
- type UpdateResourceResponse
- func (*UpdateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceResponse) GetAuditContext() *AuditContext
- func (x *UpdateResourceResponse) GetValidUntil() int64
- func (*UpdateResourceResponse) ProtoMessage()
- func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceResponse) Reset()
- func (x *UpdateResourceResponse) String() string
Constants ¶
const ( ResourceLinksHref string = "/plgd/res" StatusHref string = "/plgd/s" )
Variables ¶
var ( Connection_Status_name = map[int32]string{ 0: "OFFLINE", 1: "ONLINE", } Connection_Status_value = map[string]int32{ "OFFLINE": 0, "ONLINE": 1, } )
Enum value maps for Connection_Status.
var ( Connection_Protocol_name = map[int32]string{ 0: "UNKNOWN", 1: "COAP", 2: "COAPS", 3: "COAP_TCP", 4: "COAPS_TCP", 5: "C2C", } Connection_Protocol_value = map[string]int32{ "UNKNOWN": 0, "COAP": 1, "COAPS": 2, "COAP_TCP": 3, "COAPS_TCP": 4, "C2C": 5, } )
Enum value maps for Connection_Protocol.
var ( TwinSynchronization_State_name = map[int32]string{ 0: "OUT_OF_SYNC", 1: "DISABLED", 2: "SYNCING", 3: "IN_SYNC", } TwinSynchronization_State_value = map[string]int32{ "OUT_OF_SYNC": 0, "DISABLED": 1, "SYNCING": 2, "IN_SYNC": 3, } )
Enum value maps for TwinSynchronization_State.
var ( Status_name = map[int32]string{ 0: "UNKNOWN", 1: "OK", 2: "BAD_REQUEST", 3: "UNAUTHORIZED", 4: "FORBIDDEN", 5: "NOT_FOUND", 6: "UNAVAILABLE", 7: "NOT_IMPLEMENTED", 8: "ACCEPTED", 9: "ERROR", 10: "METHOD_NOT_ALLOWED", 11: "CREATED", 12: "CANCELED", } Status_value = map[string]int32{ "UNKNOWN": 0, "OK": 1, "BAD_REQUEST": 2, "UNAUTHORIZED": 3, "FORBIDDEN": 4, "NOT_FOUND": 5, "UNAVAILABLE": 6, "NOT_IMPLEMENTED": 7, "ACCEPTED": 8, "ERROR": 9, "METHOD_NOT_ALLOWED": 10, "CREATED": 11, "CANCELED": 12, } )
Enum value maps for Status.
var File_resource_aggregate_pb_commands_proto protoreflect.FileDescriptor
var File_resource_aggregate_pb_resources_proto protoreflect.FileDescriptor
Functions ¶
func CheckEventContent ¶
func CheckEventContent(ec EventContent) error
func CloneResourcesMap ¶
func MakeLinksResourceUUID ¶
func MakeStatusResourceUUID ¶
func ResourcesToResourceLinks ¶
func ResourcesToResourceLinks(resources []*Resource) []schema.ResourceLink
Types ¶
type AuditContext ¶
type AuditContext struct { UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` // contains filtered or unexported fields }
func NewAuditContext ¶
func NewAuditContext(userID, correlationID string) *AuditContext
func (*AuditContext) Clone ¶
func (c *AuditContext) Clone() *AuditContext
func (*AuditContext) Descriptor
deprecated
func (*AuditContext) Descriptor() ([]byte, []int)
Deprecated: Use AuditContext.ProtoReflect.Descriptor instead.
func (*AuditContext) GetCorrelationId ¶
func (x *AuditContext) GetCorrelationId() string
func (*AuditContext) GetUserId ¶
func (x *AuditContext) GetUserId() string
func (*AuditContext) ProtoMessage ¶
func (*AuditContext) ProtoMessage()
func (*AuditContext) ProtoReflect ¶
func (x *AuditContext) ProtoReflect() protoreflect.Message
func (*AuditContext) Reset ¶
func (x *AuditContext) Reset()
func (*AuditContext) String ¶
func (x *AuditContext) String() string
type BatchNotifyResourceChangedRequest ¶ added in v2.6.0
type BatchNotifyResourceChangedRequest struct { Batch []*NotifyResourceChangedRequest `protobuf:"bytes,1,rep,name=batch,proto3" json:"batch,omitempty"` // contains filtered or unexported fields }
batch of NotifyResourceChangedRequest
func (*BatchNotifyResourceChangedRequest) Descriptor
deprecated
added in
v2.6.0
func (*BatchNotifyResourceChangedRequest) Descriptor() ([]byte, []int)
Deprecated: Use BatchNotifyResourceChangedRequest.ProtoReflect.Descriptor instead.
func (*BatchNotifyResourceChangedRequest) GetBatch ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedRequest) GetBatch() []*NotifyResourceChangedRequest
func (*BatchNotifyResourceChangedRequest) ProtoMessage ¶ added in v2.6.0
func (*BatchNotifyResourceChangedRequest) ProtoMessage()
func (*BatchNotifyResourceChangedRequest) ProtoReflect ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedRequest) ProtoReflect() protoreflect.Message
func (*BatchNotifyResourceChangedRequest) Reset ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedRequest) Reset()
func (*BatchNotifyResourceChangedRequest) String ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedRequest) String() string
type BatchNotifyResourceChangedResponse ¶ added in v2.6.0
type BatchNotifyResourceChangedResponse struct { AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*BatchNotifyResourceChangedResponse) Descriptor
deprecated
added in
v2.6.0
func (*BatchNotifyResourceChangedResponse) Descriptor() ([]byte, []int)
Deprecated: Use BatchNotifyResourceChangedResponse.ProtoReflect.Descriptor instead.
func (*BatchNotifyResourceChangedResponse) GetAuditContext ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedResponse) GetAuditContext() *AuditContext
func (*BatchNotifyResourceChangedResponse) ProtoMessage ¶ added in v2.6.0
func (*BatchNotifyResourceChangedResponse) ProtoMessage()
func (*BatchNotifyResourceChangedResponse) ProtoReflect ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedResponse) ProtoReflect() protoreflect.Message
func (*BatchNotifyResourceChangedResponse) Reset ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedResponse) Reset()
func (*BatchNotifyResourceChangedResponse) String ¶ added in v2.6.0
func (x *BatchNotifyResourceChangedResponse) String() string
type CancelPendingCommandsRequest ¶
type CancelPendingCommandsRequest struct { ResourceId *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. CommandMetadata *CommandMetadata `protobuf:"bytes,100,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*CancelPendingCommandsRequest) Descriptor
deprecated
func (*CancelPendingCommandsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingCommandsRequest.ProtoReflect.Descriptor instead.
func (*CancelPendingCommandsRequest) GetCommandMetadata ¶
func (x *CancelPendingCommandsRequest) GetCommandMetadata() *CommandMetadata
func (*CancelPendingCommandsRequest) GetCorrelationIdFilter ¶
func (x *CancelPendingCommandsRequest) GetCorrelationIdFilter() []string
func (*CancelPendingCommandsRequest) GetResourceId ¶
func (x *CancelPendingCommandsRequest) GetResourceId() *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"` // list of cancelled correlation id AuditContext *AuditContext `protobuf:"bytes,100,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*CancelPendingCommandsResponse) Descriptor
deprecated
func (*CancelPendingCommandsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingCommandsResponse.ProtoReflect.Descriptor instead.
func (*CancelPendingCommandsResponse) GetAuditContext ¶
func (x *CancelPendingCommandsResponse) GetAuditContext() *AuditContext
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"` // empty array means all. CommandMetadata *CommandMetadata `protobuf:"bytes,100,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*CancelPendingMetadataUpdatesRequest) Descriptor
deprecated
func (*CancelPendingMetadataUpdatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingMetadataUpdatesRequest.ProtoReflect.Descriptor instead.
func (*CancelPendingMetadataUpdatesRequest) GetCommandMetadata ¶
func (x *CancelPendingMetadataUpdatesRequest) GetCommandMetadata() *CommandMetadata
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 CancelPendingMetadataUpdatesResponse ¶
type CancelPendingMetadataUpdatesResponse struct { CorrelationIds []string `protobuf:"bytes,1,rep,name=correlation_ids,json=correlationIds,proto3" json:"correlation_ids,omitempty"` // list of cancelled correlation id AuditContext *AuditContext `protobuf:"bytes,100,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*CancelPendingMetadataUpdatesResponse) Descriptor
deprecated
func (*CancelPendingMetadataUpdatesResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelPendingMetadataUpdatesResponse.ProtoReflect.Descriptor instead.
func (*CancelPendingMetadataUpdatesResponse) GetAuditContext ¶
func (x *CancelPendingMetadataUpdatesResponse) GetAuditContext() *AuditContext
func (*CancelPendingMetadataUpdatesResponse) GetCorrelationIds ¶
func (x *CancelPendingMetadataUpdatesResponse) GetCorrelationIds() []string
func (*CancelPendingMetadataUpdatesResponse) ProtoMessage ¶
func (*CancelPendingMetadataUpdatesResponse) ProtoMessage()
func (*CancelPendingMetadataUpdatesResponse) ProtoReflect ¶
func (x *CancelPendingMetadataUpdatesResponse) ProtoReflect() protoreflect.Message
func (*CancelPendingMetadataUpdatesResponse) Reset ¶
func (x *CancelPendingMetadataUpdatesResponse) Reset()
func (*CancelPendingMetadataUpdatesResponse) String ¶
func (x *CancelPendingMetadataUpdatesResponse) String() string
type CommandMetadata ¶
type CommandMetadata struct { ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"` // contains filtered or unexported fields }
func (*CommandMetadata) Descriptor
deprecated
func (*CommandMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CommandMetadata.ProtoReflect.Descriptor instead.
func (*CommandMetadata) GetConnectionId ¶
func (x *CommandMetadata) GetConnectionId() string
func (*CommandMetadata) GetSequence ¶
func (x *CommandMetadata) GetSequence() uint64
func (*CommandMetadata) ProtoMessage ¶
func (*CommandMetadata) ProtoMessage()
func (*CommandMetadata) ProtoReflect ¶
func (x *CommandMetadata) ProtoReflect() protoreflect.Message
func (*CommandMetadata) Reset ¶
func (x *CommandMetadata) Reset()
func (*CommandMetadata) String ¶
func (x *CommandMetadata) String() string
type ConfirmDeviceMetadataUpdateRequest ¶
type ConfirmDeviceMetadataUpdateRequest struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` // Types that are assignable to Confirm: // // *ConfirmDeviceMetadataUpdateRequest_TwinEnabled Confirm isConfirmDeviceMetadataUpdateRequest_Confirm `protobuf_oneof:"confirm"` CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*ConfirmDeviceMetadataUpdateRequest) Descriptor
deprecated
func (*ConfirmDeviceMetadataUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmDeviceMetadataUpdateRequest.ProtoReflect.Descriptor instead.
func (*ConfirmDeviceMetadataUpdateRequest) GetCommandMetadata ¶
func (x *ConfirmDeviceMetadataUpdateRequest) GetCommandMetadata() *CommandMetadata
func (*ConfirmDeviceMetadataUpdateRequest) GetConfirm ¶
func (m *ConfirmDeviceMetadataUpdateRequest) GetConfirm() isConfirmDeviceMetadataUpdateRequest_Confirm
func (*ConfirmDeviceMetadataUpdateRequest) GetCorrelationId ¶
func (x *ConfirmDeviceMetadataUpdateRequest) GetCorrelationId() string
func (*ConfirmDeviceMetadataUpdateRequest) GetDeviceId ¶
func (x *ConfirmDeviceMetadataUpdateRequest) GetDeviceId() string
func (*ConfirmDeviceMetadataUpdateRequest) GetStatus ¶
func (x *ConfirmDeviceMetadataUpdateRequest) GetStatus() Status
func (*ConfirmDeviceMetadataUpdateRequest) GetTwinEnabled ¶ added in v2.6.0
func (x *ConfirmDeviceMetadataUpdateRequest) GetTwinEnabled() bool
func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage ¶
func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage()
func (*ConfirmDeviceMetadataUpdateRequest) ProtoReflect ¶
func (x *ConfirmDeviceMetadataUpdateRequest) ProtoReflect() protoreflect.Message
func (*ConfirmDeviceMetadataUpdateRequest) Reset ¶
func (x *ConfirmDeviceMetadataUpdateRequest) Reset()
func (*ConfirmDeviceMetadataUpdateRequest) String ¶
func (x *ConfirmDeviceMetadataUpdateRequest) String() string
type ConfirmDeviceMetadataUpdateRequest_TwinEnabled ¶ added in v2.6.0
type ConfirmDeviceMetadataUpdateRequest_TwinEnabled struct {
TwinEnabled bool `protobuf:"varint,6,opt,name=twin_enabled,json=twinEnabled,proto3,oneof"`
}
type ConfirmDeviceMetadataUpdateResponse ¶
type ConfirmDeviceMetadataUpdateResponse struct { AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*ConfirmDeviceMetadataUpdateResponse) Descriptor
deprecated
func (*ConfirmDeviceMetadataUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmDeviceMetadataUpdateResponse.ProtoReflect.Descriptor instead.
func (*ConfirmDeviceMetadataUpdateResponse) GetAuditContext ¶
func (x *ConfirmDeviceMetadataUpdateResponse) GetAuditContext() *AuditContext
func (*ConfirmDeviceMetadataUpdateResponse) ProtoMessage ¶
func (*ConfirmDeviceMetadataUpdateResponse) ProtoMessage()
func (*ConfirmDeviceMetadataUpdateResponse) ProtoReflect ¶
func (x *ConfirmDeviceMetadataUpdateResponse) ProtoReflect() protoreflect.Message
func (*ConfirmDeviceMetadataUpdateResponse) Reset ¶
func (x *ConfirmDeviceMetadataUpdateResponse) Reset()
func (*ConfirmDeviceMetadataUpdateResponse) String ¶
func (x *ConfirmDeviceMetadataUpdateResponse) String() string
type ConfirmResourceCreateRequest ¶
type ConfirmResourceCreateRequest struct { ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *Content `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceCreateRequest) Descriptor
deprecated
func (*ConfirmResourceCreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceCreateRequest.ProtoReflect.Descriptor instead.
func (*ConfirmResourceCreateRequest) GetCommandMetadata ¶
func (x *ConfirmResourceCreateRequest) GetCommandMetadata() *CommandMetadata
func (*ConfirmResourceCreateRequest) GetContent ¶
func (x *ConfirmResourceCreateRequest) GetContent() *Content
func (*ConfirmResourceCreateRequest) GetCorrelationId ¶
func (x *ConfirmResourceCreateRequest) GetCorrelationId() string
func (*ConfirmResourceCreateRequest) GetResourceId ¶
func (x *ConfirmResourceCreateRequest) GetResourceId() *ResourceId
func (*ConfirmResourceCreateRequest) GetStatus ¶
func (x *ConfirmResourceCreateRequest) GetStatus() Status
func (*ConfirmResourceCreateRequest) ProtoMessage ¶
func (*ConfirmResourceCreateRequest) ProtoMessage()
func (*ConfirmResourceCreateRequest) ProtoReflect ¶
func (x *ConfirmResourceCreateRequest) ProtoReflect() protoreflect.Message
func (*ConfirmResourceCreateRequest) Reset ¶
func (x *ConfirmResourceCreateRequest) Reset()
func (*ConfirmResourceCreateRequest) String ¶
func (x *ConfirmResourceCreateRequest) String() string
type ConfirmResourceCreateResponse ¶
type ConfirmResourceCreateResponse struct { AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceCreateResponse) Descriptor
deprecated
func (*ConfirmResourceCreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceCreateResponse.ProtoReflect.Descriptor instead.
func (*ConfirmResourceCreateResponse) GetAuditContext ¶
func (x *ConfirmResourceCreateResponse) GetAuditContext() *AuditContext
func (*ConfirmResourceCreateResponse) ProtoMessage ¶
func (*ConfirmResourceCreateResponse) ProtoMessage()
func (*ConfirmResourceCreateResponse) ProtoReflect ¶
func (x *ConfirmResourceCreateResponse) ProtoReflect() protoreflect.Message
func (*ConfirmResourceCreateResponse) Reset ¶
func (x *ConfirmResourceCreateResponse) Reset()
func (*ConfirmResourceCreateResponse) String ¶
func (x *ConfirmResourceCreateResponse) String() string
type ConfirmResourceDeleteRequest ¶
type ConfirmResourceDeleteRequest struct { ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *Content `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceDeleteRequest) Descriptor
deprecated
func (*ConfirmResourceDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceDeleteRequest.ProtoReflect.Descriptor instead.
func (*ConfirmResourceDeleteRequest) GetCommandMetadata ¶
func (x *ConfirmResourceDeleteRequest) GetCommandMetadata() *CommandMetadata
func (*ConfirmResourceDeleteRequest) GetContent ¶
func (x *ConfirmResourceDeleteRequest) GetContent() *Content
func (*ConfirmResourceDeleteRequest) GetCorrelationId ¶
func (x *ConfirmResourceDeleteRequest) GetCorrelationId() string
func (*ConfirmResourceDeleteRequest) GetResourceId ¶
func (x *ConfirmResourceDeleteRequest) GetResourceId() *ResourceId
func (*ConfirmResourceDeleteRequest) GetStatus ¶
func (x *ConfirmResourceDeleteRequest) GetStatus() Status
func (*ConfirmResourceDeleteRequest) ProtoMessage ¶
func (*ConfirmResourceDeleteRequest) ProtoMessage()
func (*ConfirmResourceDeleteRequest) ProtoReflect ¶
func (x *ConfirmResourceDeleteRequest) ProtoReflect() protoreflect.Message
func (*ConfirmResourceDeleteRequest) Reset ¶
func (x *ConfirmResourceDeleteRequest) Reset()
func (*ConfirmResourceDeleteRequest) String ¶
func (x *ConfirmResourceDeleteRequest) String() string
type ConfirmResourceDeleteResponse ¶
type ConfirmResourceDeleteResponse struct { AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceDeleteResponse) Descriptor
deprecated
func (*ConfirmResourceDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceDeleteResponse.ProtoReflect.Descriptor instead.
func (*ConfirmResourceDeleteResponse) GetAuditContext ¶
func (x *ConfirmResourceDeleteResponse) GetAuditContext() *AuditContext
func (*ConfirmResourceDeleteResponse) ProtoMessage ¶
func (*ConfirmResourceDeleteResponse) ProtoMessage()
func (*ConfirmResourceDeleteResponse) ProtoReflect ¶
func (x *ConfirmResourceDeleteResponse) ProtoReflect() protoreflect.Message
func (*ConfirmResourceDeleteResponse) Reset ¶
func (x *ConfirmResourceDeleteResponse) Reset()
func (*ConfirmResourceDeleteResponse) String ¶
func (x *ConfirmResourceDeleteResponse) String() string
type ConfirmResourceRetrieveRequest ¶
type ConfirmResourceRetrieveRequest struct { ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *Content `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceRetrieveRequest) Descriptor
deprecated
func (*ConfirmResourceRetrieveRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceRetrieveRequest.ProtoReflect.Descriptor instead.
func (*ConfirmResourceRetrieveRequest) GetCommandMetadata ¶
func (x *ConfirmResourceRetrieveRequest) GetCommandMetadata() *CommandMetadata
func (*ConfirmResourceRetrieveRequest) GetContent ¶
func (x *ConfirmResourceRetrieveRequest) GetContent() *Content
func (*ConfirmResourceRetrieveRequest) GetCorrelationId ¶
func (x *ConfirmResourceRetrieveRequest) GetCorrelationId() string
func (*ConfirmResourceRetrieveRequest) GetResourceId ¶
func (x *ConfirmResourceRetrieveRequest) GetResourceId() *ResourceId
func (*ConfirmResourceRetrieveRequest) GetStatus ¶
func (x *ConfirmResourceRetrieveRequest) GetStatus() Status
func (*ConfirmResourceRetrieveRequest) ProtoMessage ¶
func (*ConfirmResourceRetrieveRequest) ProtoMessage()
func (*ConfirmResourceRetrieveRequest) ProtoReflect ¶
func (x *ConfirmResourceRetrieveRequest) ProtoReflect() protoreflect.Message
func (*ConfirmResourceRetrieveRequest) Reset ¶
func (x *ConfirmResourceRetrieveRequest) Reset()
func (*ConfirmResourceRetrieveRequest) String ¶
func (x *ConfirmResourceRetrieveRequest) String() string
type ConfirmResourceRetrieveResponse ¶
type ConfirmResourceRetrieveResponse struct { AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceRetrieveResponse) Descriptor
deprecated
func (*ConfirmResourceRetrieveResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceRetrieveResponse.ProtoReflect.Descriptor instead.
func (*ConfirmResourceRetrieveResponse) GetAuditContext ¶
func (x *ConfirmResourceRetrieveResponse) GetAuditContext() *AuditContext
func (*ConfirmResourceRetrieveResponse) ProtoMessage ¶
func (*ConfirmResourceRetrieveResponse) ProtoMessage()
func (*ConfirmResourceRetrieveResponse) ProtoReflect ¶
func (x *ConfirmResourceRetrieveResponse) ProtoReflect() protoreflect.Message
func (*ConfirmResourceRetrieveResponse) Reset ¶
func (x *ConfirmResourceRetrieveResponse) Reset()
func (*ConfirmResourceRetrieveResponse) String ¶
func (x *ConfirmResourceRetrieveResponse) String() string
type ConfirmResourceUpdateRequest ¶
type ConfirmResourceUpdateRequest struct { ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *Content `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceUpdateRequest) Descriptor
deprecated
func (*ConfirmResourceUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceUpdateRequest.ProtoReflect.Descriptor instead.
func (*ConfirmResourceUpdateRequest) GetCommandMetadata ¶
func (x *ConfirmResourceUpdateRequest) GetCommandMetadata() *CommandMetadata
func (*ConfirmResourceUpdateRequest) GetContent ¶
func (x *ConfirmResourceUpdateRequest) GetContent() *Content
func (*ConfirmResourceUpdateRequest) GetCorrelationId ¶
func (x *ConfirmResourceUpdateRequest) GetCorrelationId() string
func (*ConfirmResourceUpdateRequest) GetResourceId ¶
func (x *ConfirmResourceUpdateRequest) GetResourceId() *ResourceId
func (*ConfirmResourceUpdateRequest) GetStatus ¶
func (x *ConfirmResourceUpdateRequest) GetStatus() Status
func (*ConfirmResourceUpdateRequest) ProtoMessage ¶
func (*ConfirmResourceUpdateRequest) ProtoMessage()
func (*ConfirmResourceUpdateRequest) ProtoReflect ¶
func (x *ConfirmResourceUpdateRequest) ProtoReflect() protoreflect.Message
func (*ConfirmResourceUpdateRequest) Reset ¶
func (x *ConfirmResourceUpdateRequest) Reset()
func (*ConfirmResourceUpdateRequest) String ¶
func (x *ConfirmResourceUpdateRequest) String() string
type ConfirmResourceUpdateResponse ¶
type ConfirmResourceUpdateResponse struct { AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*ConfirmResourceUpdateResponse) Descriptor
deprecated
func (*ConfirmResourceUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfirmResourceUpdateResponse.ProtoReflect.Descriptor instead.
func (*ConfirmResourceUpdateResponse) GetAuditContext ¶
func (x *ConfirmResourceUpdateResponse) GetAuditContext() *AuditContext
func (*ConfirmResourceUpdateResponse) ProtoMessage ¶
func (*ConfirmResourceUpdateResponse) ProtoMessage()
func (*ConfirmResourceUpdateResponse) ProtoReflect ¶
func (x *ConfirmResourceUpdateResponse) ProtoReflect() protoreflect.Message
func (*ConfirmResourceUpdateResponse) Reset ¶
func (x *ConfirmResourceUpdateResponse) Reset()
func (*ConfirmResourceUpdateResponse) String ¶
func (x *ConfirmResourceUpdateResponse) String() string
type Connection ¶ added in v2.6.0
type Connection struct { Status Connection_Status `protobuf:"varint,1,opt,name=status,proto3,enum=resourceaggregate.pb.Connection_Status" json:"status,omitempty"` OnlineValidUntil int64 `protobuf:"varint,2,opt,name=online_valid_until,json=onlineValidUntil,proto3" json:"online_valid_until,omitempty"` Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // when status is ONLINE, this field contains the connection id. To update state offline, this field must be same as the one in the previous message. ConnectedAt int64 `protobuf:"varint,4,opt,name=connected_at,json=connectedAt,proto3" json:"connected_at,omitempty"` // timestamp when the device was connected Protocol Connection_Protocol `protobuf:"varint,5,opt,name=protocol,proto3,enum=resourceaggregate.pb.Connection_Protocol" json:"protocol,omitempty"` // application protocol. It need to be set when the status is ONLINE. // contains filtered or unexported fields }
func NewConnection ¶ added in v2.6.0
func NewConnection(status Connection_Status, onlineValidUntil int64, connectionID string, connectedAt int64) *Connection
func (*Connection) Clone ¶ added in v2.6.0
func (c *Connection) Clone() *Connection
func (*Connection) Descriptor
deprecated
added in
v2.6.0
func (*Connection) Descriptor() ([]byte, []int)
Deprecated: Use Connection.ProtoReflect.Descriptor instead.
func (*Connection) GetConnectedAt ¶ added in v2.6.0
func (x *Connection) GetConnectedAt() int64
func (*Connection) GetId ¶ added in v2.6.0
func (x *Connection) GetId() string
func (*Connection) GetOnlineValidUntil ¶ added in v2.6.0
func (x *Connection) GetOnlineValidUntil() int64
func (*Connection) GetProtocol ¶ added in v2.7.0
func (x *Connection) GetProtocol() Connection_Protocol
func (*Connection) GetStatus ¶ added in v2.6.0
func (x *Connection) GetStatus() Connection_Status
func (*Connection) IsOnline ¶ added in v2.6.0
func (c *Connection) IsOnline() bool
IsOnline evaluates online state
func (*Connection) ProtoMessage ¶ added in v2.6.0
func (*Connection) ProtoMessage()
func (*Connection) ProtoReflect ¶ added in v2.6.0
func (x *Connection) ProtoReflect() protoreflect.Message
func (*Connection) Reset ¶ added in v2.6.0
func (x *Connection) Reset()
func (*Connection) String ¶ added in v2.6.0
func (x *Connection) String() string
type Connection_Protocol ¶ added in v2.7.0
type Connection_Protocol int32
const ( Connection_UNKNOWN Connection_Protocol = 0 Connection_COAP Connection_Protocol = 1 Connection_COAPS Connection_Protocol = 2 Connection_COAP_TCP Connection_Protocol = 3 Connection_COAPS_TCP Connection_Protocol = 4 Connection_C2C Connection_Protocol = 5 )
func (Connection_Protocol) Descriptor ¶ added in v2.7.0
func (Connection_Protocol) Descriptor() protoreflect.EnumDescriptor
func (Connection_Protocol) Enum ¶ added in v2.7.0
func (x Connection_Protocol) Enum() *Connection_Protocol
func (Connection_Protocol) EnumDescriptor
deprecated
added in
v2.7.0
func (Connection_Protocol) EnumDescriptor() ([]byte, []int)
Deprecated: Use Connection_Protocol.Descriptor instead.
func (Connection_Protocol) Number ¶ added in v2.7.0
func (x Connection_Protocol) Number() protoreflect.EnumNumber
func (Connection_Protocol) String ¶ added in v2.7.0
func (x Connection_Protocol) String() string
func (Connection_Protocol) Type ¶ added in v2.7.0
func (Connection_Protocol) Type() protoreflect.EnumType
type Connection_Status ¶ added in v2.6.0
type Connection_Status int32
const ( Connection_OFFLINE Connection_Status = 0 Connection_ONLINE Connection_Status = 1 )
func (Connection_Status) Descriptor ¶ added in v2.6.0
func (Connection_Status) Descriptor() protoreflect.EnumDescriptor
func (Connection_Status) Enum ¶ added in v2.6.0
func (x Connection_Status) Enum() *Connection_Status
func (Connection_Status) EnumDescriptor
deprecated
added in
v2.6.0
func (Connection_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use Connection_Status.Descriptor instead.
func (Connection_Status) Number ¶ added in v2.6.0
func (x Connection_Status) Number() protoreflect.EnumNumber
func (Connection_Status) String ¶ added in v2.6.0
func (x Connection_Status) String() string
func (Connection_Status) Type ¶ added in v2.6.0
func (Connection_Status) Type() protoreflect.EnumType
type Content ¶
type Content struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` ContentType string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` CoapContentFormat int32 `protobuf:"varint,3,opt,name=coap_content_format,json=coapContentFormat,proto3" json:"coap_content_format,omitempty"` // -1 means content-format was not provided // contains filtered or unexported fields }
func EventContentToContent ¶
func EventContentToContent(ec EventContent) (*Content, error)
func (*Content) Descriptor
deprecated
func (*Content) GetCoapContentFormat ¶
func (*Content) GetContentType ¶
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
func (*Content) ProtoReflect ¶
func (x *Content) ProtoReflect() protoreflect.Message
type CreateResourceRequest ¶
type CreateResourceRequest struct { ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Content *Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,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). CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*CreateResourceRequest) Descriptor
deprecated
func (*CreateResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateResourceRequest.ProtoReflect.Descriptor instead.
func (*CreateResourceRequest) GetCommandMetadata ¶
func (x *CreateResourceRequest) GetCommandMetadata() *CommandMetadata
func (*CreateResourceRequest) GetContent ¶
func (x *CreateResourceRequest) GetContent() *Content
func (*CreateResourceRequest) GetCorrelationId ¶
func (x *CreateResourceRequest) GetCorrelationId() string
func (*CreateResourceRequest) GetResourceId ¶
func (x *CreateResourceRequest) GetResourceId() *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
type CreateResourceResponse ¶
type CreateResourceResponse struct { ValidUntil int64 `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever. AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*CreateResourceResponse) Descriptor
deprecated
func (*CreateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResourceResponse.ProtoReflect.Descriptor instead.
func (*CreateResourceResponse) GetAuditContext ¶
func (x *CreateResourceResponse) GetAuditContext() *AuditContext
func (*CreateResourceResponse) GetValidUntil ¶
func (x *CreateResourceResponse) GetValidUntil() int64
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 { DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteDevicesRequest) Descriptor
deprecated
func (*DeleteDevicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDevicesRequest.ProtoReflect.Descriptor instead.
func (*DeleteDevicesRequest) GetDeviceIds ¶
func (x *DeleteDevicesRequest) GetDeviceIds() []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"` AuditContext *AuditContext `protobuf:"bytes,100,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*DeleteDevicesResponse) Descriptor
deprecated
func (*DeleteDevicesResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDevicesResponse.ProtoReflect.Descriptor instead.
func (*DeleteDevicesResponse) GetAuditContext ¶
func (x *DeleteDevicesResponse) GetAuditContext() *AuditContext
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 *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,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). CommandMetadata *CommandMetadata `protobuf:"bytes,4,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*DeleteResourceRequest) Descriptor
deprecated
func (*DeleteResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResourceRequest.ProtoReflect.Descriptor instead.
func (*DeleteResourceRequest) GetCommandMetadata ¶
func (x *DeleteResourceRequest) GetCommandMetadata() *CommandMetadata
func (*DeleteResourceRequest) GetCorrelationId ¶
func (x *DeleteResourceRequest) GetCorrelationId() string
func (*DeleteResourceRequest) GetResourceId ¶
func (x *DeleteResourceRequest) GetResourceId() *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
type DeleteResourceResponse ¶
type DeleteResourceResponse struct { ValidUntil int64 `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever. AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*DeleteResourceResponse) Descriptor
deprecated
func (*DeleteResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResourceResponse.ProtoReflect.Descriptor instead.
func (*DeleteResourceResponse) GetAuditContext ¶
func (x *DeleteResourceResponse) GetAuditContext() *AuditContext
func (*DeleteResourceResponse) GetValidUntil ¶
func (x *DeleteResourceResponse) GetValidUntil() int64
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 EndpointInformation ¶
type EndpointInformation struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Priority int64 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"` // contains filtered or unexported fields }
func SchemaEndpointsToRAEndpointInformations ¶
func SchemaEndpointsToRAEndpointInformations(ra []schema.Endpoint) []*EndpointInformation
func (*EndpointInformation) Clone ¶
func (e *EndpointInformation) Clone() *EndpointInformation
func (*EndpointInformation) Descriptor
deprecated
func (*EndpointInformation) Descriptor() ([]byte, []int)
Deprecated: Use EndpointInformation.ProtoReflect.Descriptor instead.
func (*EndpointInformation) GetEndpoint ¶
func (x *EndpointInformation) GetEndpoint() string
func (*EndpointInformation) GetPriority ¶
func (x *EndpointInformation) GetPriority() int64
func (*EndpointInformation) ProtoMessage ¶
func (*EndpointInformation) ProtoMessage()
func (*EndpointInformation) ProtoReflect ¶
func (x *EndpointInformation) ProtoReflect() protoreflect.Message
func (*EndpointInformation) Reset ¶
func (x *EndpointInformation) Reset()
func (*EndpointInformation) String ¶
func (x *EndpointInformation) String() string
func (*EndpointInformation) ToSchema ¶
func (e *EndpointInformation) ToSchema() schema.Endpoint
type EndpointInformations ¶
type EndpointInformations []*EndpointInformation
func (EndpointInformations) Clone ¶
func (e EndpointInformations) Clone() EndpointInformations
func (EndpointInformations) ToSchema ¶
func (e EndpointInformations) ToSchema() []schema.Endpoint
type EventContent ¶
type EventContent interface { GetContent() *Content GetStatus() Status protoiface.MessageV1 }
type NotifyResourceChangedRequest ¶
type NotifyResourceChangedRequest struct { ResourceId *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"` CommandMetadata *CommandMetadata `protobuf:"bytes,3,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` Status Status `protobuf:"varint,4,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*NotifyResourceChangedRequest) Descriptor
deprecated
func (*NotifyResourceChangedRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyResourceChangedRequest.ProtoReflect.Descriptor instead.
func (*NotifyResourceChangedRequest) GetCommandMetadata ¶
func (x *NotifyResourceChangedRequest) GetCommandMetadata() *CommandMetadata
func (*NotifyResourceChangedRequest) GetContent ¶
func (x *NotifyResourceChangedRequest) GetContent() *Content
func (*NotifyResourceChangedRequest) GetResourceId ¶
func (x *NotifyResourceChangedRequest) GetResourceId() *ResourceId
func (*NotifyResourceChangedRequest) GetStatus ¶
func (x *NotifyResourceChangedRequest) GetStatus() Status
func (*NotifyResourceChangedRequest) ProtoMessage ¶
func (*NotifyResourceChangedRequest) ProtoMessage()
func (*NotifyResourceChangedRequest) ProtoReflect ¶
func (x *NotifyResourceChangedRequest) ProtoReflect() protoreflect.Message
func (*NotifyResourceChangedRequest) Reset ¶
func (x *NotifyResourceChangedRequest) Reset()
func (*NotifyResourceChangedRequest) String ¶
func (x *NotifyResourceChangedRequest) String() string
type NotifyResourceChangedResponse ¶
type NotifyResourceChangedResponse struct { AuditContext *AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*NotifyResourceChangedResponse) Descriptor
deprecated
func (*NotifyResourceChangedResponse) Descriptor() ([]byte, []int)
Deprecated: Use NotifyResourceChangedResponse.ProtoReflect.Descriptor instead.
func (*NotifyResourceChangedResponse) GetAuditContext ¶
func (x *NotifyResourceChangedResponse) GetAuditContext() *AuditContext
func (*NotifyResourceChangedResponse) ProtoMessage ¶
func (*NotifyResourceChangedResponse) ProtoMessage()
func (*NotifyResourceChangedResponse) ProtoReflect ¶
func (x *NotifyResourceChangedResponse) ProtoReflect() protoreflect.Message
func (*NotifyResourceChangedResponse) Reset ¶
func (x *NotifyResourceChangedResponse) Reset()
func (*NotifyResourceChangedResponse) String ¶
func (x *NotifyResourceChangedResponse) String() string
type Policy ¶
type Policy struct { BitFlags int32 `protobuf:"varint,1,opt,name=bit_flags,json=bitFlags,proto3" json:"bit_flags,omitempty"` // contains filtered or unexported fields }
func SchemaPolicyToRAPolicy ¶
func (*Policy) Descriptor
deprecated
func (*Policy) GetBitFlags ¶
func (*Policy) ProtoMessage ¶
func (*Policy) ProtoMessage()
func (*Policy) ProtoReflect ¶
func (x *Policy) ProtoReflect() protoreflect.Message
type PublishResourceLinksRequest ¶
type PublishResourceLinksRequest struct { Resources []*Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` CommandMetadata *CommandMetadata `protobuf:"bytes,3,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*PublishResourceLinksRequest) Descriptor
deprecated
func (*PublishResourceLinksRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishResourceLinksRequest.ProtoReflect.Descriptor instead.
func (*PublishResourceLinksRequest) GetCommandMetadata ¶
func (x *PublishResourceLinksRequest) GetCommandMetadata() *CommandMetadata
func (*PublishResourceLinksRequest) GetDeviceId ¶
func (x *PublishResourceLinksRequest) GetDeviceId() string
func (*PublishResourceLinksRequest) GetResources ¶
func (x *PublishResourceLinksRequest) GetResources() []*Resource
func (*PublishResourceLinksRequest) ProtoMessage ¶
func (*PublishResourceLinksRequest) ProtoMessage()
func (*PublishResourceLinksRequest) ProtoReflect ¶
func (x *PublishResourceLinksRequest) ProtoReflect() protoreflect.Message
func (*PublishResourceLinksRequest) Reset ¶
func (x *PublishResourceLinksRequest) Reset()
func (*PublishResourceLinksRequest) String ¶
func (x *PublishResourceLinksRequest) String() string
type PublishResourceLinksResponse ¶
type PublishResourceLinksResponse struct { PublishedResources []*Resource `protobuf:"bytes,1,rep,name=published_resources,json=publishedResources,proto3" json:"published_resources,omitempty"` DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` AuditContext *AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*PublishResourceLinksResponse) Descriptor
deprecated
func (*PublishResourceLinksResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishResourceLinksResponse.ProtoReflect.Descriptor instead.
func (*PublishResourceLinksResponse) GetAuditContext ¶
func (x *PublishResourceLinksResponse) GetAuditContext() *AuditContext
func (*PublishResourceLinksResponse) GetDeviceId ¶
func (x *PublishResourceLinksResponse) GetDeviceId() string
func (*PublishResourceLinksResponse) GetPublishedResources ¶
func (x *PublishResourceLinksResponse) GetPublishedResources() []*Resource
func (*PublishResourceLinksResponse) ProtoMessage ¶
func (*PublishResourceLinksResponse) ProtoMessage()
func (*PublishResourceLinksResponse) ProtoReflect ¶
func (x *PublishResourceLinksResponse) ProtoReflect() protoreflect.Message
func (*PublishResourceLinksResponse) Reset ¶
func (x *PublishResourceLinksResponse) Reset()
func (*PublishResourceLinksResponse) String ¶
func (x *PublishResourceLinksResponse) String() string
type Resource ¶
type Resource struct { Href string `protobuf:"bytes,1,opt,name=href,proto3" json:"href,omitempty"` DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` ResourceTypes []string `protobuf:"bytes,3,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"` Interfaces []string `protobuf:"bytes,4,rep,name=interfaces,proto3" json:"interfaces,omitempty"` Anchor string `protobuf:"bytes,5,opt,name=anchor,proto3" json:"anchor,omitempty"` Title string `protobuf:"bytes,6,opt,name=title,proto3" json:"title,omitempty"` SupportedContentTypes []string `` /* 126-byte string literal not displayed */ ValidUntil int64 `protobuf:"varint,8,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` Policy *Policy `protobuf:"bytes,9,opt,name=policy,proto3" json:"policy,omitempty"` EndpointInformations []*EndpointInformation `protobuf:"bytes,10,rep,name=endpoint_informations,json=endpointInformations,proto3" json:"endpoint_informations,omitempty"` // contains filtered or unexported fields }
func SchemaResourceLinkToResource ¶
func SchemaResourceLinkToResource(link schema.ResourceLink, validUntil time.Time) *Resource
func SchemaResourceLinksToResources ¶
func SchemaResourceLinksToResources(links schema.ResourceLinks, validUntil time.Time) []*Resource
func (*Resource) Descriptor
deprecated
func (*Resource) GetDeviceId ¶
func (*Resource) GetEndpointInformations ¶
func (x *Resource) GetEndpointInformations() []*EndpointInformation
func (*Resource) GetInterfaces ¶
func (*Resource) GetResourceID ¶
func (r *Resource) GetResourceID() *ResourceId
GetResourceID converts resource href and device id to resource id struct
func (*Resource) GetResourceTypes ¶
func (*Resource) GetSupportedContentTypes ¶
func (*Resource) GetValidUntil ¶
func (*Resource) IsObservable ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
func (*Resource) ToSchema ¶
func (r *Resource) ToSchema() schema.ResourceLink
type ResourceId ¶
type ResourceId struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Href string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"` // contains filtered or unexported fields }
func NewResourceID ¶
func NewResourceID(deviceID, href string) *ResourceId
func ResourceIdFromString ¶
func ResourceIdFromString(v string) *ResourceId
func SchemaResourceLinkToResourceId ¶
func SchemaResourceLinkToResourceId(link schema.ResourceLink) *ResourceId
func (*ResourceId) Descriptor
deprecated
func (*ResourceId) Descriptor() ([]byte, []int)
Deprecated: Use ResourceId.ProtoReflect.Descriptor instead.
func (*ResourceId) GetDeviceId ¶
func (x *ResourceId) GetDeviceId() string
func (*ResourceId) GetHref ¶
func (x *ResourceId) GetHref() string
func (*ResourceId) ProtoMessage ¶
func (*ResourceId) ProtoMessage()
func (*ResourceId) ProtoReflect ¶
func (x *ResourceId) ProtoReflect() protoreflect.Message
func (*ResourceId) Reset ¶
func (x *ResourceId) Reset()
func (*ResourceId) String ¶
func (x *ResourceId) String() string
func (*ResourceId) ToString ¶
func (r *ResourceId) ToString() string
func (*ResourceId) ToUUID ¶
func (r *ResourceId) ToUUID() uuid.UUID
ToUUID converts resource href and device id to unique resource ID
type RetrieveResourceRequest ¶
type RetrieveResourceRequest struct { ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_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). CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*RetrieveResourceRequest) Descriptor
deprecated
func (*RetrieveResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveResourceRequest.ProtoReflect.Descriptor instead.
func (*RetrieveResourceRequest) GetCommandMetadata ¶
func (x *RetrieveResourceRequest) GetCommandMetadata() *CommandMetadata
func (*RetrieveResourceRequest) GetCorrelationId ¶
func (x *RetrieveResourceRequest) GetCorrelationId() string
func (*RetrieveResourceRequest) GetResourceId ¶
func (x *RetrieveResourceRequest) GetResourceId() *ResourceId
func (*RetrieveResourceRequest) GetResourceInterface ¶
func (x *RetrieveResourceRequest) GetResourceInterface() string
func (*RetrieveResourceRequest) GetTimeToLive ¶
func (x *RetrieveResourceRequest) GetTimeToLive() int64
func (*RetrieveResourceRequest) ProtoMessage ¶
func (*RetrieveResourceRequest) ProtoMessage()
func (*RetrieveResourceRequest) ProtoReflect ¶
func (x *RetrieveResourceRequest) ProtoReflect() protoreflect.Message
func (*RetrieveResourceRequest) Reset ¶
func (x *RetrieveResourceRequest) Reset()
func (*RetrieveResourceRequest) String ¶
func (x *RetrieveResourceRequest) String() string
type RetrieveResourceResponse ¶
type RetrieveResourceResponse struct { ValidUntil int64 `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever. AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*RetrieveResourceResponse) Descriptor
deprecated
func (*RetrieveResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveResourceResponse.ProtoReflect.Descriptor instead.
func (*RetrieveResourceResponse) GetAuditContext ¶
func (x *RetrieveResourceResponse) GetAuditContext() *AuditContext
func (*RetrieveResourceResponse) GetValidUntil ¶
func (x *RetrieveResourceResponse) GetValidUntil() int64
func (*RetrieveResourceResponse) ProtoMessage ¶
func (*RetrieveResourceResponse) ProtoMessage()
func (*RetrieveResourceResponse) ProtoReflect ¶
func (x *RetrieveResourceResponse) ProtoReflect() protoreflect.Message
func (*RetrieveResourceResponse) Reset ¶
func (x *RetrieveResourceResponse) Reset()
func (*RetrieveResourceResponse) String ¶
func (x *RetrieveResourceResponse) String() string
type Status ¶
type Status int32
const ( Status_UNKNOWN Status = 0 Status_OK Status = 1 Status_BAD_REQUEST Status = 2 Status_UNAUTHORIZED Status = 3 Status_FORBIDDEN Status = 4 Status_NOT_FOUND Status = 5 Status_UNAVAILABLE Status = 6 Status_NOT_IMPLEMENTED Status = 7 Status_ACCEPTED Status = 8 Status_ERROR Status = 9 Status_METHOD_NOT_ALLOWED Status = 10 Status_CREATED Status = 11 Status_CANCELED Status = 12 // Canceled indicates the operation was canceled (typically by the user). )
func HTTPStatus2Status ¶
func (Status) Descriptor ¶
func (Status) Descriptor() protoreflect.EnumDescriptor
func (Status) EnumDescriptor
deprecated
func (Status) Number ¶
func (x Status) Number() protoreflect.EnumNumber
func (Status) ToGrpcCode ¶
func (Status) ToHTTPCode ¶
func (Status) Type ¶
func (Status) Type() protoreflect.EnumType
type TwinSynchronization ¶ added in v2.6.0
type TwinSynchronization struct { State TwinSynchronization_State `protobuf:"varint,1,opt,name=state,proto3,enum=resourceaggregate.pb.TwinSynchronization_State" json:"state,omitempty"` SyncingAt int64 `protobuf:"varint,2,opt,name=syncing_at,json=syncingAt,proto3" json:"syncing_at,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when synchronization started. InSyncAt int64 `protobuf:"varint,3,opt,name=in_sync_at,json=inSyncAt,proto3" json:"in_sync_at,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when synchronization finished. CommandMetadata *CommandMetadata `protobuf:"bytes,4,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // when status is SYNCING, this field contains the connection id. To update state to IN_SYNC, this field must be same as the one in the previous message. // contains filtered or unexported fields }
func (*TwinSynchronization) Descriptor
deprecated
added in
v2.6.0
func (*TwinSynchronization) Descriptor() ([]byte, []int)
Deprecated: Use TwinSynchronization.ProtoReflect.Descriptor instead.
func (*TwinSynchronization) GetCommandMetadata ¶ added in v2.6.0
func (x *TwinSynchronization) GetCommandMetadata() *CommandMetadata
func (*TwinSynchronization) GetInSyncAt ¶ added in v2.6.0
func (x *TwinSynchronization) GetInSyncAt() int64
func (*TwinSynchronization) GetState ¶ added in v2.6.0
func (x *TwinSynchronization) GetState() TwinSynchronization_State
func (*TwinSynchronization) GetSyncingAt ¶ added in v2.6.0
func (x *TwinSynchronization) GetSyncingAt() int64
func (*TwinSynchronization) ProtoMessage ¶ added in v2.6.0
func (*TwinSynchronization) ProtoMessage()
func (*TwinSynchronization) ProtoReflect ¶ added in v2.6.0
func (x *TwinSynchronization) ProtoReflect() protoreflect.Message
func (*TwinSynchronization) Reset ¶ added in v2.6.0
func (x *TwinSynchronization) Reset()
func (*TwinSynchronization) String ¶ added in v2.6.0
func (x *TwinSynchronization) String() string
type TwinSynchronization_State ¶ added in v2.6.0
type TwinSynchronization_State int32
const ( TwinSynchronization_OUT_OF_SYNC TwinSynchronization_State = 0 // As soon as it connects after it was offline or when it goes errorless offline or when twin enabled has been changed to true. TwinSynchronization_DISABLED TwinSynchronization_State = 1 // As soon as twin enabled is set to false. TwinSynchronization_SYNCING TwinSynchronization_State = 2 // As soon as device connects, successfully signs in and batch observe is called on device from the cloud. TwinSynchronization_IN_SYNC TwinSynchronization_State = 3 // As soon as current device resources values are received and applied to twin database. Twin was successfully reconciled after device reconnect and is kept up to date using an active subscription to device resource changes. )
func (TwinSynchronization_State) Descriptor ¶ added in v2.6.0
func (TwinSynchronization_State) Descriptor() protoreflect.EnumDescriptor
func (TwinSynchronization_State) Enum ¶ added in v2.6.0
func (x TwinSynchronization_State) Enum() *TwinSynchronization_State
func (TwinSynchronization_State) EnumDescriptor
deprecated
added in
v2.6.0
func (TwinSynchronization_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use TwinSynchronization_State.Descriptor instead.
func (TwinSynchronization_State) Number ¶ added in v2.6.0
func (x TwinSynchronization_State) Number() protoreflect.EnumNumber
func (TwinSynchronization_State) String ¶ added in v2.6.0
func (x TwinSynchronization_State) String() string
func (TwinSynchronization_State) Type ¶ added in v2.6.0
func (TwinSynchronization_State) Type() protoreflect.EnumType
type UnpublishResourceLinksRequest ¶
type UnpublishResourceLinksRequest struct { Hrefs []string `protobuf:"bytes,1,rep,name=hrefs,proto3" json:"hrefs,omitempty"` DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` CommandMetadata *CommandMetadata `protobuf:"bytes,3,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` InstanceIds []int64 `protobuf:"varint,4,rep,packed,name=instance_ids,json=instanceIds,proto3" json:"instance_ids,omitempty"` // used by device when sending unpublish request to RD // contains filtered or unexported fields }
https://github.com/openconnectivityfoundation/cloud-services/blob/master/swagger2.0/oic.wk.rd.swagger.json #Specification CR needed
func (*UnpublishResourceLinksRequest) Descriptor
deprecated
func (*UnpublishResourceLinksRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnpublishResourceLinksRequest.ProtoReflect.Descriptor instead.
func (*UnpublishResourceLinksRequest) GetCommandMetadata ¶
func (x *UnpublishResourceLinksRequest) GetCommandMetadata() *CommandMetadata
func (*UnpublishResourceLinksRequest) GetDeviceId ¶
func (x *UnpublishResourceLinksRequest) GetDeviceId() string
func (*UnpublishResourceLinksRequest) GetHrefs ¶
func (x *UnpublishResourceLinksRequest) GetHrefs() []string
func (*UnpublishResourceLinksRequest) GetInstanceIds ¶
func (x *UnpublishResourceLinksRequest) GetInstanceIds() []int64
func (*UnpublishResourceLinksRequest) ProtoMessage ¶
func (*UnpublishResourceLinksRequest) ProtoMessage()
func (*UnpublishResourceLinksRequest) ProtoReflect ¶
func (x *UnpublishResourceLinksRequest) ProtoReflect() protoreflect.Message
func (*UnpublishResourceLinksRequest) Reset ¶
func (x *UnpublishResourceLinksRequest) Reset()
func (*UnpublishResourceLinksRequest) String ¶
func (x *UnpublishResourceLinksRequest) String() string
type UnpublishResourceLinksResponse ¶
type UnpublishResourceLinksResponse struct { UnpublishedHrefs []string `protobuf:"bytes,1,rep,name=unpublished_hrefs,json=unpublishedHrefs,proto3" json:"unpublished_hrefs,omitempty"` DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` AuditContext *AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*UnpublishResourceLinksResponse) Descriptor
deprecated
func (*UnpublishResourceLinksResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnpublishResourceLinksResponse.ProtoReflect.Descriptor instead.
func (*UnpublishResourceLinksResponse) GetAuditContext ¶
func (x *UnpublishResourceLinksResponse) GetAuditContext() *AuditContext
func (*UnpublishResourceLinksResponse) GetDeviceId ¶
func (x *UnpublishResourceLinksResponse) GetDeviceId() string
func (*UnpublishResourceLinksResponse) GetUnpublishedHrefs ¶
func (x *UnpublishResourceLinksResponse) GetUnpublishedHrefs() []string
func (*UnpublishResourceLinksResponse) ProtoMessage ¶
func (*UnpublishResourceLinksResponse) ProtoMessage()
func (*UnpublishResourceLinksResponse) ProtoReflect ¶
func (x *UnpublishResourceLinksResponse) ProtoReflect() protoreflect.Message
func (*UnpublishResourceLinksResponse) Reset ¶
func (x *UnpublishResourceLinksResponse) Reset()
func (*UnpublishResourceLinksResponse) String ¶
func (x *UnpublishResourceLinksResponse) String() string
type UpdateDeviceMetadataRequest ¶
type UpdateDeviceMetadataRequest struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` // Types that are assignable to Update: // // *UpdateDeviceMetadataRequest_Connection // *UpdateDeviceMetadataRequest_TwinSynchronization // *UpdateDeviceMetadataRequest_TwinEnabled Update isUpdateDeviceMetadataRequest_Update `protobuf_oneof:"update"` TimeToLive int64 `protobuf:"varint,5,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). CommandMetadata *CommandMetadata `protobuf:"bytes,6,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*UpdateDeviceMetadataRequest) Descriptor
deprecated
func (*UpdateDeviceMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDeviceMetadataRequest.ProtoReflect.Descriptor instead.
func (*UpdateDeviceMetadataRequest) GetCommandMetadata ¶
func (x *UpdateDeviceMetadataRequest) GetCommandMetadata() *CommandMetadata
func (*UpdateDeviceMetadataRequest) GetConnection ¶ added in v2.6.0
func (x *UpdateDeviceMetadataRequest) GetConnection() *Connection
func (*UpdateDeviceMetadataRequest) GetCorrelationId ¶
func (x *UpdateDeviceMetadataRequest) GetCorrelationId() string
func (*UpdateDeviceMetadataRequest) GetDeviceId ¶
func (x *UpdateDeviceMetadataRequest) GetDeviceId() string
func (*UpdateDeviceMetadataRequest) GetTimeToLive ¶
func (x *UpdateDeviceMetadataRequest) GetTimeToLive() int64
func (*UpdateDeviceMetadataRequest) GetTwinEnabled ¶ added in v2.6.0
func (x *UpdateDeviceMetadataRequest) GetTwinEnabled() bool
func (*UpdateDeviceMetadataRequest) GetTwinSynchronization ¶ added in v2.6.0
func (x *UpdateDeviceMetadataRequest) GetTwinSynchronization() *TwinSynchronization
func (*UpdateDeviceMetadataRequest) GetUpdate ¶
func (m *UpdateDeviceMetadataRequest) GetUpdate() isUpdateDeviceMetadataRequest_Update
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
type UpdateDeviceMetadataRequest_Connection ¶ added in v2.6.0
type UpdateDeviceMetadataRequest_Connection struct {
Connection *Connection `protobuf:"bytes,3,opt,name=connection,proto3,oneof"`
}
type UpdateDeviceMetadataRequest_TwinEnabled ¶ added in v2.6.0
type UpdateDeviceMetadataRequest_TwinEnabled struct {
TwinEnabled bool `protobuf:"varint,8,opt,name=twin_enabled,json=twinEnabled,proto3,oneof"` // by default true
}
type UpdateDeviceMetadataRequest_TwinSynchronization ¶ added in v2.6.0
type UpdateDeviceMetadataRequest_TwinSynchronization struct {
TwinSynchronization *TwinSynchronization `protobuf:"bytes,7,opt,name=twin_synchronization,json=twinSynchronization,proto3,oneof"`
}
type UpdateDeviceMetadataResponse ¶
type UpdateDeviceMetadataResponse struct { ValidUntil int64 `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever. AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` TwinEnabled bool `protobuf:"varint,3,opt,name=twin_enabled,json=twinEnabled,proto3" json:"twin_enabled,omitempty"` // contains filtered or unexported fields }
func (*UpdateDeviceMetadataResponse) Descriptor
deprecated
func (*UpdateDeviceMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDeviceMetadataResponse.ProtoReflect.Descriptor instead.
func (*UpdateDeviceMetadataResponse) GetAuditContext ¶
func (x *UpdateDeviceMetadataResponse) GetAuditContext() *AuditContext
func (*UpdateDeviceMetadataResponse) GetTwinEnabled ¶ added in v2.6.1
func (x *UpdateDeviceMetadataResponse) GetTwinEnabled() bool
func (*UpdateDeviceMetadataResponse) GetValidUntil ¶
func (x *UpdateDeviceMetadataResponse) GetValidUntil() int64
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 *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Content *Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` ResourceInterface string `protobuf:"bytes,4,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"` TimeToLive int64 `protobuf:"varint,5,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). CommandMetadata *CommandMetadata `protobuf:"bytes,6,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"` // contains filtered or unexported fields }
func (*UpdateResourceRequest) Descriptor
deprecated
func (*UpdateResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceRequest.ProtoReflect.Descriptor instead.
func (*UpdateResourceRequest) GetCommandMetadata ¶
func (x *UpdateResourceRequest) GetCommandMetadata() *CommandMetadata
func (*UpdateResourceRequest) GetContent ¶
func (x *UpdateResourceRequest) GetContent() *Content
func (*UpdateResourceRequest) GetCorrelationId ¶
func (x *UpdateResourceRequest) GetCorrelationId() string
func (*UpdateResourceRequest) GetResourceId ¶
func (x *UpdateResourceRequest) GetResourceId() *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
type UpdateResourceResponse ¶
type UpdateResourceResponse struct { ValidUntil int64 `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever. AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func (*UpdateResourceResponse) Descriptor
deprecated
func (*UpdateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceResponse.ProtoReflect.Descriptor instead.
func (*UpdateResourceResponse) GetAuditContext ¶
func (x *UpdateResourceResponse) GetAuditContext() *AuditContext
func (*UpdateResourceResponse) GetValidUntil ¶
func (x *UpdateResourceResponse) GetValidUntil() int64
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