commands

package
v2.18.0 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2024 License: Apache-2.0 Imports: 16 Imported by: 3

Documentation

Index

Constants

View Source
const (
	ResourceLinksHref    string = "/plgd/res"
	StatusHref           string = "/plgd/s"
	ServicesResourceHref string = "/plgd/services"
)

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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",
		13: "NOT_MODIFIED",
	}
	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,
		"NOT_MODIFIED":       13,
	}
)

Enum value maps for Status.

View Source
var File_resource_aggregate_pb_commands_proto protoreflect.FileDescriptor
View Source
var File_resource_aggregate_pb_resources_proto protoreflect.FileDescriptor

Functions

func CheckEventContent

func CheckEventContent(ec EventContent) error

func CloneResourcesMap

func CloneResourcesMap(resources map[string]*Resource) map[string]*Resource

func MakeLinksResourceUUID

func MakeLinksResourceUUID(deviceID string) uuid.UUID

func MakeServicesResourceUUID added in v2.12.0

func MakeServicesResourceUUID(hubID string) uuid.UUID

func MakeStatusResourceUUID

func MakeStatusResourceUUID(deviceID string) uuid.UUID
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"`
	Owner         string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func NewAuditContext

func NewAuditContext(userID, correlationID, owner 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) GetOwner added in v2.12.0

func (x *AuditContext) GetOwner() 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 (*BatchNotifyResourceChangedRequest) ProtoMessage added in v2.6.0

func (*BatchNotifyResourceChangedRequest) ProtoMessage()

func (*BatchNotifyResourceChangedRequest) ProtoReflect added in v2.6.0

func (*BatchNotifyResourceChangedRequest) Reset added in v2.6.0

func (*BatchNotifyResourceChangedRequest) String added in v2.6.0

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 (*BatchNotifyResourceChangedResponse) Reset added in v2.6.0

func (*BatchNotifyResourceChangedResponse) String added in v2.6.0

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 (*CancelPendingCommandsRequest) Reset

func (x *CancelPendingCommandsRequest) Reset()

func (*CancelPendingCommandsRequest) 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 (*CancelPendingCommandsResponse) Reset

func (x *CancelPendingCommandsResponse) Reset()

func (*CancelPendingCommandsResponse) 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 (*CancelPendingMetadataUpdatesRequest) ProtoMessage

func (*CancelPendingMetadataUpdatesRequest) ProtoMessage()

func (*CancelPendingMetadataUpdatesRequest) ProtoReflect

func (*CancelPendingMetadataUpdatesRequest) Reset

func (*CancelPendingMetadataUpdatesRequest) 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 (*CancelPendingMetadataUpdatesResponse) Reset

func (*CancelPendingMetadataUpdatesResponse) 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
	//	*ConfirmDeviceMetadataUpdateRequest_TwinForceSynchronization
	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 (*ConfirmDeviceMetadataUpdateRequest) GetTwinEnabled added in v2.6.0

func (x *ConfirmDeviceMetadataUpdateRequest) GetTwinEnabled() bool

func (*ConfirmDeviceMetadataUpdateRequest) GetTwinForceSynchronization added in v2.10.0

func (x *ConfirmDeviceMetadataUpdateRequest) GetTwinForceSynchronization() bool

func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage

func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage()

func (*ConfirmDeviceMetadataUpdateRequest) ProtoReflect

func (*ConfirmDeviceMetadataUpdateRequest) Reset

func (*ConfirmDeviceMetadataUpdateRequest) 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"` // will set twin_enabled to true and TwinSynchronization.state to OUT_OF_SYNC.
}

type ConfirmDeviceMetadataUpdateRequest_TwinForceSynchronization added in v2.10.0

type ConfirmDeviceMetadataUpdateRequest_TwinForceSynchronization struct {
	TwinForceSynchronization bool `protobuf:"varint,7,opt,name=twin_force_synchronization,json=twinForceSynchronization,proto3,oneof"` // will set twin_enabled to true, set time TwinSynchronization.force_synchronization_at and TwinSynchronization.state to OUT_OF_SYNC.
}

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 (*ConfirmDeviceMetadataUpdateResponse) Reset

func (*ConfirmDeviceMetadataUpdateResponse) 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 (*ConfirmResourceCreateRequest) Reset

func (x *ConfirmResourceCreateRequest) Reset()

func (*ConfirmResourceCreateRequest) 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 (*ConfirmResourceCreateResponse) Reset

func (x *ConfirmResourceCreateResponse) Reset()

func (*ConfirmResourceCreateResponse) 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 (*ConfirmResourceDeleteRequest) Reset

func (x *ConfirmResourceDeleteRequest) Reset()

func (*ConfirmResourceDeleteRequest) 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 (*ConfirmResourceDeleteResponse) Reset

