commands

package
v2.5.0 Latest Latest
Warning

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

Go to latest
Published: Sep 27, 2022 License: Apache-2.0 Imports: 16 Imported by: 3

Documentation

Index

Constants

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

Variables

View Source
var (
	ShadowSynchronization_name = map[int32]string{
		0: "UNSET",
		1: "ENABLED",
		2: "DISABLED",
	}
	ShadowSynchronization_value = map[string]int32{
		"UNSET":    0,
		"ENABLED":  1,
		"DISABLED": 2,
	}
)

Enum value maps for ShadowSynchronization.

View Source
var (
	ConnectionStatus_Status_name = map[int32]string{
		0: "OFFLINE",
		1: "ONLINE",
	}
	ConnectionStatus_Status_value = map[string]int32{
		"OFFLINE": 0,
		"ONLINE":  1,
	}
)

Enum value maps for ConnectionStatus_Status.

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",
	}
	Status_value = map[string]int32{
		"UNKNOWN":            0,
		"OK":                 1,
		"BAD_REQUEST":        2,
		"UNAUTHORIZED":       3,
		"FORBIDDEN":          4,
		"NOT_FOUND":          5,
		"UNAVAILABLE":        6,
		"NOT_IMPLEMENTED":    7,
		"ACCEPTED":           8,
		"ERROR":              9,
		"METHOD_NOT_ALLOWED": 10,
		"CREATED":            11,
		"CANCELED":           12,
	}
)

Enum value maps for Status.

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) string

func MakeStatusResourceUUID

func MakeStatusResourceUUID(deviceID string) string
func ResourcesToResourceLinks(resources []*Resource) []schema.ResourceLink

Types

type AuditContext

type AuditContext struct {
	UserId        string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// contains filtered or unexported fields
}

func NewAuditContext

func NewAuditContext(userID, correlationID string) *AuditContext

func (*AuditContext) Clone

func (c *AuditContext) Clone() *AuditContext

func (*AuditContext) Descriptor deprecated

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

Deprecated: Use AuditContext.ProtoReflect.Descriptor instead.

func (*AuditContext) GetCorrelationId

func (x *AuditContext) GetCorrelationId() string

func (*AuditContext) GetUserId

func (x *AuditContext) GetUserId() string

func (*AuditContext) ProtoMessage

func (*AuditContext) ProtoMessage()

func (*AuditContext) ProtoReflect

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

func (*AuditContext) Reset

func (x *AuditContext) Reset()

func (*AuditContext) String

func (x *AuditContext) String() string

type 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_ShadowSynchronization
	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) GetShadowSynchronization

func (x *ConfirmDeviceMetadataUpdateRequest) GetShadowSynchronization() ShadowSynchronization

func (*ConfirmDeviceMetadataUpdateRequest) GetStatus

func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage

func (*ConfirmDeviceMetadataUpdateRequest) ProtoMessage()

func (*ConfirmDeviceMetadataUpdateRequest) ProtoReflect

func (*ConfirmDeviceMetadataUpdateRequest) Reset

func (*ConfirmDeviceMetadataUpdateRequest) String

type ConfirmDeviceMetadataUpdateRequest_ShadowSynchronization

type ConfirmDeviceMetadataUpdateRequest_ShadowSynchronization struct {
	ShadowSynchronization ShadowSynchronization `` /* 139-byte string literal not displayed */
}

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"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceRetrieveRequest) Descriptor deprecated

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

Deprecated: Use ConfirmResourceRetrieveRequest.ProtoReflect.Descriptor instead.

func (*ConfirmResourceRetrieveRequest) GetCommandMetadata

func (x *ConfirmResourceRetrieveRequest) GetCommandMetadata() *CommandMetadata

func (*ConfirmResourceRetrieveRequest) GetContent

func (x *ConfirmResourceRetrieveRequest) GetContent() *Content

func (*ConfirmResourceRetrieveRequest) GetCorrelationId

func (x *ConfirmResourceRetrieveRequest) GetCorrelationId() string

func (*ConfirmResourceRetrieveRequest) GetResourceId

func (x *ConfirmResourceRetrieveRequest) GetResourceId() *ResourceId

func (*ConfirmResourceRetrieveRequest) GetStatus

func (x *ConfirmResourceRetrieveRequest) GetStatus() Status

func (*ConfirmResourceRetrieveRequest) ProtoMessage

func (*ConfirmResourceRetrieveRequest) ProtoMessage()

func (*ConfirmResourceRetrieveRequest) ProtoReflect

