commands

package
v2.4.4 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const ResourceLinksHref string = "/plgd/res"
View Source 
const 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 (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_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 (x *ConfirmDeviceMetadataUpdateRequest) GetStatus() Status

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

func (*ConfirmDeviceMetadataUpdateResponse) Reset 

func (x *ConfirmDeviceMetadataUpdateResponse) Reset()

func (*ConfirmDeviceMetadataUpdateResponse) String 

func (x *ConfirmDeviceMetadataUpdateResponse) String() string

type ConfirmResourceCreateRequest 

type ConfirmResourceCreateRequest struct {
	ResourceId      *ResourceId      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CorrelationId   string           `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Status          Status           `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"`
	Content         *Content         `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceCreateRequest) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceCreateRequest.ProtoReflect.Descriptor instead.

func (*ConfirmResourceCreateRequest) GetCommandMetadata 

func (x *ConfirmResourceCreateRequest) GetCommandMetadata() *CommandMetadata

func (*ConfirmResourceCreateRequest) GetContent 

func (x *ConfirmResourceCreateRequest) GetContent() *Content

func (*ConfirmResourceCreateRequest) GetCorrelationId 

func (x *ConfirmResourceCreateRequest) GetCorrelationId() string

func (*ConfirmResourceCreateRequest) GetResourceId 

func (x *ConfirmResourceCreateRequest) GetResourceId() *ResourceId

func (*ConfirmResourceCreateRequest) GetStatus 

func (x *ConfirmResourceCreateRequest) GetStatus() Status

func (*ConfirmResourceCreateRequest) ProtoMessage 

func (*ConfirmResourceCreateRequest) ProtoMessage()

func (*ConfirmResourceCreateRequest) ProtoReflect 

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

func (*ConfirmResourceCreateRequest) Reset 

func (x *ConfirmResourceCreateRequest) Reset()

func (*ConfirmResourceCreateRequest) String 

func (x *ConfirmResourceCreateRequest) String() string

type ConfirmResourceCreateResponse 

type ConfirmResourceCreateResponse struct {
	AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceCreateResponse) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceCreateResponse.ProtoReflect.Descriptor instead.

func (*ConfirmResourceCreateResponse) GetAuditContext 

func (x *ConfirmResourceCreateResponse) GetAuditContext() *AuditContext

func (*ConfirmResourceCreateResponse) ProtoMessage 

func (*ConfirmResourceCreateResponse) ProtoMessage()

func (*ConfirmResourceCreateResponse) ProtoReflect 

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

func (*ConfirmResourceCreateResponse) Reset 

func (x *ConfirmResourceCreateResponse) Reset()

func (*ConfirmResourceCreateResponse) String 

func (x *ConfirmResourceCreateResponse) String() string

type ConfirmResourceDeleteRequest 

type ConfirmResourceDeleteRequest struct {
	ResourceId      *ResourceId      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CorrelationId   string           `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Status          Status           `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"`
	Content         *Content         `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceDeleteRequest.ProtoReflect.Descriptor instead.

func (*ConfirmResourceDeleteRequest) GetCommandMetadata 

func (x *ConfirmResourceDeleteRequest) GetCommandMetadata() *CommandMetadata

func (*ConfirmResourceDeleteRequest) GetContent 

func (x *ConfirmResourceDeleteRequest) GetContent() *Content

func (*ConfirmResourceDeleteRequest) GetCorrelationId 

func (x *ConfirmResourceDeleteRequest) GetCorrelationId() string

func (*ConfirmResourceDeleteRequest) GetResourceId 

func (x *ConfirmResourceDeleteRequest) GetResourceId() *ResourceId

func (*ConfirmResourceDeleteRequest) GetStatus 

func (x *ConfirmResourceDeleteRequest) GetStatus() Status

func (*ConfirmResourceDeleteRequest) ProtoMessage 

func (*ConfirmResourceDeleteRequest) ProtoMessage()

func (*ConfirmResourceDeleteRequest) ProtoReflect 

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

func (*ConfirmResourceDeleteRequest) Reset 

func (x *ConfirmResourceDeleteRequest) Reset()

func (*ConfirmResourceDeleteRequest) String 

func (x *ConfirmResourceDeleteRequest) String() string

type ConfirmResourceDeleteResponse 

type ConfirmResourceDeleteResponse struct {
	AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceDeleteResponse.ProtoReflect.Descriptor instead.

func (*ConfirmResourceDeleteResponse) GetAuditContext 

func (x *ConfirmResourceDeleteResponse) GetAuditContext() *AuditContext

func (*ConfirmResourceDeleteResponse) ProtoMessage 

func (*ConfirmResourceDeleteResponse) ProtoMessage()

func (*ConfirmResourceDeleteResponse) ProtoReflect 

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

func (*ConfirmResourceDeleteResponse) Reset 

func (x *ConfirmResourceDeleteResponse) Reset()

func (*ConfirmResourceDeleteResponse) String 

func (x *ConfirmResourceDeleteResponse) String() string

type ConfirmResourceRetrieveRequest 

type ConfirmResourceRetrieveRequest struct {
	ResourceId      *ResourceId      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CorrelationId   string           `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Status          Status           `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"`
	Content         *Content         `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceRetrieveRequest) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceRetrieveRequest.ProtoReflect.Descriptor instead.

func (*ConfirmResourceRetrieveRequest) GetCommandMetadata 

func (x *ConfirmResourceRetrieveRequest) GetCommandMetadata() *CommandMetadata

func (*ConfirmResourceRetrieveRequest) GetContent 

func (x *ConfirmResourceRetrieveRequest) GetContent() *Content

func (*ConfirmResourceRetrieveRequest) GetCorrelationId 

func (x *ConfirmResourceRetrieveRequest) GetCorrelationId() string

func (*ConfirmResourceRetrieveRequest) GetResourceId 

func (x *ConfirmResourceRetrieveRequest) GetResourceId() *ResourceId

func (*ConfirmResourceRetrieveRequest) GetStatus 

func (x *ConfirmResourceRetrieveRequest) GetStatus() Status

func (*ConfirmResourceRetrieveRequest) ProtoMessage 

func (*ConfirmResourceRetrieveRequest) ProtoMessage()

func (*ConfirmResourceRetrieveRequest) ProtoReflect 

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

func (*ConfirmResourceRetrieveRequest) Reset 

func (x *ConfirmResourceRetrieveRequest) Reset()

func (*ConfirmResourceRetrieveRequest) String 

func (x *ConfirmResourceRetrieveRequest) String() string

type ConfirmResourceRetrieveResponse 

type ConfirmResourceRetrieveResponse struct {
	AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceRetrieveResponse) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceRetrieveResponse.ProtoReflect.Descriptor instead.

func (*ConfirmResourceRetrieveResponse) GetAuditContext 

func (x *ConfirmResourceRetrieveResponse) GetAuditContext() *AuditContext

func (*ConfirmResourceRetrieveResponse) ProtoMessage 

func (*ConfirmResourceRetrieveResponse) ProtoMessage()

func (*ConfirmResourceRetrieveResponse) ProtoReflect 

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

func (*ConfirmResourceRetrieveResponse) Reset 

func (x *ConfirmResourceRetrieveResponse) Reset()

func (*ConfirmResourceRetrieveResponse) String 

func (x *ConfirmResourceRetrieveResponse) String() string

type ConfirmResourceUpdateRequest 

type ConfirmResourceUpdateRequest struct {
	ResourceId      *ResourceId      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CorrelationId   string           `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Status          Status           `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"`
	Content         *Content         `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	CommandMetadata *CommandMetadata `protobuf:"bytes,5,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceUpdateRequest.ProtoReflect.Descriptor instead.

func (*ConfirmResourceUpdateRequest) GetCommandMetadata 

func (x *ConfirmResourceUpdateRequest) GetCommandMetadata() *CommandMetadata

func (*ConfirmResourceUpdateRequest) GetContent 

func (x *ConfirmResourceUpdateRequest) GetContent() *Content

func (*ConfirmResourceUpdateRequest) GetCorrelationId 

func (x *ConfirmResourceUpdateRequest) GetCorrelationId() string

func (*ConfirmResourceUpdateRequest) GetResourceId 

func (x *ConfirmResourceUpdateRequest) GetResourceId() *ResourceId

func (*ConfirmResourceUpdateRequest) GetStatus 

func (x *ConfirmResourceUpdateRequest) GetStatus() Status

func (*ConfirmResourceUpdateRequest) ProtoMessage 

func (*ConfirmResourceUpdateRequest) ProtoMessage()

func (*ConfirmResourceUpdateRequest) ProtoReflect 

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

func (*ConfirmResourceUpdateRequest) Reset 

func (x *ConfirmResourceUpdateRequest) Reset()

func (*ConfirmResourceUpdateRequest) String 

func (x *ConfirmResourceUpdateRequest) String() string

type ConfirmResourceUpdateResponse 

type ConfirmResourceUpdateResponse struct {
	AuditContext *AuditContext `protobuf:"bytes,1,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmResourceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use ConfirmResourceUpdateResponse.ProtoReflect.Descriptor instead.

func (*ConfirmResourceUpdateResponse) GetAuditContext 

func (x *ConfirmResourceUpdateResponse) GetAuditContext() *AuditContext

func (*ConfirmResourceUpdateResponse) ProtoMessage 

func (*ConfirmResourceUpdateResponse) ProtoMessage()

func (*ConfirmResourceUpdateResponse) ProtoReflect 

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

func (*ConfirmResourceUpdateResponse) Reset 

func (x *ConfirmResourceUpdateResponse) Reset()

func (*ConfirmResourceUpdateResponse) String 

func (x *ConfirmResourceUpdateResponse) String() string

type 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 (x *ConnectionStatus) GetValue() ConnectionStatus_Status

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) Descriptor() protoreflect.EnumDescriptor

func (ConnectionStatus_Status) Enum 

func (x ConnectionStatus_Status) Enum() *ConnectionStatus_Status

func (ConnectionStatus_Status) EnumDescriptor deprecated 

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

Deprecated: Use ConnectionStatus_Status.Descriptor instead.

func (ConnectionStatus_Status) Number 

func (x ConnectionStatus_Status) Number() protoreflect.EnumNumber

func (ConnectionStatus_Status) String 

func (x ConnectionStatus_Status) String() string

func (ConnectionStatus_Status) Type 

func (ConnectionStatus_Status) Type() protoreflect.EnumType

type Content 

type Content struct {
	Data              []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	ContentType       string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	CoapContentFormat int32  `protobuf:"varint,3,opt,name=coap_content_format,json=coapContentFormat,proto3" json:"coap_content_format,omitempty"` // -1 means content-format was not provided
	// contains filtered or unexported fields
}

func EventContentToContent 

func EventContentToContent(ec EventContent) (*Content, error)

func (*Content) Descriptor deprecated 

func (*Content) 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 (e *EndpointInformation) Clone() *EndpointInformation

func (*EndpointInformation) Descriptor deprecated 

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

Deprecated: Use EndpointInformation.ProtoReflect.Descriptor instead.

func (*EndpointInformation) GetEndpoint 

func (x *EndpointInformation) GetEndpoint() string

func (*EndpointInformation) GetPriority 

func (x *EndpointInformation) GetPriority() int64

func (*EndpointInformation) ProtoMessage 

func (*EndpointInformation) ProtoMessage()

func (*EndpointInformation) ProtoReflect 

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

func (*EndpointInformation) Reset 

func (x *EndpointInformation) Reset()

func (*EndpointInformation) String 

func (x *EndpointInformation) String() string

func (*EndpointInformation) ToSchema 

func (e *EndpointInformation) ToSchema() schema.Endpoint

type EndpointInformations 

type EndpointInformations []*EndpointInformation

func (EndpointInformations) Clone 

func (e EndpointInformations) Clone() EndpointInformations

func (EndpointInformations) ToSchema 

func (e EndpointInformations) ToSchema() []schema.Endpoint

type EventContent 

type EventContent interface {
	GetContent() *Content
	GetStatus() Status
	protoiface.MessageV1
}

type NotifyResourceChangedRequest 

type NotifyResourceChangedRequest struct {
	ResourceId      *ResourceId      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Content         *Content         `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	CommandMetadata *CommandMetadata `protobuf:"bytes,3,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"`
	Status          Status           `protobuf:"varint,4,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyResourceChangedRequest) Descriptor deprecated 

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

Deprecated: Use NotifyResourceChangedRequest.ProtoReflect.Descriptor instead.

func (*NotifyResourceChangedRequest) GetCommandMetadata 

func (x *NotifyResourceChangedRequest) GetCommandMetadata() *CommandMetadata

func (*NotifyResourceChangedRequest) GetContent 

func (x *NotifyResourceChangedRequest) GetContent() *Content

func (*NotifyResourceChangedRequest) GetResourceId 

func (x *NotifyResourceChangedRequest) GetResourceId() *ResourceId

func (*NotifyResourceChangedRequest) GetStatus 

func (x *NotifyResourceChangedRequest) GetStatus() Status

func (*NotifyResourceChangedRequest) ProtoMessage 

func (*NotifyResourceChangedRequest) ProtoMessage()

func (*NotifyResourceChangedRequest) ProtoReflect 

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

func (*NotifyResourceChangedRequest) Reset 

func (x *NotifyResourceChangedRequest) Reset()

func (*NotifyResourceChangedRequest) String 

func (x *NotifyResourceChangedRequest) String() string

type NotifyResourceChangedResponse 

type NotifyResourceChangedResponse struct {
	AuditContext *AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyResourceChangedResponse) Descriptor deprecated 

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

Deprecated: Use NotifyResourceChangedResponse.ProtoReflect.Descriptor instead.

func (*NotifyResourceChangedResponse) GetAuditContext 

func (x *NotifyResourceChangedResponse) GetAuditContext() *AuditContext

func (*NotifyResourceChangedResponse) ProtoMessage 

func (*NotifyResourceChangedResponse) ProtoMessage()

func (*NotifyResourceChangedResponse) ProtoReflect 

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

func (*NotifyResourceChangedResponse) Reset 

func (x *NotifyResourceChangedResponse) Reset()

func (*NotifyResourceChangedResponse) String 

func (x *NotifyResourceChangedResponse) String() string

type Policy 

type Policy struct {
	BitFlags int32 `protobuf:"varint,1,opt,name=bit_flags,json=bitFlags,proto3" json:"bit_flags,omitempty"`
	// contains filtered or unexported fields
}

func SchemaPolicyToRAPolicy 

func 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() 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) Descriptor() protoreflect.EnumDescriptor

func (ShadowSynchronization) Enum 

func (x ShadowSynchronization) Enum() *ShadowSynchronization

func (ShadowSynchronization) EnumDescriptor deprecated 

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

Deprecated: Use ShadowSynchronization.Descriptor instead.

func (ShadowSynchronization) Number 

func (x ShadowSynchronization) Number() protoreflect.EnumNumber

func (ShadowSynchronization) String 

func (x ShadowSynchronization) String() string

func (ShadowSynchronization) Type 

func (ShadowSynchronization) Type() protoreflect.EnumType

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 (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_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 (x *UpdateDeviceMetadataRequest) GetStatus() *ConnectionStatus

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

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

func (*UpdateDeviceMetadataResponse) Reset 

func (x *UpdateDeviceMetadataResponse) Reset()

func (*UpdateDeviceMetadataResponse) String 

func (x *UpdateDeviceMetadataResponse) String() string

type UpdateResourceRequest 

type UpdateResourceRequest struct {
	ResourceId        *ResourceId      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CorrelationId     string           `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Content           *Content         `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	ResourceInterface string           `protobuf:"bytes,4,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"`
	TimeToLive        int64            `protobuf:"varint,5,opt,name=time_to_live,json=timeToLive,proto3" json:"time_to_live,omitempty"` // command validity in nanoseconds. 0 means forever and minimal value is 100000000 (100ms).
	CommandMetadata   *CommandMetadata `protobuf:"bytes,6,opt,name=command_metadata,json=commandMetadata,proto3" json:"command_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResourceRequest) Descriptor deprecated 

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

Deprecated: Use UpdateResourceRequest.ProtoReflect.Descriptor instead.

func (*UpdateResourceRequest) GetCommandMetadata 

func (x *UpdateResourceRequest) GetCommandMetadata() *CommandMetadata

func (*UpdateResourceRequest) GetContent 

func (x *UpdateResourceRequest) GetContent() *Content

func (*UpdateResourceRequest) GetCorrelationId 

func (x *UpdateResourceRequest) GetCorrelationId() string

func (*UpdateResourceRequest) GetResourceId 

func (x *UpdateResourceRequest) GetResourceId() *ResourceId

func (*UpdateResourceRequest) GetResourceInterface 

func (x *UpdateResourceRequest) GetResourceInterface() string

func (*UpdateResourceRequest) GetTimeToLive 

func (x *UpdateResourceRequest) GetTimeToLive() int64

func (*UpdateResourceRequest) ProtoMessage 

func (*UpdateResourceRequest) ProtoMessage()

func (*UpdateResourceRequest) ProtoReflect 

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

func (*UpdateResourceRequest) Reset 

func (x *UpdateResourceRequest) Reset()

func (*UpdateResourceRequest) String 

func (x *UpdateResourceRequest) String() string

type UpdateResourceResponse 

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

func (*UpdateResourceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResourceResponse.ProtoReflect.Descriptor instead.

func (*UpdateResourceResponse) GetAuditContext 

func (x *UpdateResourceResponse) GetAuditContext() *AuditContext

func (*UpdateResourceResponse) GetValidUntil 

func (x *UpdateResourceResponse) GetValidUntil() int64

func (*UpdateResourceResponse) ProtoMessage 

func (*UpdateResourceResponse) ProtoMessage()

func (*UpdateResourceResponse) ProtoReflect 

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

func (*UpdateResourceResponse) Reset 

func (x *UpdateResourceResponse) Reset()

func (*UpdateResourceResponse) String 

func (x *UpdateResourceResponse) String() string

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.