pb

package
v1.0.0-rc.4 Latest Latest
Warning

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

Go to latest
Published: Sep 18, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthClientConfiguration        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClientConfiguration          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupClientConfiguration = fmt.Errorf("proto: unexpected end of group")
)
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 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",
}
View Source
var 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,
}
View Source
var SubscribeForEvents_DeviceEventFilter_Event_name = map[int32]string{
	0: "RESOURCE_PUBLISHED",
	1: "RESOURCE_UNPUBLISHED",
	2: "RESOURCE_UPDATE_PENDING",
	3: "RESOURCE_UPDATED",
	4: "RESOURCE_RETRIEVE_PENDING",
	5: "RESOURCE_RETRIEVED",
}
View Source
var SubscribeForEvents_DeviceEventFilter_Event_value = map[string]int32{
	"RESOURCE_PUBLISHED":        0,
	"RESOURCE_UNPUBLISHED":      1,
	"RESOURCE_UPDATE_PENDING":   2,
	"RESOURCE_UPDATED":          3,
	"RESOURCE_RETRIEVE_PENDING": 4,
	"RESOURCE_RETRIEVED":        5,
}
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)

func RegisterHandlerGrpcGateway

func RegisterHandlerGrpcGateway(reg grpchan.ServiceRegistry, srv GrpcGatewayServer)

Types

type ClientConfigurationRequest

type ClientConfigurationRequest struct {
}

func (*ClientConfigurationRequest) Descriptor

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

func (*ClientConfigurationRequest) Marshal

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

func (*ClientConfigurationRequest) MarshalTo

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

func (*ClientConfigurationRequest) MarshalToSizedBuffer

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

func (*ClientConfigurationRequest) ProtoMessage

func (*ClientConfigurationRequest) ProtoMessage()

func (*ClientConfigurationRequest) Reset

func (m *ClientConfigurationRequest) Reset()

func (*ClientConfigurationRequest) Size

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

func (*ClientConfigurationRequest) String

func (m *ClientConfigurationRequest) String() string

func (*ClientConfigurationRequest) Unmarshal

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

func (*ClientConfigurationRequest) XXX_DiscardUnknown

func (m *ClientConfigurationRequest) XXX_DiscardUnknown()

func (*ClientConfigurationRequest) XXX_Marshal

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

func (*ClientConfigurationRequest) XXX_Merge

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

func (*ClientConfigurationRequest) XXX_Size

func (m *ClientConfigurationRequest) XXX_Size() int

func (*ClientConfigurationRequest) XXX_Unmarshal

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

type ClientConfigurationResponse

type ClientConfigurationResponse struct {
	AccessTokenUrl              string `protobuf:"bytes,1,opt,name=access_token_url,json=accessTokenUrl,proto3" json:"access_token_url,omitempty"`
	AuthCodeUrl                 string `protobuf:"bytes,2,opt,name=auth_code_url,json=authCodeUrl,proto3" json:"auth_code_url,omitempty"`
	JwtClaimOwnerId             string `protobuf:"bytes,3,opt,name=jwt_claim_owner_id,json=jwtClaimOwnerId,proto3" json:"jwt_claim_owner_id,omitempty"`
	SigningServerAddress        string `protobuf:"bytes,4,opt,name=signing_server_address,json=signingServerAddress,proto3" json:"signing_server_address,omitempty"`
	CloudId                     string `protobuf:"bytes,5,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	CloudUrl                    string `protobuf:"bytes,6,opt,name=cloud_url,json=cloudUrl,proto3" json:"cloud_url,omitempty"`
	CloudAuthorizationProvider  string `` /* 141-byte string literal not displayed */
	CloudCertificateAuthorities string `` /* 144-byte string literal not displayed */
}

func (*ClientConfigurationResponse) Descriptor

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

func (*ClientConfigurationResponse) GetAccessTokenUrl

func (m *ClientConfigurationResponse) GetAccessTokenUrl() string

func (*ClientConfigurationResponse) GetAuthCodeUrl

func (m *ClientConfigurationResponse) GetAuthCodeUrl() string

func (*ClientConfigurationResponse) GetCloudAuthorizationProvider

func (m *ClientConfigurationResponse) GetCloudAuthorizationProvider() string

func (*ClientConfigurationResponse) GetCloudCertificateAuthorities

func (m *ClientConfigurationResponse) GetCloudCertificateAuthorities() string

func (*ClientConfigurationResponse) GetCloudId

func (m *ClientConfigurationResponse) GetCloudId() string

func (*ClientConfigurationResponse) GetCloudUrl

func (m *ClientConfigurationResponse) GetCloudUrl() string

func (*ClientConfigurationResponse) GetJwtClaimOwnerId

func (m *ClientConfigurationResponse) GetJwtClaimOwnerId() string

func (*ClientConfigurationResponse) GetSigningServerAddress

func (m *ClientConfigurationResponse) GetSigningServerAddress() string

func (*ClientConfigurationResponse) Marshal

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

func (*ClientConfigurationResponse) MarshalTo

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

func (*ClientConfigurationResponse) MarshalToSizedBuffer

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

func (*ClientConfigurationResponse) ProtoMessage

func (*ClientConfigurationResponse) ProtoMessage()

func (*ClientConfigurationResponse) Reset

func (m *ClientConfigurationResponse) Reset()

func (*ClientConfigurationResponse) Size

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

func (*ClientConfigurationResponse) String

func (m *ClientConfigurationResponse) String() string

func (*ClientConfigurationResponse) Unmarshal

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

func (*ClientConfigurationResponse) XXX_DiscardUnknown

func (m *ClientConfigurationResponse) XXX_DiscardUnknown()

func (*ClientConfigurationResponse) XXX_Marshal

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

func (*ClientConfigurationResponse) XXX_Merge

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

func (*ClientConfigurationResponse) XXX_Size

func (m *ClientConfigurationResponse) XXX_Size() int

func (*ClientConfigurationResponse) XXX_Unmarshal

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

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 RAContent2Content

func RAContent2Content(s *pbRA.Content) *Content

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"`
	Interfaces       []string           `protobuf:"bytes,7,rep,name=interfaces,proto3" json:"interfaces,omitempty"`
}

