pb

package
v0.0.0-...-ec2f75e Latest Latest
Warning

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

Go to latest
Published: Apr 6, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthDevices        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDevices          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDevices = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Event_OperationProcessed_ErrorStatus_Code_name = map[int32]string{
	0: "OK",
	1: "ERROR",
	2: "NOT_FOUND",
}
View Source
var Event_OperationProcessed_ErrorStatus_Code_value = map[string]int32{
	"OK":        0,
	"ERROR":     1,
	"NOT_FOUND": 2,
}
View Source
var GetDevicesRequest_Status_name = map[int32]string{
	0: "ONLINE",
	1: "OFFLINE",
}
View Source
var GetDevicesRequest_Status_value = map[string]int32{
	"ONLINE":  0,
	"OFFLINE": 1,
}
View Source
var SubscribeForEvents_DeviceEventFilter_Event_name = map[int32]string{
	0: "RESOURCE_PUBLISHED",
	1: "RESOURCE_UNPUBLISHED",
}
View Source
var SubscribeForEvents_DeviceEventFilter_Event_value = map[string]int32{
	"RESOURCE_PUBLISHED":   0,
	"RESOURCE_UNPUBLISHED": 1,
}
View Source
var SubscribeForEvents_DevicesEventFilter_Event_name = map[int32]string{
	0: "REGISTERED",
	1: "UNREGISTERED",
	2: "ONLINE",
	3: "OFFLINE",
}
View Source
var SubscribeForEvents_DevicesEventFilter_Event_value = map[string]int32{
	"REGISTERED":   0,
	"UNREGISTERED": 1,
	"ONLINE":       2,
	"OFFLINE":      3,
}
View Source
var SubscribeForEvents_ResourceEventFilter_Event_name = map[int32]string{
	0: "CONTENT_CHANGED",
}
View Source
var SubscribeForEvents_ResourceEventFilter_Event_value = map[string]int32{
	"CONTENT_CHANGED": 0,
}

Functions

func RegisterGrpcGatewayServer

func RegisterGrpcGatewayServer(s *grpc.Server, srv GrpcGatewayServer)

Types

type Content

type Content struct {
	ContentType string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Data        []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Content) Descriptor

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

func (*Content) GetContentType

func (m *Content) GetContentType() string

func (*Content) GetData

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

func (*Content) Marshal

func (m *Content) Marshal() (dAtA []byte, err error)

func (*Content) MarshalTo

func (m *Content) MarshalTo(dAtA []byte) (int, error)

func (*Content) MarshalToSizedBuffer

func (m *Content) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Content) ProtoMessage

func (*Content) ProtoMessage()

func (*Content) Reset

func (m *Content) Reset()

func (*Content) Size

func (m *Content) Size() (n int)

func (*Content) String

func (m *Content) String() string

func (*Content) Unmarshal

func (m *Content) Unmarshal(dAtA []byte) error

func (*Content) XXX_DiscardUnknown

func (m *Content) XXX_DiscardUnknown()

func (*Content) XXX_Marshal

func (m *Content) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Content) XXX_Merge

func (m *Content) XXX_Merge(src proto.Message)

func (*Content) XXX_Size

func (m *Content) XXX_Size() int

func (*Content) XXX_Unmarshal

func (m *Content) XXX_Unmarshal(b []byte) error

type Device

type Device struct {
	Id               string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Types            []string           `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	Name             string             `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	IsOnline         bool               `protobuf:"varint,4,opt,name=is_online,json=isOnline,proto3" json:"is_online,omitempty"`
	ManufacturerName []*LocalizedString `protobuf:"bytes,5,rep,name=manufacturer_name,json=manufacturerName,proto3" json:"manufacturer_name,omitempty"`
	ModelNumber      string             `protobuf:"bytes,6,opt,name=model_number,json=modelNumber,proto3" json:"model_number,omitempty"`
}

func (*Device) Descriptor

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

func (*Device) GetId

func (m *Device) GetId() string

func (*Device) GetIsOnline

func (m *Device) GetIsOnline() bool

func (*Device) GetManufacturerName

func (m *Device) GetManufacturerName() []*LocalizedString

func (*Device) GetModelNumber

func (m *Device) GetModelNumber() string

func (*Device) GetName

func (m *Device) GetName() string

func (*Device) GetTypes

func (m *Device) GetTypes() []string

func (*Device) Marshal

func (m *Device) Marshal() (dAtA []byte, err error)

func (*Device) MarshalTo

func (m *Device) MarshalTo(dAtA []byte) (int, error)

func (*Device) MarshalToSizedBuffer

func (m *Device) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Device) ProtoMessage

func (*Device) ProtoMessage()

func (*Device) Reset

func (m *Device) Reset()

func (*Device) Size

func (m *Device) Size() (n int)

func (*Device) String

func (m *Device) String() string

func (*Device) Unmarshal

func (m *Device) Unmarshal(dAtA []byte) error

func (*Device) XXX_DiscardUnknown

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal

func (m *Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Device) XXX_Merge

func (m *Device) XXX_Merge(src proto.Message)

func (*Device) XXX_Size

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal

func (m *Device) XXX_Unmarshal(b []byte) error

type Event

type Event struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// Types that are valid to be assigned to Type:
	//	*Event_DeviceRegistered_
	//	*Event_DeviceUnregistered_
	//	*Event_DeviceOnline_
	//	*Event_DeviceOffline_
	//	*Event_ResourcePublished_
	//	*Event_ResourceUnpublished_
	//	*Event_ResourceContentChanged
	//	*Event_OperationProcessed_
	//	*Event_SubscriptionCanceled_
	Type isEvent_Type `protobuf_oneof:"type"`
}

func (*Event) Descriptor

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

func (*Event) GetDeviceOffline

func (m *Event) GetDeviceOffline() *Event_DeviceOffline

func (*Event) GetDeviceOnline

func (m *Event) GetDeviceOnline() *Event_DeviceOnline

func (*Event) GetDeviceRegistered

func (m *Event) GetDeviceRegistered() *Event_DeviceRegistered

func (*Event) GetDeviceUnregistered

func (m *Event) GetDeviceUnregistered() *Event_DeviceUnregistered

func (*Event) GetOperationProcessed

func (m *Event) GetOperationProcessed() *Event_OperationProcessed

func (*Event) GetResourceContentChanged

func (m *Event) GetResourceContentChanged() *Event_ResourceChanged

func (*Event) GetResourcePublished

func (m *Event) GetResourcePublished() *Event_ResourcePublished

func (*Event) GetResourceUnpublished

func (m *Event) GetResourceUnpublished() *Event_ResourceUnpublished

func (*Event) GetSubscriptionCanceled

func (m *Event) GetSubscriptionCanceled() *Event_SubscriptionCanceled

func (*Event) GetSubscriptionId

func (m *Event) GetSubscriptionId() string

func (*Event) GetType

func (m *Event) GetType() isEvent_Type

func (*Event) Marshal

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) Size

func (m *Event) Size() (n int)

func (*Event) String

func (m *Event) String() string

func (*Event) Unmarshal

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_OneofWrappers

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal

func (m *Event) XXX_Unmarshal(b []byte) error

type Event_DeviceOffline

type Event_DeviceOffline struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
}

func (*Event_DeviceOffline) Descriptor

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

func (*Event_DeviceOffline) GetDeviceId

func (m *Event_DeviceOffline) GetDeviceId() string

func (*Event_DeviceOffline) Marshal

func (m *Event_DeviceOffline) Marshal() (dAtA []byte, err error)

func (*Event_DeviceOffline) MarshalTo

func (m *Event_DeviceOffline) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceOffline) MarshalToSizedBuffer

func (m *Event_DeviceOffline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceOffline) ProtoMessage

func (*Event_DeviceOffline) ProtoMessage()

func (*Event_DeviceOffline) Reset

func (m *Event_DeviceOffline) Reset()

func (*Event_DeviceOffline) Size

func (m *Event_DeviceOffline) Size() (n int)

func (*Event_DeviceOffline) String

func (m *Event_DeviceOffline) String() string

func (*Event_DeviceOffline) Unmarshal

func (m *Event_DeviceOffline) Unmarshal(dAtA []byte) error

func (*Event_DeviceOffline) XXX_DiscardUnknown

func (m *Event_DeviceOffline) XXX_DiscardUnknown()

func (*Event_DeviceOffline) XXX_Marshal

func (m *Event_DeviceOffline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_DeviceOffline) XXX_Merge

func (m *Event_DeviceOffline) XXX_Merge(src proto.Message)

func (*Event_DeviceOffline) XXX_Size

func (m *Event_DeviceOffline) XXX_Size() int

func (*Event_DeviceOffline) XXX_Unmarshal

func (m *Event_DeviceOffline) XXX_Unmarshal(b []byte) error

type Event_DeviceOffline_

type Event_DeviceOffline_ struct {
	DeviceOffline *Event_DeviceOffline `protobuf:"bytes,6,opt,name=device_offline,json=deviceOffline,proto3,oneof" json:"device_offline,omitempty"`
}

func (*Event_DeviceOffline_) MarshalTo

func (m *Event_DeviceOffline_) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceOffline_) MarshalToSizedBuffer