func (x *ConfirmResourceDeleteResponse) Reset()

func (*ConfirmResourceDeleteResponse) 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"`
	Etag            []byte           `protobuf:"bytes,6,opt,name=etag,proto3" json:"etag,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) GetEtag added in v2.10.0

func (x *ConfirmResourceRetrieveRequest) GetEtag() []byte

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 (*ConfirmResourceRetrieveRequest) Reset

func (x *ConfirmResourceRetrieveRequest) Reset()

func (*ConfirmResourceRetrieveRequest) 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 (*ConfirmResourceRetrieveResponse) Reset

func (*ConfirmResourceRetrieveResponse) 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 (*ConfirmResourceUpdateRequest) Reset

func (x *ConfirmResourceUpdateRequest) Reset()

func (*ConfirmResourceUpdateRequest) 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 (*ConfirmResourceUpdateResponse) Reset

func (x *ConfirmResourceUpdateResponse) Reset()

func (*ConfirmResourceUpdateResponse) 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"`
	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.
	ServiceId      string              `protobuf:"bytes,6,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`                             // The service.ID, which identify the device being served, must be set when the status is ONLINE. However, during an OFFLINE event, they will be sed to empty values.
	LocalEndpoints []string            `protobuf:"bytes,7,rep,name=local_endpoints,json=localEndpoints,proto3" json:"local_endpoints,omitempty"`              // The last local endpoints of the device, and it is set when the status is ONLINE.
	// contains filtered or unexported fields
}

func NewConnection added in v2.6.0

func NewConnection(status Connection_Status, 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) GetLocalEndpoints added in v2.17.0

func (x *Connection) GetLocalEndpoints() []string

func (*Connection) GetProtocol added in v2.7.0

func (x *Connection) GetProtocol() Connection_Protocol

func (*Connection) GetServiceId added in v2.12.0

func (x *Connection) GetServiceId() string

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) Enum added in v2.7.0

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 (Connection_Protocol) String added in v2.7.0

func (x Connection_Protocol) String() string

func (Connection_Protocol) Type added in v2.7.0

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) Enum added in v2.6.0

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 (Connection_Status) String added in v2.6.0

func (x Connection_Status) String() string

func (Connection_Status) Type added in v2.6.0

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) Descriptor() ([]byte, []int)

Deprecated: Use Content.ProtoReflect.Descriptor instead.

func (*Content) GetCoapContentFormat

func (x *Content) GetCoapContentFormat() int32

func (*Content) GetContentType

func (x *Content) GetContentType() string

func (*Content) GetData

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

func (*Content) ProtoMessage

func (*Content) ProtoMessage()

func (*Content) ProtoReflect

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

func (*Content) Reset

func (x *Content) Reset()

func (*Content) String

func (x *Content) String() string

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"`
	ResourceInterface string           `protobuf:"bytes,5,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,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) GetResourceInterface added in v2.13.1

func (x *DeleteResourceRequest) GetResourceInterface() string

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 (*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 (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"`
	Etag            []byte           `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	ResourceTypes   []string         `protobuf:"bytes,6,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,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) GetEtag added in v2.10.0

func (x *NotifyResourceChangedRequest) GetEtag() []byte

func (*NotifyResourceChangedRequest) GetResourceId

func (x *NotifyResourceChangedRequest) GetResourceId() *ResourceId

func (*NotifyResourceChangedRequest) GetResourceTypes added in v2.18.0

func (x *NotifyResourceChangedRequest) GetResourceTypes() []string

func (*NotifyResourceChangedRequest) GetStatus

func (x *NotifyResourceChangedRequest) GetStatus() Status

func (*NotifyResourceChangedRequest) ProtoMessage

func (*NotifyResourceChangedRequest) ProtoMessage()

func (*NotifyResourceChangedRequest) ProtoReflect

func (*NotifyResourceChangedRequest) Reset

func (x *NotifyResourceChangedRequest) Reset()

func (*NotifyResourceChangedRequest) 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 (*NotifyResourceChangedResponse) Reset

func (x *NotifyResourceChangedResponse) Reset()

func (*NotifyResourceChangedResponse) 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 SchemaPolicyToRAPolicy(ra *schema.Policy) *Policy

func (*Policy) Descriptor deprecated

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

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetBitFlags

func (x *Policy) GetBitFlags() int32

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect

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

func (*Policy) Reset

func (x *Policy) Reset()

func (*Policy) String

func (x *Policy) String() string

func (*Policy) ToSchema

func (p *Policy) ToSchema() *schema.Policy

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
}

https://github.com/openconnectivityfoundation/cloud-services/blob/master/swagger2.0/oic.wk.rd.swagger.json#L35

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 (*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 (*PublishResourceLinksResponse) Reset

func (x *PublishResourceLinksResponse) Reset()

func (*PublishResourceLinksResponse) 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
}