func (*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 ConnectionStatus

type ConnectionStatus struct {
	Value        ConnectionStatus_Status `protobuf:"varint,1,opt,name=value,proto3,enum=resourceaggregate.pb.ConnectionStatus_Status" json:"value,omitempty"`
	ValidUntil   int64                   `protobuf:"varint,2,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"`
	ConnectionId string                  `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_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.
	// contains filtered or unexported fields
}

func NewConnectionStatus

func NewConnectionStatus(value ConnectionStatus_Status, validUntil int64, connectionID string) *ConnectionStatus

func (*ConnectionStatus) Clone

func (c *ConnectionStatus) Clone() *ConnectionStatus

func (*ConnectionStatus) Descriptor deprecated

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

Deprecated: Use ConnectionStatus.ProtoReflect.Descriptor instead.

func (*ConnectionStatus) GetConnectionId added in v2.3.2

func (x *ConnectionStatus) GetConnectionId() string

func (*ConnectionStatus) GetValidUntil

func (x *ConnectionStatus) GetValidUntil() int64

func (*ConnectionStatus) GetValue

func (*ConnectionStatus) IsOnline

func (c *ConnectionStatus) IsOnline() bool

IsOnline evaluates online state

func (*ConnectionStatus) ProtoMessage

func (*ConnectionStatus) ProtoMessage()

func (*ConnectionStatus) ProtoReflect

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

func (*ConnectionStatus) Reset

func (x *ConnectionStatus) Reset()

func (*ConnectionStatus) String

func (x *ConnectionStatus) String() string

type ConnectionStatus_Status

type ConnectionStatus_Status int32
const (
	ConnectionStatus_OFFLINE ConnectionStatus_Status = 0
	ConnectionStatus_ONLINE  ConnectionStatus_Status = 1
)

func (ConnectionStatus_Status) Descriptor

func (ConnectionStatus_Status) Enum

func (ConnectionStatus_Status) EnumDescriptor deprecated

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

Deprecated: Use ConnectionStatus_Status.Descriptor instead.

func (ConnectionStatus_Status) Number

func (ConnectionStatus_Status) String

func (x ConnectionStatus_Status) String() string

func (ConnectionStatus_Status) Type

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"`
	// contains filtered or unexported fields
}

func (*DeleteResourceRequest) Descriptor deprecated

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

Deprecated: Use DeleteResourceRequest.ProtoReflect.Descriptor instead.

func (*DeleteResourceRequest) GetCommandMetadata

func (x *DeleteResourceRequest) GetCommandMetadata() *CommandMetadata

func (*DeleteResourceRequest) GetCorrelationId

func (x *DeleteResourceRequest) GetCorrelationId() string

func (*DeleteResourceRequest) GetResourceId

func (x *DeleteResourceRequest) GetResourceId() *ResourceId

func (*DeleteResourceRequest) GetTimeToLive

func (x *DeleteResourceRequest) GetTimeToLive() int64

func (*DeleteResourceRequest) ProtoMessage

func (*DeleteResourceRequest) ProtoMessage()

func (*DeleteResourceRequest) ProtoReflect

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

func (*DeleteResourceRequest) Reset

func (x *DeleteResourceRequest) Reset()

func (*DeleteResourceRequest) String

func (x *DeleteResourceRequest) String() string

type DeleteResourceResponse

type DeleteResourceResponse struct {
	ValidUntil   int64         `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever.
	AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResourceResponse) Descriptor deprecated

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

Deprecated: Use DeleteResourceResponse.ProtoReflect.Descriptor instead.

func (*DeleteResourceResponse) GetAuditContext

func (x *DeleteResourceResponse) GetAuditContext() *AuditContext

func (*DeleteResourceResponse) GetValidUntil

func (x *DeleteResourceResponse) GetValidUntil() int64

func (*DeleteResourceResponse) ProtoMessage

func (*DeleteResourceResponse) ProtoMessage()

func (*DeleteResourceResponse) ProtoReflect

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

func (*DeleteResourceResponse) Reset

func (x *DeleteResourceResponse) Reset()

func (*DeleteResourceResponse) String

func (x *DeleteResourceResponse) String() string

type EndpointInformation

type EndpointInformation struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Priority int64  `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func SchemaEndpointsToRAEndpointInformations

func SchemaEndpointsToRAEndpointInformations(ra []schema.Endpoint) []*EndpointInformation

func (*EndpointInformation) Clone

func (*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"`
	// contains filtered or unexported fields
}

func (*NotifyResourceChangedRequest) Descriptor deprecated

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

Deprecated: Use NotifyResourceChangedRequest.ProtoReflect.Descriptor instead.

func (*NotifyResourceChangedRequest) GetCommandMetadata

func (x *NotifyResourceChangedRequest) GetCommandMetadata() *CommandMetadata

func (*NotifyResourceChangedRequest) GetContent

func (x *NotifyResourceChangedRequest) GetContent() *Content

func (*NotifyResourceChangedRequest) GetResourceId

func (x *NotifyResourceChangedRequest) GetResourceId() *ResourceId

func (*NotifyResourceChangedRequest) GetStatus

func (x *NotifyResourceChangedRequest) GetStatus() Status

func (*NotifyResourceChangedRequest) ProtoMessage

func (*NotifyResourceChangedRequest) ProtoMessage()

func (*NotifyResourceChangedRequest) ProtoReflect

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

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) 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() string

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"`
	// contains filtered or unexported fields
}