func (m *Event_DeviceOffline_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceOffline_) Size

func (m *Event_DeviceOffline_) Size() (n int)

type Event_DeviceOnline

type Event_DeviceOnline struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
}

func (*Event_DeviceOnline) Descriptor

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

func (*Event_DeviceOnline) GetDeviceId

func (m *Event_DeviceOnline) GetDeviceId() string

func (*Event_DeviceOnline) Marshal

func (m *Event_DeviceOnline) Marshal() (dAtA []byte, err error)

func (*Event_DeviceOnline) MarshalTo

func (m *Event_DeviceOnline) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceOnline) MarshalToSizedBuffer

func (m *Event_DeviceOnline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceOnline) ProtoMessage

func (*Event_DeviceOnline) ProtoMessage()

func (*Event_DeviceOnline) Reset

func (m *Event_DeviceOnline) Reset()

func (*Event_DeviceOnline) Size

func (m *Event_DeviceOnline) Size() (n int)

func (*Event_DeviceOnline) String

func (m *Event_DeviceOnline) String() string

func (*Event_DeviceOnline) Unmarshal

func (m *Event_DeviceOnline) Unmarshal(dAtA []byte) error

func (*Event_DeviceOnline) XXX_DiscardUnknown

func (m *Event_DeviceOnline) XXX_DiscardUnknown()

func (*Event_DeviceOnline) XXX_Marshal

func (m *Event_DeviceOnline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_DeviceOnline) XXX_Merge

func (m *Event_DeviceOnline) XXX_Merge(src proto.Message)

func (*Event_DeviceOnline) XXX_Size

func (m *Event_DeviceOnline) XXX_Size() int

func (*Event_DeviceOnline) XXX_Unmarshal

func (m *Event_DeviceOnline) XXX_Unmarshal(b []byte) error

type Event_DeviceOnline_

type Event_DeviceOnline_ struct {
	DeviceOnline *Event_DeviceOnline `protobuf:"bytes,5,opt,name=device_online,json=deviceOnline,proto3,oneof" json:"device_online,omitempty"`
}

func (*Event_DeviceOnline_) MarshalTo

func (m *Event_DeviceOnline_) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceOnline_) MarshalToSizedBuffer

func (m *Event_DeviceOnline_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceOnline_) Size

func (m *Event_DeviceOnline_) Size() (n int)

type Event_DeviceRegistered

type Event_DeviceRegistered struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
}

func (*Event_DeviceRegistered) Descriptor

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

func (*Event_DeviceRegistered) GetDeviceId

func (m *Event_DeviceRegistered) GetDeviceId() string

func (*Event_DeviceRegistered) Marshal

func (m *Event_DeviceRegistered) Marshal() (dAtA []byte, err error)

func (*Event_DeviceRegistered) MarshalTo

func (m *Event_DeviceRegistered) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceRegistered) MarshalToSizedBuffer

func (m *Event_DeviceRegistered) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceRegistered) ProtoMessage

func (*Event_DeviceRegistered) ProtoMessage()

func (*Event_DeviceRegistered) Reset

func (m *Event_DeviceRegistered) Reset()

func (*Event_DeviceRegistered) Size

func (m *Event_DeviceRegistered) Size() (n int)

func (*Event_DeviceRegistered) String

func (m *Event_DeviceRegistered) String() string

func (*Event_DeviceRegistered) Unmarshal

func (m *Event_DeviceRegistered) Unmarshal(dAtA []byte) error

func (*Event_DeviceRegistered) XXX_DiscardUnknown

func (m *Event_DeviceRegistered) XXX_DiscardUnknown()

func (*Event_DeviceRegistered) XXX_Marshal

func (m *Event_DeviceRegistered) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_DeviceRegistered) XXX_Merge

func (m *Event_DeviceRegistered) XXX_Merge(src proto.Message)

func (*Event_DeviceRegistered) XXX_Size

func (m *Event_DeviceRegistered) XXX_Size() int

func (*Event_DeviceRegistered) XXX_Unmarshal

func (m *Event_DeviceRegistered) XXX_Unmarshal(b []byte) error

type Event_DeviceRegistered_

type Event_DeviceRegistered_ struct {
	DeviceRegistered *Event_DeviceRegistered `protobuf:"bytes,3,opt,name=device_registered,json=deviceRegistered,proto3,oneof" json:"device_registered,omitempty"`
}

func (*Event_DeviceRegistered_) MarshalTo

func (m *Event_DeviceRegistered_) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceRegistered_) MarshalToSizedBuffer

func (m *Event_DeviceRegistered_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceRegistered_) Size

func (m *Event_DeviceRegistered_) Size() (n int)

type Event_DeviceUnregistered

type Event_DeviceUnregistered struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
}

func (*Event_DeviceUnregistered) Descriptor

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

func (*Event_DeviceUnregistered) GetDeviceId

func (m *Event_DeviceUnregistered) GetDeviceId() string

func (*Event_DeviceUnregistered) Marshal

func (m *Event_DeviceUnregistered) Marshal() (dAtA []byte, err error)

func (*Event_DeviceUnregistered) MarshalTo

func (m *Event_DeviceUnregistered) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceUnregistered) MarshalToSizedBuffer

func (m *Event_DeviceUnregistered) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceUnregistered) ProtoMessage

func (*Event_DeviceUnregistered) ProtoMessage()

func (*Event_DeviceUnregistered) Reset

func (m *Event_DeviceUnregistered) Reset()

func (*Event_DeviceUnregistered) Size

func (m *Event_DeviceUnregistered) Size() (n int)

func (*Event_DeviceUnregistered) String

func (m *Event_DeviceUnregistered) String() string

func (*Event_DeviceUnregistered) Unmarshal

func (m *Event_DeviceUnregistered) Unmarshal(dAtA []byte) error

func (*Event_DeviceUnregistered) XXX_DiscardUnknown

func (m *Event_DeviceUnregistered) XXX_DiscardUnknown()

func (*Event_DeviceUnregistered) XXX_Marshal

func (m *Event_DeviceUnregistered) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_DeviceUnregistered) XXX_Merge

func (m *Event_DeviceUnregistered) XXX_Merge(src proto.Message)

func (*Event_DeviceUnregistered) XXX_Size

func (m *Event_DeviceUnregistered) XXX_Size() int

func (*Event_DeviceUnregistered) XXX_Unmarshal

func (m *Event_DeviceUnregistered) XXX_Unmarshal(b []byte) error

type Event_DeviceUnregistered_

type Event_DeviceUnregistered_ struct {
	DeviceUnregistered *Event_DeviceUnregistered `protobuf:"bytes,4,opt,name=device_unregistered,json=deviceUnregistered,proto3,oneof" json:"device_unregistered,omitempty"`
}

func (*Event_DeviceUnregistered_) MarshalTo

func (m *Event_DeviceUnregistered_) MarshalTo(dAtA []byte) (int, error)

func (*Event_DeviceUnregistered_) MarshalToSizedBuffer

func (m *Event_DeviceUnregistered_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_DeviceUnregistered_) Size

func (m *Event_DeviceUnregistered_) Size() (n int)

type Event_OperationProcessed