https://github.com/openconnectivityfoundation/core/blob/master/schemas/oic.links.properties.core-schema.json

func SchemaResourceLinkToResource

func SchemaResourceLinkToResource(link schema.ResourceLink, validUntil time.Time) *Resource

func SchemaResourceLinksToResources

func SchemaResourceLinksToResources(links schema.ResourceLinks, validUntil time.Time) []*Resource

func (*Resource) Clone

func (r *Resource) Clone() *Resource

func (*Resource) Descriptor deprecated

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetAnchor

func (x *Resource) GetAnchor() string

func (*Resource) GetDeviceId

func (x *Resource) GetDeviceId() string

func (*Resource) GetEndpointInformations

func (x *Resource) GetEndpointInformations() []*EndpointInformation

func (*Resource) GetHref

func (x *Resource) GetHref() string

func (*Resource) GetInterfaces

func (x *Resource) GetInterfaces() []string

func (*Resource) GetPolicy

func (x *Resource) GetPolicy() *Policy

func (*Resource) GetResourceID

func (r *Resource) GetResourceID() *ResourceId

GetResourceID converts resource href and device id to resource id struct

func (*Resource) GetResourceTypes

func (x *Resource) GetResourceTypes() []string

func (*Resource) GetSupportedContentTypes

func (x *Resource) GetSupportedContentTypes() []string

func (*Resource) GetTitle

func (x *Resource) GetTitle() string

func (*Resource) GetValidUntil

func (x *Resource) GetValidUntil() int64

func (*Resource) IsObservable

func (r *Resource) IsObservable() bool

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

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

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

func (*Resource) ToSchema

func (r *Resource) ToSchema() schema.ResourceLink

func (*Resource) ToUUID

func (r *Resource) ToUUID() uuid.UUID

ToUUID converts resource href and device id to unique resource ID

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) Equal added in v2.13.0

func (r *ResourceId) Equal(r1 *ResourceId) bool

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 Resources added in v2.4.1

type Resources []*Resource

func (Resources) Len added in v2.4.1

func (r Resources) Len() int

func (Resources) Less added in v2.4.1

func (r Resources) Less(i, j int) bool

func (Resources) Sort added in v2.4.1

func (r Resources) Sort()

func (Resources) Swap added in v2.4.1