func SchemaDeviceToProto

func SchemaDeviceToProto(d *schema.Device) *Device

func (*Device) Descriptor

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

func (*Device) GetId

func (m *Device) GetId() string

func (*Device) GetInterfaces

func (m *Device) GetInterfaces() []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) ToSchema

func (d Device) ToSchema() schema.Device

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

func RAEndpointInformationsToProto

func RAEndpointInformationsToProto(e []*pbRA.EndpointInformation) []*EndpointInformation

func SchemaEndpointsToProto

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

func (*EndpointInformation) Descriptor

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

func (*EndpointInformation) GetEndpoint

func (m *EndpointInformation) GetEndpoint() string

func (*EndpointInformation) GetPriority

func (m *EndpointInformation) GetPriority() int64

func (*EndpointInformation) Marshal

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

func (*EndpointInformation) MarshalTo

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

func (*EndpointInformation) MarshalToSizedBuffer

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

func (*EndpointInformation) ProtoMessage

func (*EndpointInformation) ProtoMessage()

func (*EndpointInformation) Reset

func (m *EndpointInformation) Reset()

func (*EndpointInformation) Size

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

func (*EndpointInformation) String

func (m *EndpointInformation) String() string

func (EndpointInformation) ToRAProto

func (EndpointInformation) ToSchema

func (e EndpointInformation) ToSchema() schema.Endpoint

func (*EndpointInformation) Unmarshal

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

func (*EndpointInformation) XXX_DiscardUnknown

func (m *EndpointInformation) XXX_DiscardUnknown()

func (*EndpointInformation) XXX_Marshal

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

func (*EndpointInformation) XXX_Merge

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

func (*EndpointInformation) XXX_Size

func (m *EndpointInformation) XXX_Size() int

func (*EndpointInformation) XXX_Unmarshal

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

type EndpointInformations

type EndpointInformations []*EndpointInformation

func (EndpointInformations) ToRAProto

func (EndpointInformations) ToSchema

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

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_ResourceChanged_
	//	*Event_OperationProcessed_
	//	*Event_SubscriptionCanceled_
	//	*Event_ResourceUpdatePending_
	//	*Event_ResourceUpdated_
	//	*Event_ResourceRetrievePending_
	//	*Event_ResourceRetrieved_
	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) GetResourceChanged

func (m *Event) GetResourceChanged() *Event_ResourceChanged

func (*Event) GetResourcePublished

func (m *Event) GetResourcePublished() *Event_ResourcePublished

func (*Event) GetResourceRetrievePending

func (m *Event) GetResourceRetrievePending() *Event_ResourceRetrievePending

func (*Event) GetResourceRetrieved

func (m *Event) GetResourceRetrieved() *Event_ResourceRetrieved

