commands

package
v2.23.0 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2024 License: Apache-2.0 Imports: 20 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 DecodeContent added in v2.21.0 

func DecodeContent(content *Content, v interface{}) error

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 (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
	//	*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 (x *ConfirmDeviceMetadataUpdateRequest) GetStatus() Status

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 (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"` // 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 (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"`
	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 (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"`
	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) 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) Clone added in v2.21.0 

func (c *Content) Clone() *Content

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"`
	Force           bool             `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"` // if true, the command will be executed even if the resource does not exist
	// 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) GetForce added in v2.21.0 

func (x *CreateResourceRequest) GetForce() bool

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"`
	Force             bool             `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"` // if true, the command will be executed even if the resource does not exist
	// 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) GetForce added in v2.21.0 

func (x *DeleteResourceRequest) GetForce() bool

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 (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"`
	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 (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 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 (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
}

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) Clone added in v2.21.0 

func (r *ResourceId) Clone() *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 (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
	//	*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 (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_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 (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"`
	Force             bool             `protobuf:"varint,7,opt,name=force,proto3" json:"force,omitempty"` // if true, the command will be executed even if the resource does not exist
	// 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) GetForce added in v2.21.0 

func (x *UpdateResourceRequest) GetForce() bool

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 (x *UpdateServiceMetadataRequest) GetHeartbeat() *ServiceHeartbeat

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

func (*UpdateServiceMetadataRequest) Reset added in v2.12.0 

func (x *UpdateServiceMetadataRequest) Reset()

func (*UpdateServiceMetadataRequest) String added in v2.12.0 

func (x *UpdateServiceMetadataRequest) String() string

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

func (*UpdateServiceMetadataResponse) Reset added in v2.12.0 

func (x *UpdateServiceMetadataResponse) Reset()

func (*UpdateServiceMetadataResponse) String added in v2.12.0 

func (x *UpdateServiceMetadataResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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