func (r Resources) Swap(i, j int)

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"`
	Etag              [][]byte         `protobuf:"bytes,6,rep,name=etag,proto3" json:"etag,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) GetEtag added in v2.10.0

func (x *RetrieveResourceRequest) GetEtag() [][]byte

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 ServiceHeartbeat added in v2.12.0

type ServiceHeartbeat struct {
	ServiceId  string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`       // generated unique id during start the service
	TimeToLive int64  `protobuf:"varint,2,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // validity in nanoseconds. minimal value is 1000000000 (1s).
	Timestamp  int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                       // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano)
	Register   bool   `protobuf:"varint,4,opt,name=register,proto3" json:"register,omitempty"`                         // Set to true to attempt service registration; it will fail if the service is already registered. Set to false to attempt service update; it will fail if the service is not registered.
	// contains filtered or unexported fields
}

func (*ServiceHeartbeat) Descriptor deprecated added in v2.12.0

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

Deprecated: Use ServiceHeartbeat.ProtoReflect.Descriptor instead.

func (*ServiceHeartbeat) GetRegister added in v2.12.0

func (x *ServiceHeartbeat) GetRegister() bool

func (*ServiceHeartbeat) GetServiceId added in v2.12.0

func (x *ServiceHeartbeat) GetServiceId() string

func (*ServiceHeartbeat) GetTimeToLive added in v2.12.0

func (x *ServiceHeartbeat) GetTimeToLive() int64

func (*ServiceHeartbeat) GetTimestamp added in v2.12.0

func (x *ServiceHeartbeat) GetTimestamp() int64

func (*ServiceHeartbeat) ProtoMessage added in v2.12.0

func (*ServiceHeartbeat) ProtoMessage()

func (*ServiceHeartbeat) ProtoReflect added in v2.12.0

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

func (*ServiceHeartbeat) Reset added in v2.12.0

func (x *ServiceHeartbeat) Reset()

func (*ServiceHeartbeat) String added in v2.12.0

func (x *ServiceHeartbeat) 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).
	Status_NOT_MODIFIED       Status = 13 // Valid indicates the content hasn't changed. (provided etag in GET request is same as the resource etag).
)

func HTTPStatus2Status

func HTTPStatus2Status(s int) Status

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

func (Status) ToGrpcCode

func (s Status) ToGrpcCode() codes.Code

func (Status) ToHTTPCode

func (s Status) ToHTTPCode() int

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.
	ForceSynchronizationAt int64                     ``                                                                                                           // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when the force synchronization has been started. 0 means force synchronization has never started.
	/* 130-byte string literal not displayed */
	// 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) GetForceSynchronizationAt added in v2.10.0

func (x *TwinSynchronization) GetForceSynchronizationAt() int64

func (*TwinSynchronization) GetInSyncAt added in v2.6.0

func (x *TwinSynchronization) GetInSyncAt() int64

func (*TwinSynchronization) GetState added in v2.6.0

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) Enum added in v2.6.0

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 (TwinSynchronization_State) String added in v2.6.0

func (x TwinSynchronization_State) String() string

func (TwinSynchronization_State) Type added in v2.6.0

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 (*UnpublishResourceLinksRequest) Reset

func (x *UnpublishResourceLinksRequest) Reset()

func (*UnpublishResourceLinksRequest) 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 (*UnpublishResourceLinksResponse) Reset

func (x *UnpublishResourceLinksResponse) Reset()

func (*UnpublishResourceLinksResponse) 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
	//	*UpdateDeviceMetadataRequest_TwinForceSynchronization
	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) GetTwinForceSynchronization added in v2.10.0

func (x *UpdateDeviceMetadataRequest) GetTwinForceSynchronization() 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 (*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_TwinForceSynchronization added in v2.10.0

type UpdateDeviceMetadataRequest_TwinForceSynchronization struct {
	TwinForceSynchronization bool `protobuf:"varint,9,opt,name=twin_force_synchronization,json=twinForceSynchronization,proto3,oneof"` // Force synchronization IoT hub with the device resources and set twin_enabled to true. Use to address potential synchronization issues and prevent operational discrepancies.
}

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 (*UpdateDeviceMetadataResponse) Reset

func (x *UpdateDeviceMetadataResponse) Reset()

func (*UpdateDeviceMetadataResponse) 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

type UpdateServiceMetadataRequest added in v2.12.0

type UpdateServiceMetadataRequest struct {

	// Types that are assignable to Update:
	//
	//	*UpdateServiceMetadataRequest_Heartbeat
	Update isUpdateServiceMetadataRequest_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

func (*UpdateServiceMetadataRequest) Descriptor deprecated added in v2.12.0

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

Deprecated: Use UpdateServiceMetadataRequest.ProtoReflect.Descriptor instead.

func (*UpdateServiceMetadataRequest) GetHeartbeat added in v2.12.0

func (*UpdateServiceMetadataRequest) GetUpdate added in v2.12.0

func (m *UpdateServiceMetadataRequest) GetUpdate() isUpdateServiceMetadataRequest_Update

func (*UpdateServiceMetadataRequest) ProtoMessage added in v2.12.0

func (*UpdateServiceMetadataRequest) ProtoMessage()

func (*UpdateServiceMetadataRequest) ProtoReflect added in v2.12.0

func (*UpdateServiceMetadataRequest) Reset added in v2.12.0

func (x *UpdateServiceMetadataRequest) Reset()

func (*UpdateServiceMetadataRequest) String added in v2.12.0

type UpdateServiceMetadataRequest_Heartbeat added in v2.12.0

type UpdateServiceMetadataRequest_Heartbeat struct {
	// Include or modify services within the valid services heartbeat list and transfer expired services from the valid list to the expired list.
	Heartbeat *ServiceHeartbeat `protobuf:"bytes,1,opt,name=heartbeat,proto3,oneof"`
}

type UpdateServiceMetadataResponse added in v2.12.0

type UpdateServiceMetadataResponse struct {
	HeartbeatValidUntil int64 `protobuf:"varint,1,opt,name=heartbeat_valid_until,json=heartbeatValidUntil,proto3" json:"heartbeat_valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when service is considered as expired. 0 means forever.
	// contains filtered or unexported fields
}

func (*UpdateServiceMetadataResponse) Descriptor deprecated added in v2.12.0

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

Deprecated: Use UpdateServiceMetadataResponse.ProtoReflect.Descriptor instead.

func (*UpdateServiceMetadataResponse) GetHeartbeatValidUntil added in v2.12.0

func (x *UpdateServiceMetadataResponse) GetHeartbeatValidUntil() int64

func (*UpdateServiceMetadataResponse) ProtoMessage added in v2.12.0

func (*UpdateServiceMetadataResponse) ProtoMessage()

func (*UpdateServiceMetadataResponse) ProtoReflect added in v2.12.0

func (*UpdateServiceMetadataResponse) Reset added in v2.12.0

func (x *UpdateServiceMetadataResponse) Reset()

func (*UpdateServiceMetadataResponse) String added in v2.12.0

Jump to

Keyboard shortcuts

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