func (*Event) GetResourceUnpublished

func (m *Event) GetResourceUnpublished() *Event_ResourceUnpublished

func (*Event) GetResourceUpdatePending

func (m *Event) GetResourceUpdatePending() *Event_ResourceUpdatePending

func (*Event) GetResourceUpdated

func (m *Event) GetResourceUpdated() *Event_ResourceUpdated

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 {
	DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
}

func (*Event_DeviceOffline) Descriptor

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

func (*Event_DeviceOffline) GetDeviceIds

func (m *Event_DeviceOffline) GetDeviceIds() []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 {
	DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
}

func (*Event_DeviceOnline) Descriptor

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

func (*Event_DeviceOnline) GetDeviceIds

func (m *Event_DeviceOnline) GetDeviceIds() []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 {
	DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
}

func (*Event_DeviceRegistered) Descriptor

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

func (*Event_DeviceRegistered) GetDeviceIds

func (m *Event_DeviceRegistered) GetDeviceIds() []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 {
	DeviceIds []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
}

func (*Event_DeviceUnregistered) Descriptor

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

func (*Event_DeviceUnregistered) GetDeviceIds

func (m *Event_DeviceUnregistered) GetDeviceIds() []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"`
	Status     Status      `protobuf:"varint,3,opt,name=status,proto3,enum=ocf.cloud.grpcgateway.pb.Status" json:"status,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) GetStatus

func (m *Event_ResourceChanged) GetStatus() Status

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_ResourceChanged_

type Event_ResourceChanged_ struct {
	ResourceChanged *Event_ResourceChanged `protobuf:"bytes,9,opt,name=resource_changed,json=resourceChanged,proto3,oneof" json:"resource_changed,omitempty"`
}

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_) Size

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

type Event_ResourcePublished

type Event_ResourcePublished struct {
	Links []*ResourceLink `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
}

func (*Event_ResourcePublished) Descriptor

func (*Event_ResourcePublished) Descriptor() ([]byte, []int)
func (m *Event_ResourcePublished) GetLinks() []*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_ResourceRetrievePending