func (*RetrieveResourceRequest) Descriptor deprecated

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

Deprecated: Use RetrieveResourceRequest.ProtoReflect.Descriptor instead.

func (*RetrieveResourceRequest) GetCommandMetadata

func (x *RetrieveResourceRequest) GetCommandMetadata() *CommandMetadata

func (*RetrieveResourceRequest) GetCorrelationId

func (x *RetrieveResourceRequest) GetCorrelationId() string

func (*RetrieveResourceRequest) GetResourceId

func (x *RetrieveResourceRequest) GetResourceId() *ResourceId

func (*RetrieveResourceRequest) GetResourceInterface

func (x *RetrieveResourceRequest) GetResourceInterface() string

func (*RetrieveResourceRequest) GetTimeToLive

func (x *RetrieveResourceRequest) GetTimeToLive() int64

func (*RetrieveResourceRequest) ProtoMessage

func (*RetrieveResourceRequest) ProtoMessage()

func (*RetrieveResourceRequest) ProtoReflect

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

func (*RetrieveResourceRequest) Reset

func (x *RetrieveResourceRequest) Reset()

func (*RetrieveResourceRequest) String

func (x *RetrieveResourceRequest) String() string

type RetrieveResourceResponse

type RetrieveResourceResponse struct {
	ValidUntil   int64         `protobuf:"varint,1,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when command is considered as expired. 0 means forever.
	AuditContext *AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrieveResourceResponse) Descriptor deprecated

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

Deprecated: Use RetrieveResourceResponse.ProtoReflect.Descriptor instead.

func (*RetrieveResourceResponse) GetAuditContext

func (x *RetrieveResourceResponse) GetAuditContext() *AuditContext

func (*RetrieveResourceResponse) GetValidUntil

func (x *RetrieveResourceResponse) GetValidUntil() int64

func (*RetrieveResourceResponse) ProtoMessage

func (*RetrieveResourceResponse) ProtoMessage()

func (*RetrieveResourceResponse) ProtoReflect

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

func (*RetrieveResourceResponse) Reset

func (x *RetrieveResourceResponse) Reset()

func (*RetrieveResourceResponse) String

func (x *RetrieveResourceResponse) String() string

type ShadowSynchronization

type ShadowSynchronization int32
const (
	ShadowSynchronization_UNSET    ShadowSynchronization = 0
	ShadowSynchronization_ENABLED  ShadowSynchronization = 1
	ShadowSynchronization_DISABLED ShadowSynchronization = 2
)

func (ShadowSynchronization) Descriptor

func (ShadowSynchronization) Enum

func (ShadowSynchronization) EnumDescriptor deprecated

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

Deprecated: Use ShadowSynchronization.Descriptor instead.

func (ShadowSynchronization) Number

func (ShadowSynchronization) String

func (x ShadowSynchronization) String() string

func (ShadowSynchronization) Type

type Status

type Status int32
const (
	Status_UNKNOWN            Status = 0
	Status_OK                 Status = 1
	Status_BAD_REQUEST        Status = 2
	Status_UNAUTHORIZED       Status = 3
	Status_FORBIDDEN          Status = 4
	Status_NOT_FOUND          Status = 5
	Status_UNAVAILABLE        Status = 6
	Status_NOT_IMPLEMENTED    Status = 7
	Status_ACCEPTED           Status = 8
	Status_ERROR              Status = 9
	Status_METHOD_NOT_ALLOWED Status = 10
	Status_CREATED            Status = 11
	Status_CANCELED           Status = 12 // Canceled indicates the operation was canceled (typically by the user).
)

func HTTPStatus2Status

func 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 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_Status
	//	*UpdateDeviceMetadataRequest_ShadowSynchronization
	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) GetCorrelationId

func (x *UpdateDeviceMetadataRequest) GetCorrelationId() string

func (*UpdateDeviceMetadataRequest) GetDeviceId

func (x *UpdateDeviceMetadataRequest) GetDeviceId() string

func (*UpdateDeviceMetadataRequest) GetShadowSynchronization

func (x *UpdateDeviceMetadataRequest) GetShadowSynchronization() ShadowSynchronization

func (*UpdateDeviceMetadataRequest) GetStatus

func (*UpdateDeviceMetadataRequest) GetTimeToLive

func (x *UpdateDeviceMetadataRequest) GetTimeToLive() int64

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_ShadowSynchronization

type UpdateDeviceMetadataRequest_ShadowSynchronization struct {
	ShadowSynchronization ShadowSynchronization `` /* 139-byte string literal not displayed */
}

type UpdateDeviceMetadataRequest_Status

type UpdateDeviceMetadataRequest_Status struct {
	Status *ConnectionStatus `protobuf:"bytes,3,opt,name=status,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"`
	// 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) 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

Jump to

Keyboard shortcuts

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