type Event_OperationProcessed struct {
	Token       string                                `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	ErrorStatus *Event_OperationProcessed_ErrorStatus `protobuf:"bytes,2,opt,name=error_status,json=errorStatus,proto3" json:"error_status,omitempty"`
}

func (*Event_OperationProcessed) Descriptor

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

func (*Event_OperationProcessed) GetErrorStatus

func (*Event_OperationProcessed) GetToken

func (m *Event_OperationProcessed) GetToken() string

func (*Event_OperationProcessed) Marshal

func (m *Event_OperationProcessed) Marshal() (dAtA []byte, err error)

func (*Event_OperationProcessed) MarshalTo

func (m *Event_OperationProcessed) MarshalTo(dAtA []byte) (int, error)

func (*Event_OperationProcessed) MarshalToSizedBuffer

func (m *Event_OperationProcessed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_OperationProcessed) ProtoMessage

func (*Event_OperationProcessed) ProtoMessage()

func (*Event_OperationProcessed) Reset

func (m *Event_OperationProcessed) Reset()

func (*Event_OperationProcessed) Size

func (m *Event_OperationProcessed) Size() (n int)

func (*Event_OperationProcessed) String

func (m *Event_OperationProcessed) String() string

func (*Event_OperationProcessed) Unmarshal

func (m *Event_OperationProcessed) Unmarshal(dAtA []byte) error

func (*Event_OperationProcessed) XXX_DiscardUnknown

func (m *Event_OperationProcessed) XXX_DiscardUnknown()

func (*Event_OperationProcessed) XXX_Marshal

func (m *Event_OperationProcessed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_OperationProcessed) XXX_Merge

func (m *Event_OperationProcessed) XXX_Merge(src proto.Message)

func (*Event_OperationProcessed) XXX_Size

func (m *Event_OperationProcessed) XXX_Size() int

func (*Event_OperationProcessed) XXX_Unmarshal

func (m *Event_OperationProcessed) XXX_Unmarshal(b []byte) error

type Event_OperationProcessed_

type Event_OperationProcessed_ struct {
	OperationProcessed *Event_OperationProcessed `protobuf:"bytes,10,opt,name=operation_processed,json=operationProcessed,proto3,oneof" json:"operation_processed,omitempty"`
}

func (*Event_OperationProcessed_) MarshalTo

func (m *Event_OperationProcessed_) MarshalTo(dAtA []byte) (int, error)

func (*Event_OperationProcessed_) MarshalToSizedBuffer

func (m *Event_OperationProcessed_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_OperationProcessed_) Size

func (m *Event_OperationProcessed_) Size() (n int)

type Event_OperationProcessed_ErrorStatus

type Event_OperationProcessed_ErrorStatus struct {
	Code    Event_OperationProcessed_ErrorStatus_Code `` /* 134-byte string literal not displayed */
	Message string                                    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Event_OperationProcessed_ErrorStatus) Descriptor

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

func (*Event_OperationProcessed_ErrorStatus) GetCode

func (*Event_OperationProcessed_ErrorStatus) GetMessage

func (*Event_OperationProcessed_ErrorStatus) Marshal

func (m *Event_OperationProcessed_ErrorStatus) Marshal() (dAtA []byte, err error)

func (*Event_OperationProcessed_ErrorStatus) MarshalTo

func (m *Event_OperationProcessed_ErrorStatus) MarshalTo(dAtA []byte) (int, error)

func (*Event_OperationProcessed_ErrorStatus) MarshalToSizedBuffer

func (m *Event_OperationProcessed_ErrorStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_OperationProcessed_ErrorStatus) ProtoMessage

func (*Event_OperationProcessed_ErrorStatus) ProtoMessage()

func (*Event_OperationProcessed_ErrorStatus) Reset

func (*Event_OperationProcessed_ErrorStatus) Size

func (*Event_OperationProcessed_ErrorStatus) String

func (*Event_OperationProcessed_ErrorStatus) Unmarshal

func (m *Event_OperationProcessed_ErrorStatus) Unmarshal(dAtA []byte) error

func (*Event_OperationProcessed_ErrorStatus) XXX_DiscardUnknown

func (m *Event_OperationProcessed_ErrorStatus) XXX_DiscardUnknown()

func (*Event_OperationProcessed_ErrorStatus) XXX_Marshal

func (m *Event_OperationProcessed_ErrorStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_OperationProcessed_ErrorStatus) XXX_Merge

func (*Event_OperationProcessed_ErrorStatus) XXX_Size

func (*Event_OperationProcessed_ErrorStatus) XXX_Unmarshal

func (m *Event_OperationProcessed_ErrorStatus) XXX_Unmarshal(b []byte) error

type Event_OperationProcessed_ErrorStatus_Code

type Event_OperationProcessed_ErrorStatus_Code int32
const (
	Event_OperationProcessed_ErrorStatus_OK        Event_OperationProcessed_ErrorStatus_Code = 0
	Event_OperationProcessed_ErrorStatus_ERROR     Event_OperationProcessed_ErrorStatus_Code = 1
	Event_OperationProcessed_ErrorStatus_NOT_FOUND Event_OperationProcessed_ErrorStatus_Code = 2
)

func (Event_OperationProcessed_ErrorStatus_Code) EnumDescriptor

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

func (Event_OperationProcessed_ErrorStatus_Code) String

type Event_ResourceChanged

type Event_ResourceChanged 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"`
}

func (*Event_ResourceChanged) Descriptor

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

func (*Event_ResourceChanged) GetContent

func (m *Event_ResourceChanged) GetContent() *Content

func (*Event_ResourceChanged) GetResourceId

func (m *Event_ResourceChanged) GetResourceId() *ResourceId

func (*Event_ResourceChanged) Marshal

func (m *Event_ResourceChanged) Marshal() (dAtA []byte, err error)

func (*Event_ResourceChanged) MarshalTo

func (m *Event_ResourceChanged) MarshalTo(dAtA []byte) (int, error)

func (*Event_ResourceChanged) MarshalToSizedBuffer

func (m *Event_ResourceChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ResourceChanged) ProtoMessage

func (*Event_ResourceChanged) ProtoMessage()

func (*Event_ResourceChanged) Reset

func (m *Event_ResourceChanged) Reset()

func (*Event_ResourceChanged) Size

func (m *Event_ResourceChanged) Size() (n int)

func (*Event_ResourceChanged) String

func (m *Event_ResourceChanged) String() string

func (*Event_ResourceChanged) Unmarshal

func (m *Event_ResourceChanged) Unmarshal(dAtA []byte) error

func (*Event_ResourceChanged) XXX_DiscardUnknown

func (m *Event_ResourceChanged) XXX_DiscardUnknown()

func (*Event_ResourceChanged) XXX_Marshal

func (m *Event_ResourceChanged) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_ResourceChanged) XXX_Merge

func (m *Event_ResourceChanged) XXX_Merge(src proto.Message)

func (*Event_ResourceChanged) XXX_Size

func (m *Event_ResourceChanged) XXX_Size() int

func (*Event_ResourceChanged) XXX_Unmarshal

func (m *Event_ResourceChanged) XXX_Unmarshal(b []byte) error

type Event_ResourceContentChanged

type Event_ResourceContentChanged struct {
	ResourceContentChanged *Event_ResourceChanged `` /* 135-byte string literal not displayed */
}

func (*Event_ResourceContentChanged) MarshalTo

func (m *Event_ResourceContentChanged) MarshalTo(dAtA []byte) (int, error)

func (*Event_ResourceContentChanged) MarshalToSizedBuffer

func (m *Event_ResourceContentChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ResourceContentChanged) Size

func (m *Event_ResourceContentChanged) Size() (n int)

type Event_ResourcePublished

type Event_ResourcePublished struct {
	Link *ResourceLink `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"`
}

func (*Event_ResourcePublished) Descriptor

func (*Event_ResourcePublished) Descriptor() ([]byte, []int)
func (m *Event_ResourcePublished) GetLink() *ResourceLink

func (*Event_ResourcePublished) Marshal

func (m *Event_ResourcePublished) Marshal() (dAtA []byte, err error)

func (*Event_ResourcePublished) MarshalTo

func (m *Event_ResourcePublished) MarshalTo(dAtA []byte) (int, error)

func (*Event_ResourcePublished) MarshalToSizedBuffer

func (m *Event_ResourcePublished) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ResourcePublished) ProtoMessage

func (*Event_ResourcePublished) ProtoMessage()

func (*Event_ResourcePublished) Reset

func (m *Event_ResourcePublished) Reset()

func (*Event_ResourcePublished) Size

func (m *Event_ResourcePublished) Size() (n int)

func (*Event_ResourcePublished) String

func (m *Event_ResourcePublished) String() string

func (*Event_ResourcePublished) Unmarshal

func (m *Event_ResourcePublished) Unmarshal(dAtA []byte) error

func (*Event_ResourcePublished) XXX_DiscardUnknown

func (m *Event_ResourcePublished) XXX_DiscardUnknown()

func (*Event_ResourcePublished) XXX_Marshal

func (m *Event_ResourcePublished) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_ResourcePublished) XXX_Merge

func (m *Event_ResourcePublished) XXX_Merge(src proto.Message)

func (*Event_ResourcePublished) XXX_Size

func (m *Event_ResourcePublished) XXX_Size() int

func (*Event_ResourcePublished) XXX_Unmarshal

func (m *Event_ResourcePublished) XXX_Unmarshal(b []byte) error

type Event_ResourcePublished_

type Event_ResourcePublished_ struct {
	ResourcePublished *Event_ResourcePublished `protobuf:"bytes,7,opt,name=resource_published,json=resourcePublished,proto3,oneof" json:"resource_published,omitempty"`
}

func (*Event_ResourcePublished_) MarshalTo

func (m *Event_ResourcePublished_) MarshalTo(dAtA []byte) (int, error)

func (*Event_ResourcePublished_) MarshalToSizedBuffer

func (m *Event_ResourcePublished_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ResourcePublished_) Size

func (m *Event_ResourcePublished_) Size() (n int)

type Event_ResourceUnpublished

type Event_ResourceUnpublished struct {
	Link *ResourceLink `protobuf:"bytes,2,opt,name=link,proto3" json:"link,omitempty"`
}

func (*Event_ResourceUnpublished) Descriptor

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

func (*Event_ResourceUnpublished) Marshal

func (m *Event_ResourceUnpublished) Marshal() (dAtA []byte, err error)

func (*Event_ResourceUnpublished) MarshalTo

func (m *Event_ResourceUnpublished) MarshalTo(dAtA []byte) (int, error)

func (*Event_ResourceUnpublished) MarshalToSizedBuffer

func (m *Event_ResourceUnpublished) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ResourceUnpublished) ProtoMessage

func (*Event_ResourceUnpublished) ProtoMessage()

func (*Event_ResourceUnpublished) Reset

func (m *Event_ResourceUnpublished) Reset()

func (*Event_ResourceUnpublished) Size

func (m *Event_ResourceUnpublished) Size() (n int)

func (*Event_ResourceUnpublished) String

func (m *Event_ResourceUnpublished) String() string

func (*Event_ResourceUnpublished) Unmarshal

func (m *Event_ResourceUnpublished) Unmarshal(dAtA []byte) error