type Event_ResourceRetrievePending 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"`
	CorrelationId     string      `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
}

func (*Event_ResourceRetrievePending) Descriptor

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

func (*Event_ResourceRetrievePending) GetCorrelationId

func (m *Event_ResourceRetrievePending) GetCorrelationId() string

func (*Event_ResourceRetrievePending) GetResourceId

func (m *Event_ResourceRetrievePending) GetResourceId() *ResourceId

func (*Event_ResourceRetrievePending) GetResourceInterface

func (m *Event_ResourceRetrievePending) GetResourceInterface() string

func (*Event_ResourceRetrievePending) Marshal

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

func (*Event_ResourceRetrievePending) MarshalTo

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

func (*Event_ResourceRetrievePending) MarshalToSizedBuffer

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

func (*Event_ResourceRetrievePending) ProtoMessage

func (*Event_ResourceRetrievePending) ProtoMessage()

func (*Event_ResourceRetrievePending) Reset

func (m *Event_ResourceRetrievePending) Reset()

func (*Event_ResourceRetrievePending) Size

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

func (*Event_ResourceRetrievePending) String

func (*Event_ResourceRetrievePending) Unmarshal

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

func (*Event_ResourceRetrievePending) XXX_DiscardUnknown

func (m *Event_ResourceRetrievePending) XXX_DiscardUnknown()

func (*Event_ResourceRetrievePending) XXX_Marshal

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

func (*Event_ResourceRetrievePending) XXX_Merge

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

func (*Event_ResourceRetrievePending) XXX_Size

func (m *Event_ResourceRetrievePending) XXX_Size() int

func (*Event_ResourceRetrievePending) XXX_Unmarshal

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

type Event_ResourceRetrievePending_

type Event_ResourceRetrievePending_ struct {
	ResourceRetrievePending *Event_ResourceRetrievePending `` /* 139-byte string literal not displayed */
}

func (*Event_ResourceRetrievePending_) MarshalTo

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

func (*Event_ResourceRetrievePending_) MarshalToSizedBuffer

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

func (*Event_ResourceRetrievePending_) Size

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

type Event_ResourceRetrieved

type Event_ResourceRetrieved 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"`
	Status        Status      `protobuf:"varint,3,opt,name=status,proto3,enum=ocf.cloud.grpcgateway.pb.Status" json:"status,omitempty"`
	CorrelationId string      `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
}

func (*Event_ResourceRetrieved) Descriptor

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

func (*Event_ResourceRetrieved) GetContent

func (m *Event_ResourceRetrieved) GetContent() *Content

func (*Event_ResourceRetrieved) GetCorrelationId

func (m *Event_ResourceRetrieved) GetCorrelationId() string

func (*Event_ResourceRetrieved) GetResourceId

func (m *Event_ResourceRetrieved) GetResourceId() *ResourceId

func (*Event_ResourceRetrieved) GetStatus

func (m *Event_ResourceRetrieved) GetStatus() Status

func (*Event_ResourceRetrieved) Marshal

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

func (*Event_ResourceRetrieved) MarshalTo

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

func (*Event_ResourceRetrieved) MarshalToSizedBuffer

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

func (*Event_ResourceRetrieved) ProtoMessage

func (*Event_ResourceRetrieved) ProtoMessage()

func (*Event_ResourceRetrieved) Reset

func (m *Event_ResourceRetrieved) Reset()

func (*Event_ResourceRetrieved) Size

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

func (*Event_ResourceRetrieved) String

func (m *Event_ResourceRetrieved) String() string

func (*Event_ResourceRetrieved) Unmarshal

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

func (*Event_ResourceRetrieved) XXX_DiscardUnknown

func (m *Event_ResourceRetrieved) XXX_DiscardUnknown()

func (*Event_ResourceRetrieved) XXX_Marshal

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

func (*Event_ResourceRetrieved) XXX_Merge

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

func (*Event_ResourceRetrieved) XXX_Size

func (m *Event_ResourceRetrieved) XXX_Size() int

func (*Event_ResourceRetrieved) XXX_Unmarshal

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

type Event_ResourceRetrieved_

type Event_ResourceRetrieved_ struct {
	ResourceRetrieved *Event_ResourceRetrieved `protobuf:"bytes,15,opt,name=resource_retrieved,json=resourceRetrieved,proto3,oneof" json:"resource_retrieved,omitempty"`
}

func (*Event_ResourceRetrieved_) MarshalTo

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

func (*Event_ResourceRetrieved_) MarshalToSizedBuffer

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

func (*Event_ResourceRetrieved_) Size

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

type Event_ResourceUnpublished

type Event_ResourceUnpublished struct {
	Links []*ResourceLink `protobuf:"bytes,2,rep,name=links,proto3" json:"links,omitempty"`
}

func (*Event_ResourceUnpublished) Descriptor

func (*Event_ResourceUnpublished) Descriptor() ([]byte, []int)
func (m *Event_ResourceUnpublished) GetLinks() []*ResourceLink

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_ResourceUpdatePending

type Event_ResourceUpdatePending 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"`
	CorrelationId     string      `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
}

func (*Event_ResourceUpdatePending) Descriptor

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

func (*Event_ResourceUpdatePending) GetContent

func (m *Event_ResourceUpdatePending) GetContent() *Content

func (*Event_ResourceUpdatePending) GetCorrelationId

func (m *Event_ResourceUpdatePending) GetCorrelationId() string

func (*Event_ResourceUpdatePending) GetResourceId

func (m *Event_ResourceUpdatePending) GetResourceId() *ResourceId

func (*Event_ResourceUpdatePending) GetResourceInterface

func (m *Event_ResourceUpdatePending) GetResourceInterface() string

func (*Event_ResourceUpdatePending) Marshal

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

func (*Event_ResourceUpdatePending) MarshalTo

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

func (*Event_ResourceUpdatePending) MarshalToSizedBuffer

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

func (*Event_ResourceUpdatePending) ProtoMessage

func (*Event_ResourceUpdatePending) ProtoMessage()

func (*Event_ResourceUpdatePending) Reset

func (m *Event_ResourceUpdatePending) Reset()

func (*Event_ResourceUpdatePending) Size

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

func (*Event_ResourceUpdatePending) String

func (m *Event_ResourceUpdatePending) String() string

func (*Event_ResourceUpdatePending) Unmarshal

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

func (*Event_ResourceUpdatePending) XXX_DiscardUnknown

func (m *Event_ResourceUpdatePending) XXX_DiscardUnknown()

func (*Event_ResourceUpdatePending) XXX_Marshal

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

func (*Event_ResourceUpdatePending) XXX_Merge

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

func (*Event_ResourceUpdatePending) XXX_Size

func (m *Event_ResourceUpdatePending) XXX_Size() int

func (*Event_ResourceUpdatePending) XXX_Unmarshal

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

type Event_ResourceUpdatePending_

type Event_ResourceUpdatePending_ struct {
	ResourceUpdatePending *Event_ResourceUpdatePending `` /* 133-byte string literal not displayed */
}

func (*Event_ResourceUpdatePending_) MarshalTo

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

func (*Event_ResourceUpdatePending_) MarshalToSizedBuffer

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

func (*Event_ResourceUpdatePending_) Size

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

type Event_ResourceUpdated

type Event_ResourceUpdated 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"`
	Status        Status      `protobuf:"varint,3,opt,name=status,proto3,enum=ocf.cloud.grpcgateway.pb.Status" json:"status,omitempty"`
	CorrelationId string      `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
}

func (*Event_ResourceUpdated) Descriptor

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

func (*Event_ResourceUpdated) GetContent

func (m *Event_ResourceUpdated) GetContent() *Content

func (*Event_ResourceUpdated) GetCorrelationId

func (m *Event_ResourceUpdated) GetCorrelationId() string

func (*Event_ResourceUpdated) GetResourceId

func (m *Event_ResourceUpdated) GetResourceId() *ResourceId

func (*Event_ResourceUpdated) GetStatus

func (m *Event_ResourceUpdated) GetStatus() Status

func (*Event_ResourceUpdated) Marshal

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

func (*Event_ResourceUpdated) MarshalTo

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

func (*Event_ResourceUpdated) MarshalToSizedBuffer

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

func (*Event_ResourceUpdated) ProtoMessage

func (*Event_ResourceUpdated) ProtoMessage()

func (*Event_ResourceUpdated) Reset

func (m *Event_ResourceUpdated) Reset()

func (*Event_ResourceUpdated) Size

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

func (*Event_ResourceUpdated) String

func (m *Event_ResourceUpdated) String() string

func (*Event_ResourceUpdated) Unmarshal

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

func (*Event_ResourceUpdated) XXX_DiscardUnknown

func (m *Event_ResourceUpdated) XXX_DiscardUnknown()

func (*Event_ResourceUpdated) XXX_Marshal

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

func (*Event_ResourceUpdated) XXX_Merge

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

func (*Event_ResourceUpdated) XXX_Size

func (m *Event_ResourceUpdated) XXX_Size() int

func (*Event_ResourceUpdated) XXX_Unmarshal

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

type Event_ResourceUpdated_

type Event_ResourceUpdated_ struct {
	ResourceUpdated *Event_ResourceUpdated `protobuf:"bytes,13,opt,name=resource_updated,json=resourceUpdated,proto3,oneof" json:"resource_updated,omitempty"`
}

func (*Event_ResourceUpdated_) MarshalTo

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

func (*Event_ResourceUpdated_) MarshalToSizedBuffer

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

func (*Event_ResourceUpdated_) Size

func (m *Event_ResourceUpdated_) 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)
	// Get client configuration
	GetClientConfiguration(ctx context.Context, in *ClientConfigurationRequest, opts ...grpc.CallOption) (*ClientConfigurationResponse, 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 NewGrpcGatewayChannelClient

func NewGrpcGatewayChannelClient(ch grpchan.Channel) 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
	// Get client configuration
	GetClientConfiguration(context.Context, *ClientConfigurationRequest) (*ClientConfigurationResponse, 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 SchemaLocalizedStringToProto

func SchemaLocalizedStringToProto(s schema.LocalizedString) *LocalizedString

func SchemaLocalizedStringsToProto

func SchemaLocalizedStringsToProto(s []schema.LocalizedString) []*LocalizedString

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

func (l *LocalizedString) ToSchema() schema.LocalizedString

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 LocalizedStrings

type LocalizedStrings []*LocalizedString

func (LocalizedStrings) ToSchema

func (s LocalizedStrings) ToSchema() []schema.LocalizedString

type Policies

type Policies struct {
	BitFlags int32 `protobuf:"varint,1,opt,name=bit_flags,json=bitFlags,proto3" json:"bit_flags,omitempty"`
}

func SchemaPolicyToProto

func SchemaPolicyToProto(ra *schema.Policy) *Policies

func (*Policies) Descriptor

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

func (*Policies) GetBitFlags

func (m *Policies) GetBitFlags() int32

func (*Policies) Marshal

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

func (*Policies) MarshalTo

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

func (*Policies) MarshalToSizedBuffer

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

func (*Policies) ProtoMessage

func (*Policies) ProtoMessage()

func (*Policies) Reset

func (m *Policies) Reset()

func (*Policies) Size

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

func (*Policies) String

func (m *Policies) String() string

func (*Policies) ToRAProto

func (p *Policies) ToRAProto() *pbRA.Policies

func (*Policies) ToSchema

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

func (*Policies) Unmarshal

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

func (*Policies) XXX_DiscardUnknown

func (m *Policies) XXX_DiscardUnknown()

func (*Policies) XXX_Marshal

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

func (*Policies) XXX_Merge

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

func (*Policies) XXX_Size

func (m *Policies) XXX_Size() int

func (*Policies) XXX_Unmarshal

func (m *Policies) 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"`
	Href     string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
}

func (*ResourceId) Descriptor

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

func (*ResourceId) GetDeviceId

func (m *ResourceId) GetDeviceId() string

func (*ResourceId) GetHref

func (m *ResourceId) GetHref() string

func (*ResourceId) ID

func (r *ResourceId) ID() 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"`
	InstanceId            int64                  `protobuf:"varint,5,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Anchor                string                 `protobuf:"bytes,6,opt,name=anchor,proto3" json:"anchor,omitempty"`
	Policies              *Policies              `protobuf:"bytes,7,opt,name=policies,proto3" json:"policies,omitempty"`
	Title                 string                 `protobuf:"bytes,8,opt,name=title,proto3" json:"title,omitempty"`
	SupportedContentTypes []string               `` /* 126-byte string literal not displayed */
	EndpointInformations  []*EndpointInformation `protobuf:"bytes,10,rep,name=endpoint_informations,json=endpointInformations,proto3" json:"endpoint_informations,omitempty"`
}

func RAResourceToProto

func RAResourceToProto(ra *pbRA.Resource) ResourceLink

func SchemaResourceLinkToProto

func SchemaResourceLinkToProto(ra schema.ResourceLink) ResourceLink

func (*ResourceLink) Descriptor

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

func (*ResourceLink) GetAnchor

func (m *ResourceLink) GetAnchor() string

func (*ResourceLink) GetDeviceId

func (m *ResourceLink) GetDeviceId() string

func (*ResourceLink) GetEndpointInformations

func (m *ResourceLink) GetEndpointInformations() []*EndpointInformation

func (*ResourceLink) GetHref

func (m *ResourceLink) GetHref() string

func (*ResourceLink) GetInstanceId

func (m *ResourceLink) GetInstanceId() int64

func (*ResourceLink) GetInterfaces

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

func (*ResourceLink) GetPolicies

func (m *ResourceLink) GetPolicies() *Policies

func (*ResourceLink) GetSupportedContentTypes

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

func (*ResourceLink) GetTitle

func (m *ResourceLink) GetTitle() 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) ToRAProto

func (l ResourceLink) ToRAProto() pbRA.Resource

func (ResourceLink) ToSchema

func (l ResourceLink) ToSchema() schema.ResourceLink

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"`
	Status     Status      `protobuf:"varint,4,opt,name=status,proto3,enum=ocf.cloud.grpcgateway.pb.Status" json:"status,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) GetStatus

func (m *ResourceValue) GetStatus() Status

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

func RAStatus2Status

func RAStatus2Status(s pbRA.Status) Status

func (Status) EnumDescriptor

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

func (Status) String

func (x Status) String() string

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
	SubscribeForEvents_DeviceEventFilter_RESOURCE_UPDATE_PENDING   SubscribeForEvents_DeviceEventFilter_Event = 2
	SubscribeForEvents_DeviceEventFilter_RESOURCE_UPDATED          SubscribeForEvents_DeviceEventFilter_Event = 3
	SubscribeForEvents_DeviceEventFilter_RESOURCE_RETRIEVE_PENDING SubscribeForEvents_DeviceEventFilter_Event = 4
	SubscribeForEvents_DeviceEventFilter_RESOURCE_RETRIEVED        SubscribeForEvents_DeviceEventFilter_Event = 5
)

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

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"`
	Status  Status   `protobuf:"varint,2,opt,name=status,proto3,enum=ocf.cloud.grpcgateway.pb.Status" json:"status,omitempty"`
}

func (*UpdateResourceValuesResponse) Descriptor

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

func (*UpdateResourceValuesResponse) GetContent

func (m *UpdateResourceValuesResponse) GetContent() *Content

func (*UpdateResourceValuesResponse) GetStatus

func (m *UpdateResourceValuesResponse) GetStatus() Status

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