func (*Event_ResourceUnpublished) XXX_DiscardUnknown

func (m *Event_ResourceUnpublished) XXX_DiscardUnknown()

func (*Event_ResourceUnpublished) XXX_Marshal

func (m *Event_ResourceUnpublished) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_ResourceUnpublished) XXX_Merge

func (m *Event_ResourceUnpublished) XXX_Merge(src proto.Message)

func (*Event_ResourceUnpublished) XXX_Size

func (m *Event_ResourceUnpublished) XXX_Size() int

func (*Event_ResourceUnpublished) XXX_Unmarshal

func (m *Event_ResourceUnpublished) XXX_Unmarshal(b []byte) error

type Event_ResourceUnpublished_

type Event_ResourceUnpublished_ struct {
	ResourceUnpublished *Event_ResourceUnpublished `protobuf:"bytes,8,opt,name=resource_unpublished,json=resourceUnpublished,proto3,oneof" json:"resource_unpublished,omitempty"`
}

func (*Event_ResourceUnpublished_) MarshalTo

func (m *Event_ResourceUnpublished_) MarshalTo(dAtA []byte) (int, error)

func (*Event_ResourceUnpublished_) MarshalToSizedBuffer

func (m *Event_ResourceUnpublished_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_ResourceUnpublished_) Size

func (m *Event_ResourceUnpublished_) Size() (n int)

type Event_SubscriptionCanceled

type Event_SubscriptionCanceled struct {
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*Event_SubscriptionCanceled) Descriptor

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

func (*Event_SubscriptionCanceled) GetReason

func (m *Event_SubscriptionCanceled) GetReason() string

func (*Event_SubscriptionCanceled) Marshal

func (m *Event_SubscriptionCanceled) Marshal() (dAtA []byte, err error)

func (*Event_SubscriptionCanceled) MarshalTo

func (m *Event_SubscriptionCanceled) MarshalTo(dAtA []byte) (int, error)

func (*Event_SubscriptionCanceled) MarshalToSizedBuffer

func (m *Event_SubscriptionCanceled) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_SubscriptionCanceled) ProtoMessage

func (*Event_SubscriptionCanceled) ProtoMessage()

func (*Event_SubscriptionCanceled) Reset

func (m *Event_SubscriptionCanceled) Reset()

func (*Event_SubscriptionCanceled) Size

func (m *Event_SubscriptionCanceled) Size() (n int)

func (*Event_SubscriptionCanceled) String

func (m *Event_SubscriptionCanceled) String() string

func (*Event_SubscriptionCanceled) Unmarshal

func (m *Event_SubscriptionCanceled) Unmarshal(dAtA []byte) error

func (*Event_SubscriptionCanceled) XXX_DiscardUnknown

func (m *Event_SubscriptionCanceled) XXX_DiscardUnknown()

func (*Event_SubscriptionCanceled) XXX_Marshal

func (m *Event_SubscriptionCanceled) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event_SubscriptionCanceled) XXX_Merge

func (m *Event_SubscriptionCanceled) XXX_Merge(src proto.Message)

func (*Event_SubscriptionCanceled) XXX_Size

func (m *Event_SubscriptionCanceled) XXX_Size() int

func (*Event_SubscriptionCanceled) XXX_Unmarshal

func (m *Event_SubscriptionCanceled) XXX_Unmarshal(b []byte) error

type Event_SubscriptionCanceled_

type Event_SubscriptionCanceled_ struct {
	SubscriptionCanceled *Event_SubscriptionCanceled `` /* 128-byte string literal not displayed */
}

func (*Event_SubscriptionCanceled_) MarshalTo

func (m *Event_SubscriptionCanceled_) MarshalTo(dAtA []byte) (int, error)

func (*Event_SubscriptionCanceled_) MarshalToSizedBuffer

func (m *Event_SubscriptionCanceled_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event_SubscriptionCanceled_) Size

func (m *Event_SubscriptionCanceled_) Size() (n int)

type GetDevicesRequest

type GetDevicesRequest struct {
	TypeFilter      []string                   `protobuf:"bytes,1,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"`
	StatusFilter    []GetDevicesRequest_Status `` /* 160-byte string literal not displayed */
	DeviceIdsFilter []string                   `protobuf:"bytes,3,rep,name=device_ids_filter,json=deviceIdsFilter,proto3" json:"device_ids_filter,omitempty"`
}

func (*GetDevicesRequest) Descriptor

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

func (*GetDevicesRequest) GetDeviceIdsFilter

func (m *GetDevicesRequest) GetDeviceIdsFilter() []string

func (*GetDevicesRequest) GetStatusFilter

func (m *GetDevicesRequest) GetStatusFilter() []GetDevicesRequest_Status

func (*GetDevicesRequest) GetTypeFilter

func (m *GetDevicesRequest) GetTypeFilter() []string

func (*GetDevicesRequest) Marshal

func (m *GetDevicesRequest) Marshal() (dAtA []byte, err error)

func (*GetDevicesRequest) MarshalTo

func (m *GetDevicesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDevicesRequest) MarshalToSizedBuffer

func (m *GetDevicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDevicesRequest) ProtoMessage

func (*GetDevicesRequest) ProtoMessage()

func (*GetDevicesRequest) Reset

func (m *GetDevicesRequest) Reset()

func (*GetDevicesRequest) Size

func (m *GetDevicesRequest) Size() (n int)

func (*GetDevicesRequest) String

func (m *GetDevicesRequest) String() string

func (*GetDevicesRequest) Unmarshal

func (m *GetDevicesRequest) Unmarshal(dAtA []byte) error

func (*GetDevicesRequest) XXX_DiscardUnknown

func (m *GetDevicesRequest) XXX_DiscardUnknown()

func (*GetDevicesRequest) XXX_Marshal

func (m *GetDevicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDevicesRequest) XXX_Merge

func (m *GetDevicesRequest) XXX_Merge(src proto.Message)

func (*GetDevicesRequest) XXX_Size

func (m *GetDevicesRequest) XXX_Size() int

func (*GetDevicesRequest) XXX_Unmarshal

func (m *GetDevicesRequest) XXX_Unmarshal(b []byte) error

type GetDevicesRequest_Status

type GetDevicesRequest_Status int32
const (
	GetDevicesRequest_ONLINE  GetDevicesRequest_Status = 0
	GetDevicesRequest_OFFLINE GetDevicesRequest_Status = 1
)

func (GetDevicesRequest_Status) EnumDescriptor

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

func (GetDevicesRequest_Status) String

func (x GetDevicesRequest_Status) String() string

type GetResourceLinksRequest

type GetResourceLinksRequest struct {
	TypeFilter      []string `protobuf:"bytes,1,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"`
	DeviceIdsFilter []string `protobuf:"bytes,2,rep,name=device_ids_filter,json=deviceIdsFilter,proto3" json:"device_ids_filter,omitempty"`
}

func (*GetResourceLinksRequest) Descriptor

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

func (*GetResourceLinksRequest) GetDeviceIdsFilter

func (m *GetResourceLinksRequest) GetDeviceIdsFilter() []string

func (*GetResourceLinksRequest) GetTypeFilter

func (m *GetResourceLinksRequest) GetTypeFilter() []string

func (*GetResourceLinksRequest) Marshal

func (m *GetResourceLinksRequest) Marshal() (dAtA []byte, err error)

func (*GetResourceLinksRequest) MarshalTo

func (m *GetResourceLinksRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetResourceLinksRequest) MarshalToSizedBuffer

func (m *GetResourceLinksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetResourceLinksRequest) ProtoMessage

func (*GetResourceLinksRequest) ProtoMessage()

func (*GetResourceLinksRequest) Reset

func (m *GetResourceLinksRequest) Reset()

func (*GetResourceLinksRequest) Size

func (m *GetResourceLinksRequest) Size() (n int)

func (*GetResourceLinksRequest) String

func (m *GetResourceLinksRequest) String() string

func (*GetResourceLinksRequest) Unmarshal

func (m *GetResourceLinksRequest) Unmarshal(dAtA []byte) error

func (*GetResourceLinksRequest) XXX_DiscardUnknown

func (m *GetResourceLinksRequest) XXX_DiscardUnknown()

func (*GetResourceLinksRequest) XXX_Marshal

func (m *GetResourceLinksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResourceLinksRequest) XXX_Merge

func (m *GetResourceLinksRequest) XXX_Merge(src proto.Message)

func (*GetResourceLinksRequest) XXX_Size

func (m *GetResourceLinksRequest) XXX_Size() int

func (*GetResourceLinksRequest) XXX_Unmarshal

func (m *GetResourceLinksRequest) XXX_Unmarshal(b []byte) error

type GrpcGatewayClient

type GrpcGatewayClient interface {
	// Get all devices
	GetDevices(ctx context.Context, in *GetDevicesRequest, opts ...grpc.CallOption) (GrpcGateway_GetDevicesClient, error)
	// Get resource links of devices.
	GetResourceLinks(ctx context.Context, in *GetResourceLinksRequest, opts ...grpc.CallOption) (GrpcGateway_GetResourceLinksClient, error)
	RetrieveResourceFromDevice(ctx context.Context, in *RetrieveResourceFromDeviceRequest, opts ...grpc.CallOption) (*RetrieveResourceFromDeviceResponse, error)
	// Retrieve resources values from resource shadow
	RetrieveResourcesValues(ctx context.Context, in *RetrieveResourcesValuesRequest, opts ...grpc.CallOption) (GrpcGateway_RetrieveResourcesValuesClient, error)
	// Update resource values
	UpdateResourcesValues(ctx context.Context, in *UpdateResourceValuesRequest, opts ...grpc.CallOption) (*UpdateResourceValuesResponse, error)
	// Subscribe to events
	SubscribeForEvents(ctx context.Context, opts ...grpc.CallOption) (GrpcGateway_SubscribeForEventsClient, error)
}

GrpcGatewayClient is the client API for GrpcGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGrpcGatewayClient

func NewGrpcGatewayClient(cc *grpc.ClientConn) GrpcGatewayClient

type GrpcGatewayServer

type GrpcGatewayServer interface {
	// Get all devices
	GetDevices(*GetDevicesRequest, GrpcGateway_GetDevicesServer) error
	// Get resource links of devices.
	GetResourceLinks(*GetResourceLinksRequest, GrpcGateway_GetResourceLinksServer) error
	RetrieveResourceFromDevice(context.Context, *RetrieveResourceFromDeviceRequest) (*RetrieveResourceFromDeviceResponse, error)
	// Retrieve resources values from resource shadow
	RetrieveResourcesValues(*RetrieveResourcesValuesRequest, GrpcGateway_RetrieveResourcesValuesServer) error
	// Update resource values
	UpdateResourcesValues(context.Context, *UpdateResourceValuesRequest) (*UpdateResourceValuesResponse, error)
	// Subscribe to events
	SubscribeForEvents(GrpcGateway_SubscribeForEventsServer) error
}

GrpcGatewayServer is the server API for GrpcGateway service.

type GrpcGateway_GetDevicesClient

type GrpcGateway_GetDevicesClient interface {
	Recv() (*Device, error)
	grpc.ClientStream
}

type GrpcGateway_GetDevicesServer

type GrpcGateway_GetDevicesServer interface {
	Send(*Device) error
	grpc.ServerStream
}

type GrpcGateway_GetResourceLinksClient

type GrpcGateway_GetResourceLinksClient interface {
	Recv() (*ResourceLink, error)
	grpc.ClientStream
}

type GrpcGateway_GetResourceLinksServer

type GrpcGateway_GetResourceLinksServer interface {
	Send(*ResourceLink) error
	grpc.ServerStream
}

type GrpcGateway_RetrieveResourcesValuesClient

type GrpcGateway_RetrieveResourcesValuesClient interface {
	Recv() (*ResourceValue, error)
	grpc.ClientStream
}

type GrpcGateway_RetrieveResourcesValuesServer

type GrpcGateway_RetrieveResourcesValuesServer interface {
	Send(*ResourceValue) error
	grpc.ServerStream
}

type GrpcGateway_SubscribeForEventsClient

type GrpcGateway_SubscribeForEventsClient interface {
	Send(*SubscribeForEvents) error
	Recv() (*Event, error)
	grpc.ClientStream
}

type GrpcGateway_SubscribeForEventsServer

type GrpcGateway_SubscribeForEventsServer interface {
	Send(*Event) error
	Recv() (*SubscribeForEvents, error)
	grpc.ServerStream
}

type LocalizedString

type LocalizedString struct {
	Language string `protobuf:"bytes,1,opt,name=language,proto3" json:"language,omitempty"`
	Value    string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LocalizedString) Descriptor

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

func (*LocalizedString) GetLanguage

func (m *LocalizedString) GetLanguage() string

func (*LocalizedString) GetValue

func (m *LocalizedString) GetValue() string

func (*LocalizedString) Marshal

func (m *LocalizedString) Marshal() (dAtA []byte, err error)

func (*LocalizedString) MarshalTo

func (m *LocalizedString) MarshalTo(dAtA []byte) (int, error)

func (*LocalizedString) MarshalToSizedBuffer

func (m *LocalizedString) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LocalizedString) ProtoMessage

func (*LocalizedString) ProtoMessage()

func (*LocalizedString) Reset

func (m *LocalizedString) Reset()

func (*LocalizedString) Size

func (m *LocalizedString) Size() (n int)

func (*LocalizedString) String

func (m *LocalizedString) String() string

func (*LocalizedString) Unmarshal

func (m *LocalizedString) Unmarshal(dAtA []byte) error

func (*LocalizedString) XXX_DiscardUnknown

func (m *LocalizedString) XXX_DiscardUnknown()

func (*LocalizedString) XXX_Marshal

func (m *LocalizedString) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocalizedString) XXX_Merge

func (m *LocalizedString) XXX_Merge(src proto.Message)

func (*LocalizedString) XXX_Size

func (m *LocalizedString) XXX_Size() int

func (*LocalizedString) XXX_Unmarshal

func (m *LocalizedString) XXX_Unmarshal(b []byte) error

type ResourceId

type ResourceId struct {
	DeviceId         string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	ResourceLinkHref string `protobuf:"bytes,2,opt,name=resource_link_href,json=resourceLinkHref,proto3" json:"resource_link_href,omitempty"`
}

func (*ResourceId) Descriptor

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

func (*ResourceId) GetDeviceId

func (m *ResourceId) GetDeviceId() string

func (*ResourceId) GetResourceLinkHref

func (m *ResourceId) GetResourceLinkHref() string

func (*ResourceId) Marshal

func (m *ResourceId) Marshal() (dAtA []byte, err error)

func (*ResourceId) MarshalTo

func (m *ResourceId) MarshalTo(dAtA []byte) (int, error)

func (*ResourceId) MarshalToSizedBuffer

func (m *ResourceId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceId) ProtoMessage

func (*ResourceId) ProtoMessage()

func (*ResourceId) Reset

func (m *ResourceId) Reset()

func (*ResourceId) Size

func (m *ResourceId) Size() (n int)

func (*ResourceId) String

func (m *ResourceId) String() string

func (*ResourceId) Unmarshal

func (m *ResourceId) Unmarshal(dAtA []byte) error

func (*ResourceId) XXX_DiscardUnknown

func (m *ResourceId) XXX_DiscardUnknown()

func (*ResourceId) XXX_Marshal

func (m *ResourceId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceId) XXX_Merge

func (m *ResourceId) XXX_Merge(src proto.Message)

func (*ResourceId) XXX_Size

func (m *ResourceId) XXX_Size() int

func (*ResourceId) XXX_Unmarshal

func (m *ResourceId) XXX_Unmarshal(b []byte) error
type ResourceLink struct {
	Href       string   `protobuf:"bytes,1,opt,name=href,proto3" json:"href,omitempty"`
	Types      []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	Interfaces []string `protobuf:"bytes,3,rep,name=interfaces,proto3" json:"interfaces,omitempty"`
	DeviceId   string   `protobuf:"bytes,4,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
}

func (*ResourceLink) Descriptor

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

func (*ResourceLink) GetDeviceId

func (m *ResourceLink) GetDeviceId() string

func (*ResourceLink) GetHref

func (m *ResourceLink) GetHref() string

func (*ResourceLink) GetInterfaces

func (m *ResourceLink) GetInterfaces() []string

func (*ResourceLink) GetTypes

func (m *ResourceLink) GetTypes() []string

func (*ResourceLink) Marshal

func (m *ResourceLink) Marshal() (dAtA []byte, err error)

func (*ResourceLink) MarshalTo

func (m *ResourceLink) MarshalTo(dAtA []byte) (int, error)

func (*ResourceLink) MarshalToSizedBuffer

func (m *ResourceLink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceLink) ProtoMessage

func (*ResourceLink) ProtoMessage()

func (*ResourceLink) Reset

func (m *ResourceLink) Reset()

func (*ResourceLink) Size

func (m *ResourceLink) Size() (n int)

func (*ResourceLink) String

func (m *ResourceLink) String() string

func (*ResourceLink) Unmarshal

func (m *ResourceLink) Unmarshal(dAtA []byte) error

func (*ResourceLink) XXX_DiscardUnknown

func (m *ResourceLink) XXX_DiscardUnknown()

func (*ResourceLink) XXX_Marshal

func (m *ResourceLink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceLink) XXX_Merge

func (m *ResourceLink) XXX_Merge(src proto.Message)

func (*ResourceLink) XXX_Size

func (m *ResourceLink) XXX_Size() int

func (*ResourceLink) XXX_Unmarshal

func (m *ResourceLink) XXX_Unmarshal(b []byte) error

type ResourceValue

type ResourceValue struct {
	ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Types      []string    `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	Content    *Content    `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
}

func (*ResourceValue) Descriptor

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

func (*ResourceValue) GetContent

func (m *ResourceValue) GetContent() *Content

func (*ResourceValue) GetResourceId

func (m *ResourceValue) GetResourceId() *ResourceId

func (*ResourceValue) GetTypes

func (m *ResourceValue) GetTypes() []string

func (*ResourceValue) Marshal

func (m *ResourceValue) Marshal() (dAtA []byte, err error)

func (*ResourceValue) MarshalTo

func (m *ResourceValue) MarshalTo(dAtA []byte) (int, error)

func (*ResourceValue) MarshalToSizedBuffer

func (m *ResourceValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceValue) ProtoMessage

func (*ResourceValue) ProtoMessage()

func (*ResourceValue) Reset

func (m *ResourceValue) Reset()

func (*ResourceValue) Size

func (m *ResourceValue) Size() (n int)

func (*ResourceValue) String

func (m *ResourceValue) String() string

func (*ResourceValue) Unmarshal

func (m *ResourceValue) Unmarshal(dAtA []byte) error

func (*ResourceValue) XXX_DiscardUnknown

func (m *ResourceValue) XXX_DiscardUnknown()

func (*ResourceValue) XXX_Marshal

func (m *ResourceValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceValue) XXX_Merge

func (m *ResourceValue) XXX_Merge(src proto.Message)

func (*ResourceValue) XXX_Size

func (m *ResourceValue) XXX_Size() int

func (*ResourceValue) XXX_Unmarshal

func (m *ResourceValue) XXX_Unmarshal(b []byte) error

type RetrieveResourceFromDeviceRequest

type RetrieveResourceFromDeviceRequest struct {
	ResourceId        *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceInterface string      `protobuf:"bytes,2,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"`
}

RetrieveResourceFromDeviceRequest retrieve value from device

func (*RetrieveResourceFromDeviceRequest) Descriptor

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

func (*RetrieveResourceFromDeviceRequest) GetResourceId

func (m *RetrieveResourceFromDeviceRequest) GetResourceId() *ResourceId

func (*RetrieveResourceFromDeviceRequest) GetResourceInterface

func (m *RetrieveResourceFromDeviceRequest) GetResourceInterface() string

func (*RetrieveResourceFromDeviceRequest) Marshal

func (m *RetrieveResourceFromDeviceRequest) Marshal() (dAtA []byte, err error)

func (*RetrieveResourceFromDeviceRequest) MarshalTo

func (m *RetrieveResourceFromDeviceRequest) MarshalTo(dAtA []byte) (int, error)

func (*RetrieveResourceFromDeviceRequest) MarshalToSizedBuffer

func (m *RetrieveResourceFromDeviceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RetrieveResourceFromDeviceRequest) ProtoMessage

func (*RetrieveResourceFromDeviceRequest) ProtoMessage()

func (*RetrieveResourceFromDeviceRequest) Reset

func (*RetrieveResourceFromDeviceRequest) Size

func (m *RetrieveResourceFromDeviceRequest) Size() (n int)

func (*RetrieveResourceFromDeviceRequest) String

func (*RetrieveResourceFromDeviceRequest) Unmarshal

func (m *RetrieveResourceFromDeviceRequest) Unmarshal(dAtA []byte) error

func (*RetrieveResourceFromDeviceRequest) XXX_DiscardUnknown

func (m *RetrieveResourceFromDeviceRequest) XXX_DiscardUnknown()

func (*RetrieveResourceFromDeviceRequest) XXX_Marshal

func (m *RetrieveResourceFromDeviceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetrieveResourceFromDeviceRequest) XXX_Merge

func (*RetrieveResourceFromDeviceRequest) XXX_Size

func (m *RetrieveResourceFromDeviceRequest) XXX_Size() int

func (*RetrieveResourceFromDeviceRequest) XXX_Unmarshal

func (m *RetrieveResourceFromDeviceRequest) XXX_Unmarshal(b []byte) error

type RetrieveResourceFromDeviceResponse

type RetrieveResourceFromDeviceResponse struct {
	Content *Content `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
}

func (*RetrieveResourceFromDeviceResponse) Descriptor

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

func (*RetrieveResourceFromDeviceResponse) GetContent

func (*RetrieveResourceFromDeviceResponse) Marshal

func (m *RetrieveResourceFromDeviceResponse) Marshal() (dAtA []byte, err error)

func (*RetrieveResourceFromDeviceResponse) MarshalTo

func (m *RetrieveResourceFromDeviceResponse) MarshalTo(dAtA []byte) (int, error)

func (*RetrieveResourceFromDeviceResponse) MarshalToSizedBuffer

func (m *RetrieveResourceFromDeviceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RetrieveResourceFromDeviceResponse) ProtoMessage

func (*RetrieveResourceFromDeviceResponse) ProtoMessage()

func (*RetrieveResourceFromDeviceResponse) Reset

func (*RetrieveResourceFromDeviceResponse) Size

func (*RetrieveResourceFromDeviceResponse) String

func (*RetrieveResourceFromDeviceResponse) Unmarshal

func (m *RetrieveResourceFromDeviceResponse) Unmarshal(dAtA []byte) error

func (*RetrieveResourceFromDeviceResponse) XXX_DiscardUnknown

func (m *RetrieveResourceFromDeviceResponse) XXX_DiscardUnknown()

func (*RetrieveResourceFromDeviceResponse) XXX_Marshal

func (m *RetrieveResourceFromDeviceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetrieveResourceFromDeviceResponse) XXX_Merge

func (*RetrieveResourceFromDeviceResponse) XXX_Size

func (*RetrieveResourceFromDeviceResponse) XXX_Unmarshal

func (m *RetrieveResourceFromDeviceResponse) XXX_Unmarshal(b []byte) error

type RetrieveResourcesValuesRequest

type RetrieveResourcesValuesRequest struct {
	ResourceIdsFilter []*ResourceId `protobuf:"bytes,1,rep,name=resource_ids_filter,json=resourceIdsFilter,proto3" json:"resource_ids_filter,omitempty"`
	DeviceIdsFilter   []string      `protobuf:"bytes,2,rep,name=device_ids_filter,json=deviceIdsFilter,proto3" json:"device_ids_filter,omitempty"`
	TypeFilter        []string      `protobuf:"bytes,3,rep,name=type_filter,json=typeFilter,proto3" json:"type_filter,omitempty"`
}

RetrieveResourcesValuesRequest get values from resource-shadow

func (*RetrieveResourcesValuesRequest) Descriptor

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

func (*RetrieveResourcesValuesRequest) GetDeviceIdsFilter

func (m *RetrieveResourcesValuesRequest) GetDeviceIdsFilter() []string

func (*RetrieveResourcesValuesRequest) GetResourceIdsFilter

func (m *RetrieveResourcesValuesRequest) GetResourceIdsFilter() []*ResourceId

func (*RetrieveResourcesValuesRequest) GetTypeFilter

func (m *RetrieveResourcesValuesRequest) GetTypeFilter() []string

func (*RetrieveResourcesValuesRequest) Marshal

func (m *RetrieveResourcesValuesRequest) Marshal() (dAtA []byte, err error)

func (*RetrieveResourcesValuesRequest) MarshalTo

func (m *RetrieveResourcesValuesRequest) MarshalTo(dAtA []byte) (int, error)

func (*RetrieveResourcesValuesRequest) MarshalToSizedBuffer

func (m *RetrieveResourcesValuesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RetrieveResourcesValuesRequest) ProtoMessage

func (*RetrieveResourcesValuesRequest) ProtoMessage()

func (*RetrieveResourcesValuesRequest) Reset

func (m *RetrieveResourcesValuesRequest) Reset()

func (*RetrieveResourcesValuesRequest) Size

func (m *RetrieveResourcesValuesRequest) Size() (n int)

func (*RetrieveResourcesValuesRequest) String

func (*RetrieveResourcesValuesRequest) Unmarshal

func (m *RetrieveResourcesValuesRequest) Unmarshal(dAtA []byte) error

func (*RetrieveResourcesValuesRequest) XXX_DiscardUnknown

func (m *RetrieveResourcesValuesRequest) XXX_DiscardUnknown()

func (*RetrieveResourcesValuesRequest) XXX_Marshal

func (m *RetrieveResourcesValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetrieveResourcesValuesRequest) XXX_Merge

func (m *RetrieveResourcesValuesRequest) XXX_Merge(src proto.Message)

func (*RetrieveResourcesValuesRequest) XXX_Size

func (m *RetrieveResourcesValuesRequest) XXX_Size() int

func (*RetrieveResourcesValuesRequest) XXX_Unmarshal

func (m *RetrieveResourcesValuesRequest) XXX_Unmarshal(b []byte) error

type SubscribeForEvents

type SubscribeForEvents struct {
	// Types that are valid to be assigned to FilterBy:
	//	*SubscribeForEvents_DevicesEvent
	//	*SubscribeForEvents_DeviceEvent
	//	*SubscribeForEvents_ResourceEvent
	//	*SubscribeForEvents_CancelSubscription_
	FilterBy isSubscribeForEvents_FilterBy `protobuf_oneof:"filter_by"`
	Token    string                        `protobuf:"bytes,101,opt,name=token,proto3" json:"token,omitempty"`
}

func (*SubscribeForEvents) Descriptor

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

func (*SubscribeForEvents) GetCancelSubscription

func (m *SubscribeForEvents) GetCancelSubscription() *SubscribeForEvents_CancelSubscription

func (*SubscribeForEvents) GetDeviceEvent

func (*SubscribeForEvents) GetDevicesEvent

func (*SubscribeForEvents) GetFilterBy

func (m *SubscribeForEvents) GetFilterBy() isSubscribeForEvents_FilterBy

func (*SubscribeForEvents) GetResourceEvent

func (*SubscribeForEvents) GetToken

func (m *SubscribeForEvents) GetToken() string

func (*SubscribeForEvents) Marshal

func (m *SubscribeForEvents) Marshal() (dAtA []byte, err error)

func (*SubscribeForEvents) MarshalTo

func (m *SubscribeForEvents) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents) MarshalToSizedBuffer

func (m *SubscribeForEvents) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents) ProtoMessage

func (*SubscribeForEvents) ProtoMessage()

func (*SubscribeForEvents) Reset

func (m *SubscribeForEvents) Reset()

func (*SubscribeForEvents) Size

func (m *SubscribeForEvents) Size() (n int)

func (*SubscribeForEvents) String

func (m *SubscribeForEvents) String() string

func (*SubscribeForEvents) Unmarshal

func (m *SubscribeForEvents) Unmarshal(dAtA []byte) error

func (*SubscribeForEvents) XXX_DiscardUnknown

func (m *SubscribeForEvents) XXX_DiscardUnknown()

func (*SubscribeForEvents) XXX_Marshal

func (m *SubscribeForEvents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeForEvents) XXX_Merge

func (m *SubscribeForEvents) XXX_Merge(src proto.Message)

func (*SubscribeForEvents) XXX_OneofWrappers

func (*SubscribeForEvents) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubscribeForEvents) XXX_Size

func (m *SubscribeForEvents) XXX_Size() int

func (*SubscribeForEvents) XXX_Unmarshal

func (m *SubscribeForEvents) XXX_Unmarshal(b []byte) error

type SubscribeForEvents_CancelSubscription

type SubscribeForEvents_CancelSubscription struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
}

func (*SubscribeForEvents_CancelSubscription) Descriptor

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

func (*SubscribeForEvents_CancelSubscription) GetSubscriptionId

func (m *SubscribeForEvents_CancelSubscription) GetSubscriptionId() string

func (*SubscribeForEvents_CancelSubscription) Marshal

func (m *SubscribeForEvents_CancelSubscription) Marshal() (dAtA []byte, err error)

func (*SubscribeForEvents_CancelSubscription) MarshalTo

func (m *SubscribeForEvents_CancelSubscription) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_CancelSubscription) MarshalToSizedBuffer

func (m *SubscribeForEvents_CancelSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_CancelSubscription) ProtoMessage

func (*SubscribeForEvents_CancelSubscription) ProtoMessage()

func (*SubscribeForEvents_CancelSubscription) Reset

func (*SubscribeForEvents_CancelSubscription) Size

func (*SubscribeForEvents_CancelSubscription) String

func (*SubscribeForEvents_CancelSubscription) Unmarshal

func (m *SubscribeForEvents_CancelSubscription) Unmarshal(dAtA []byte) error

func (*SubscribeForEvents_CancelSubscription) XXX_DiscardUnknown

func (m *SubscribeForEvents_CancelSubscription) XXX_DiscardUnknown()

func (*SubscribeForEvents_CancelSubscription) XXX_Marshal

func (m *SubscribeForEvents_CancelSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeForEvents_CancelSubscription) XXX_Merge

func (*SubscribeForEvents_CancelSubscription) XXX_Size

func (*SubscribeForEvents_CancelSubscription) XXX_Unmarshal

func (m *SubscribeForEvents_CancelSubscription) XXX_Unmarshal(b []byte) error

type SubscribeForEvents_CancelSubscription_

type SubscribeForEvents_CancelSubscription_ struct {
	CancelSubscription *SubscribeForEvents_CancelSubscription `protobuf:"bytes,5,opt,name=cancel_subscription,json=cancelSubscription,proto3,oneof" json:"cancel_subscription,omitempty"`
}

func (*SubscribeForEvents_CancelSubscription_) MarshalTo

func (m *SubscribeForEvents_CancelSubscription_) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_CancelSubscription_) MarshalToSizedBuffer

func (m *SubscribeForEvents_CancelSubscription_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_CancelSubscription_) Size

type SubscribeForEvents_DeviceEvent

type SubscribeForEvents_DeviceEvent struct {
	DeviceEvent *SubscribeForEvents_DeviceEventFilter `protobuf:"bytes,2,opt,name=device_event,json=deviceEvent,proto3,oneof" json:"device_event,omitempty"`
}

func (*SubscribeForEvents_DeviceEvent) MarshalTo

func (m *SubscribeForEvents_DeviceEvent) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_DeviceEvent) MarshalToSizedBuffer

func (m *SubscribeForEvents_DeviceEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_DeviceEvent) Size

func (m *SubscribeForEvents_DeviceEvent) Size() (n int)

type SubscribeForEvents_DeviceEventFilter

type SubscribeForEvents_DeviceEventFilter struct {
	DeviceId     string                                       `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	FilterEvents []SubscribeForEvents_DeviceEventFilter_Event `` /* 178-byte string literal not displayed */
}

func (*SubscribeForEvents_DeviceEventFilter) Descriptor

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

func (*SubscribeForEvents_DeviceEventFilter) GetDeviceId

func (*SubscribeForEvents_DeviceEventFilter) GetFilterEvents

func (*SubscribeForEvents_DeviceEventFilter) Marshal

func (m *SubscribeForEvents_DeviceEventFilter) Marshal() (dAtA []byte, err error)

func (*SubscribeForEvents_DeviceEventFilter) MarshalTo

func (m *SubscribeForEvents_DeviceEventFilter) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_DeviceEventFilter) MarshalToSizedBuffer

func (m *SubscribeForEvents_DeviceEventFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_DeviceEventFilter) ProtoMessage

func (*SubscribeForEvents_DeviceEventFilter) ProtoMessage()

func (*SubscribeForEvents_DeviceEventFilter) Reset

func (*SubscribeForEvents_DeviceEventFilter) Size

func (*SubscribeForEvents_DeviceEventFilter) String

func (*SubscribeForEvents_DeviceEventFilter) Unmarshal

func (m *SubscribeForEvents_DeviceEventFilter) Unmarshal(dAtA []byte) error

func (*SubscribeForEvents_DeviceEventFilter) XXX_DiscardUnknown

func (m *SubscribeForEvents_DeviceEventFilter) XXX_DiscardUnknown()

func (*SubscribeForEvents_DeviceEventFilter) XXX_Marshal

func (m *SubscribeForEvents_DeviceEventFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeForEvents_DeviceEventFilter) XXX_Merge

func (*SubscribeForEvents_DeviceEventFilter) XXX_Size

func (*SubscribeForEvents_DeviceEventFilter) XXX_Unmarshal

func (m *SubscribeForEvents_DeviceEventFilter) XXX_Unmarshal(b []byte) error

type SubscribeForEvents_DeviceEventFilter_Event

type SubscribeForEvents_DeviceEventFilter_Event int32
const (
	SubscribeForEvents_DeviceEventFilter_RESOURCE_PUBLISHED   SubscribeForEvents_DeviceEventFilter_Event = 0
	SubscribeForEvents_DeviceEventFilter_RESOURCE_UNPUBLISHED SubscribeForEvents_DeviceEventFilter_Event = 1
)

func (SubscribeForEvents_DeviceEventFilter_Event) EnumDescriptor

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

func (SubscribeForEvents_DeviceEventFilter_Event) String

type SubscribeForEvents_DevicesEvent

type SubscribeForEvents_DevicesEvent struct {
	DevicesEvent *SubscribeForEvents_DevicesEventFilter `protobuf:"bytes,1,opt,name=devices_event,json=devicesEvent,proto3,oneof" json:"devices_event,omitempty"`
}

func (*SubscribeForEvents_DevicesEvent) MarshalTo

func (m *SubscribeForEvents_DevicesEvent) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_DevicesEvent) MarshalToSizedBuffer

func (m *SubscribeForEvents_DevicesEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_DevicesEvent) Size

func (m *SubscribeForEvents_DevicesEvent) Size() (n int)

type SubscribeForEvents_DevicesEventFilter

type SubscribeForEvents_DevicesEventFilter struct {
	FilterEvents []SubscribeForEvents_DevicesEventFilter_Event `` /* 179-byte string literal not displayed */
}

func (*SubscribeForEvents_DevicesEventFilter) Descriptor

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

func (*SubscribeForEvents_DevicesEventFilter) GetFilterEvents

func (*SubscribeForEvents_DevicesEventFilter) Marshal

func (m *SubscribeForEvents_DevicesEventFilter) Marshal() (dAtA []byte, err error)

func (*SubscribeForEvents_DevicesEventFilter) MarshalTo

func (m *SubscribeForEvents_DevicesEventFilter) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_DevicesEventFilter) MarshalToSizedBuffer

func (m *SubscribeForEvents_DevicesEventFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_DevicesEventFilter) ProtoMessage

func (*SubscribeForEvents_DevicesEventFilter) ProtoMessage()

func (*SubscribeForEvents_DevicesEventFilter) Reset

func (*SubscribeForEvents_DevicesEventFilter) Size

func (*SubscribeForEvents_DevicesEventFilter) String

func (*SubscribeForEvents_DevicesEventFilter) Unmarshal

func (m *SubscribeForEvents_DevicesEventFilter) Unmarshal(dAtA []byte) error

func (*SubscribeForEvents_DevicesEventFilter) XXX_DiscardUnknown

func (m *SubscribeForEvents_DevicesEventFilter) XXX_DiscardUnknown()

func (*SubscribeForEvents_DevicesEventFilter) XXX_Marshal

func (m *SubscribeForEvents_DevicesEventFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeForEvents_DevicesEventFilter) XXX_Merge

func (*SubscribeForEvents_DevicesEventFilter) XXX_Size

func (*SubscribeForEvents_DevicesEventFilter) XXX_Unmarshal

func (m *SubscribeForEvents_DevicesEventFilter) XXX_Unmarshal(b []byte) error

type SubscribeForEvents_DevicesEventFilter_Event

type SubscribeForEvents_DevicesEventFilter_Event int32
const (
	SubscribeForEvents_DevicesEventFilter_REGISTERED   SubscribeForEvents_DevicesEventFilter_Event = 0
	SubscribeForEvents_DevicesEventFilter_UNREGISTERED SubscribeForEvents_DevicesEventFilter_Event = 1
	SubscribeForEvents_DevicesEventFilter_ONLINE       SubscribeForEvents_DevicesEventFilter_Event = 2
	SubscribeForEvents_DevicesEventFilter_OFFLINE      SubscribeForEvents_DevicesEventFilter_Event = 3
)

func (SubscribeForEvents_DevicesEventFilter_Event) EnumDescriptor

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

func (SubscribeForEvents_DevicesEventFilter_Event) String

type SubscribeForEvents_ResourceEvent

type SubscribeForEvents_ResourceEvent struct {
	ResourceEvent *SubscribeForEvents_ResourceEventFilter `protobuf:"bytes,3,opt,name=resource_event,json=resourceEvent,proto3,oneof" json:"resource_event,omitempty"`
}

func (*SubscribeForEvents_ResourceEvent) MarshalTo

func (m *SubscribeForEvents_ResourceEvent) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_ResourceEvent) MarshalToSizedBuffer

func (m *SubscribeForEvents_ResourceEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_ResourceEvent) Size

func (m *SubscribeForEvents_ResourceEvent) Size() (n int)

type SubscribeForEvents_ResourceEventFilter

type SubscribeForEvents_ResourceEventFilter struct {
	ResourceId   *ResourceId                                    `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	FilterEvents []SubscribeForEvents_ResourceEventFilter_Event `` /* 180-byte string literal not displayed */
}

func (*SubscribeForEvents_ResourceEventFilter) Descriptor

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

func (*SubscribeForEvents_ResourceEventFilter) GetFilterEvents

func (*SubscribeForEvents_ResourceEventFilter) GetResourceId

func (*SubscribeForEvents_ResourceEventFilter) Marshal

func (m *SubscribeForEvents_ResourceEventFilter) Marshal() (dAtA []byte, err error)

func (*SubscribeForEvents_ResourceEventFilter) MarshalTo

func (m *SubscribeForEvents_ResourceEventFilter) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeForEvents_ResourceEventFilter) MarshalToSizedBuffer

func (m *SubscribeForEvents_ResourceEventFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeForEvents_ResourceEventFilter) ProtoMessage

func (*SubscribeForEvents_ResourceEventFilter) Reset

func (*SubscribeForEvents_ResourceEventFilter) Size

func (*SubscribeForEvents_ResourceEventFilter) String

func (*SubscribeForEvents_ResourceEventFilter) Unmarshal

func (m *SubscribeForEvents_ResourceEventFilter) Unmarshal(dAtA []byte) error

func (*SubscribeForEvents_ResourceEventFilter) XXX_DiscardUnknown

func (m *SubscribeForEvents_ResourceEventFilter) XXX_DiscardUnknown()

func (*SubscribeForEvents_ResourceEventFilter) XXX_Marshal

func (m *SubscribeForEvents_ResourceEventFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeForEvents_ResourceEventFilter) XXX_Merge

func (*SubscribeForEvents_ResourceEventFilter) XXX_Size

func (*SubscribeForEvents_ResourceEventFilter) XXX_Unmarshal

func (m *SubscribeForEvents_ResourceEventFilter) XXX_Unmarshal(b []byte) error

type SubscribeForEvents_ResourceEventFilter_Event

type SubscribeForEvents_ResourceEventFilter_Event int32
const (
	SubscribeForEvents_ResourceEventFilter_CONTENT_CHANGED SubscribeForEvents_ResourceEventFilter_Event = 0
)

func (SubscribeForEvents_ResourceEventFilter_Event) EnumDescriptor

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

func (SubscribeForEvents_ResourceEventFilter_Event) String

type UnimplementedGrpcGatewayServer

type UnimplementedGrpcGatewayServer struct {
}

UnimplementedGrpcGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedGrpcGatewayServer) GetDevices

func (*UnimplementedGrpcGatewayServer) RetrieveResourceFromDevice

func (*UnimplementedGrpcGatewayServer) RetrieveResourcesValues

func (*UnimplementedGrpcGatewayServer) SubscribeForEvents

func (*UnimplementedGrpcGatewayServer) UpdateResourcesValues

type UpdateResourceValuesRequest

type UpdateResourceValuesRequest 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"`
	ResourceInterface string      `protobuf:"bytes,3,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"`
}

func (*UpdateResourceValuesRequest) Descriptor

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

func (*UpdateResourceValuesRequest) GetContent

func (m *UpdateResourceValuesRequest) GetContent() *Content

func (*UpdateResourceValuesRequest) GetResourceId

func (m *UpdateResourceValuesRequest) GetResourceId() *ResourceId

func (*UpdateResourceValuesRequest) GetResourceInterface

func (m *UpdateResourceValuesRequest) GetResourceInterface() string

func (*UpdateResourceValuesRequest) Marshal

func (m *UpdateResourceValuesRequest) Marshal() (dAtA []byte, err error)

func (*UpdateResourceValuesRequest) MarshalTo

func (m *UpdateResourceValuesRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateResourceValuesRequest) MarshalToSizedBuffer

func (m *UpdateResourceValuesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateResourceValuesRequest) ProtoMessage

func (*UpdateResourceValuesRequest) ProtoMessage()

func (*UpdateResourceValuesRequest) Reset

func (m *UpdateResourceValuesRequest) Reset()

func (*UpdateResourceValuesRequest) Size

func (m *UpdateResourceValuesRequest) Size() (n int)

func (*UpdateResourceValuesRequest) String

func (m *UpdateResourceValuesRequest) String() string

func (*UpdateResourceValuesRequest) Unmarshal

func (m *UpdateResourceValuesRequest) Unmarshal(dAtA []byte) error

func (*UpdateResourceValuesRequest) XXX_DiscardUnknown

func (m *UpdateResourceValuesRequest) XXX_DiscardUnknown()

func (*UpdateResourceValuesRequest) XXX_Marshal

func (m *UpdateResourceValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateResourceValuesRequest) XXX_Merge

func (m *UpdateResourceValuesRequest) XXX_Merge(src proto.Message)

func (*UpdateResourceValuesRequest) XXX_Size

func (m *UpdateResourceValuesRequest) XXX_Size() int

func (*UpdateResourceValuesRequest) XXX_Unmarshal

func (m *UpdateResourceValuesRequest) XXX_Unmarshal(b []byte) error

type UpdateResourceValuesResponse

type UpdateResourceValuesResponse struct {
	Content *Content `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
}

func (*UpdateResourceValuesResponse) Descriptor

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

func (*UpdateResourceValuesResponse) GetContent

func (m *UpdateResourceValuesResponse) GetContent() *Content

func (*UpdateResourceValuesResponse) Marshal

func (m *UpdateResourceValuesResponse) Marshal() (dAtA []byte, err error)

func (*UpdateResourceValuesResponse) MarshalTo

func (m *UpdateResourceValuesResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateResourceValuesResponse) MarshalToSizedBuffer

func (m *UpdateResourceValuesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateResourceValuesResponse) ProtoMessage

func (*UpdateResourceValuesResponse) ProtoMessage()

func (*UpdateResourceValuesResponse) Reset

func (m *UpdateResourceValuesResponse) Reset()

func (*UpdateResourceValuesResponse) Size

func (m *UpdateResourceValuesResponse) Size() (n int)

func (*UpdateResourceValuesResponse) String

func (*UpdateResourceValuesResponse) Unmarshal

func (m *UpdateResourceValuesResponse) Unmarshal(dAtA []byte) error

func (*UpdateResourceValuesResponse) XXX_DiscardUnknown

func (m *UpdateResourceValuesResponse) XXX_DiscardUnknown()

func (*UpdateResourceValuesResponse) XXX_Marshal

func (m *UpdateResourceValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateResourceValuesResponse) XXX_Merge

func (m *UpdateResourceValuesResponse) XXX_Merge(src proto.Message)

func (*UpdateResourceValuesResponse) XXX_Size

func (m *UpdateResourceValuesResponse) XXX_Size() int

func (*UpdateResourceValuesResponse) XXX_Unmarshal

func (m *UpdateResourceValuesResponse) XXX_Unmarshal(b []byte) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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