pb

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 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",
	10: "METHOD_NOT_ALLOWED",
}
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,
	"METHOD_NOT_ALLOWED": 10,
}
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",
	6: "RESOURCE_DELETE_PENDING",
	7: "RESOURCE_DELETED",
}
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,
	"RESOURCE_DELETE_PENDING":   6,
	"RESOURCE_DELETED":          7,
}
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 DeleteResourceRequest added in v1.1.0 

type DeleteResourceRequest struct {
	ResourceId *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
}

func (*DeleteResourceRequest) Descriptor added in v1.1.0 

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

func (*DeleteResourceRequest) GetResourceId added in v1.1.0 

func (m *DeleteResourceRequest) GetResourceId() *ResourceId

func (*DeleteResourceRequest) Marshal added in v1.1.0 

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

func (*DeleteResourceRequest) MarshalTo added in v1.1.0 

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

func (*DeleteResourceRequest) MarshalToSizedBuffer added in v1.1.0 

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

func (*DeleteResourceRequest) ProtoMessage added in v1.1.0 

func (*DeleteResourceRequest) ProtoMessage()

func (*DeleteResourceRequest) Reset added in v1.1.0 

func (m *DeleteResourceRequest) Reset()

func (*DeleteResourceRequest) Size added in v1.1.0 

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

func (*DeleteResourceRequest) String added in v1.1.0 

func (m *DeleteResourceRequest) String() string

func (*DeleteResourceRequest) Unmarshal added in v1.1.0 

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

func (*DeleteResourceRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *DeleteResourceRequest) XXX_DiscardUnknown()

func (*DeleteResourceRequest) XXX_Marshal added in v1.1.0 

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

func (*DeleteResourceRequest) XXX_Merge added in v1.1.0 

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

func (*DeleteResourceRequest) XXX_Size added in v1.1.0 

func (m *DeleteResourceRequest) XXX_Size() int

func (*DeleteResourceRequest) XXX_Unmarshal added in v1.1.0 

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

type DeleteResourceResponse added in v1.1.0 

type DeleteResourceResponse 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 (*DeleteResourceResponse) Descriptor added in v1.1.0 

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

func (*DeleteResourceResponse) GetContent added in v1.1.0 

func (m *DeleteResourceResponse) GetContent() *Content

func (*DeleteResourceResponse) GetStatus added in v1.1.0 

func (m *DeleteResourceResponse) GetStatus() Status

func (*DeleteResourceResponse) Marshal added in v1.1.0 

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

func (*DeleteResourceResponse) MarshalTo added in v1.1.0 

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

func (*DeleteResourceResponse) MarshalToSizedBuffer added in v1.1.0 

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

func (*DeleteResourceResponse) ProtoMessage added in v1.1.0 

func (*DeleteResourceResponse) ProtoMessage()

func (*DeleteResourceResponse) Reset added in v1.1.0 

func (m *DeleteResourceResponse) Reset()

func (*DeleteResourceResponse) Size added in v1.1.0 

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

func (*DeleteResourceResponse) String added in v1.1.0 

func (m *DeleteResourceResponse) String() string

func (*DeleteResourceResponse) Unmarshal added in v1.1.0 

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

func (*DeleteResourceResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *DeleteResourceResponse) XXX_DiscardUnknown()

func (*DeleteResourceResponse) XXX_Marshal added in v1.1.0 

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

func (*DeleteResourceResponse) XXX_Merge added in v1.1.0 

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

func (*DeleteResourceResponse) XXX_Size added in v1.1.0 

func (m *DeleteResourceResponse) XXX_Size() int

func (*DeleteResourceResponse) XXX_Unmarshal added in v1.1.0 

func (m *DeleteResourceResponse) 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"`
	ProtocolIndependentId string             `` /* 126-byte string literal not displayed */
}

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) GetProtocolIndependentId added in v1.0.2 

func (m *Device) GetProtocolIndependentId() 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 (e EndpointInformation) ToRAProto() *pbRA.EndpointInformation

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 (e EndpointInformations) ToRAProto() []*pbRA.EndpointInformation

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_
	//	*Event_ResourceDeletePending_
	//	*Event_ResourceDeleted_
	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) GetResourceDeletePending added in v1.1.0 

func (m *Event) GetResourceDeletePending() *Event_ResourceDeletePending

func (*Event) GetResourceDeleted added in v1.1.0 

func (m *Event) GetResourceDeleted() *Event_ResourceDeleted

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 (m *Event_OperationProcessed) GetErrorStatus() *Event_OperationProcessed_ErrorStatus

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 (m *Event_OperationProcessed_ErrorStatus) GetCode() Event_OperationProcessed_ErrorStatus_Code

func (*Event_OperationProcessed_ErrorStatus) GetMessage 

func (m *Event_OperationProcessed_ErrorStatus) GetMessage() string

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 (m *Event_OperationProcessed_ErrorStatus) Reset()

func (*Event_OperationProcessed_ErrorStatus) Size 

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

func (*Event_OperationProcessed_ErrorStatus) String 

func (m *Event_OperationProcessed_ErrorStatus) String() 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 (m *Event_OperationProcessed_ErrorStatus) XXX_Merge(src proto.Message)

func (*Event_OperationProcessed_ErrorStatus) XXX_Size 

func (m *Event_OperationProcessed_ErrorStatus) XXX_Size() int

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 

func (x Event_OperationProcessed_ErrorStatus_Code) String() 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_ResourceDeletePending added in v1.1.0 

type Event_ResourceDeletePending struct {
	ResourceId    *ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CorrelationId string      `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
}

func (*Event_ResourceDeletePending) Descriptor added in v1.1.0 

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

func (*Event_ResourceDeletePending) GetCorrelationId added in v1.1.0 

func (m *Event_ResourceDeletePending) GetCorrelationId() string

func (*Event_ResourceDeletePending) GetResourceId added in v1.1.0 

func (m *Event_ResourceDeletePending) GetResourceId() *ResourceId

func (*Event_ResourceDeletePending) Marshal added in v1.1.0 

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

func (*Event_ResourceDeletePending) MarshalTo added in v1.1.0 

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

func (*Event_ResourceDeletePending) MarshalToSizedBuffer added in v1.1.0 

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

func (*Event_ResourceDeletePending) ProtoMessage added in v1.1.0 

func (*Event_ResourceDeletePending) ProtoMessage()

func (*Event_ResourceDeletePending) Reset added in v1.1.0 

func (m *Event_ResourceDeletePending) Reset()

func (*Event_ResourceDeletePending) Size added in v1.1.0 

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

func (*Event_ResourceDeletePending) String added in v1.1.0 

func (m *Event_ResourceDeletePending) String() string

func (*Event_ResourceDeletePending) Unmarshal added in v1.1.0 

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

func (*Event_ResourceDeletePending) XXX_DiscardUnknown added in v1.1.0 

func (m *Event_ResourceDeletePending) XXX_DiscardUnknown()

func (*Event_ResourceDeletePending) XXX_Marshal added in v1.1.0 

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

func (*Event_ResourceDeletePending) XXX_Merge added in v1.1.0 

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

func (*Event_ResourceDeletePending) XXX_Size added in v1.1.0 

func (m *Event_ResourceDeletePending) XXX_Size() int

func (*Event_ResourceDeletePending) XXX_Unmarshal added in v1.1.0 

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

type Event_ResourceDeletePending_ added in v1.1.0 

type Event_ResourceDeletePending_ struct {
	ResourceDeletePending *Event_ResourceDeletePending `` /* 133-byte string literal not displayed */
}

func (*Event_ResourceDeletePending_) MarshalTo added in v1.1.0 

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

func (*Event_ResourceDeletePending_) MarshalToSizedBuffer added in v1.1.0 

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

func (*Event_ResourceDeletePending_) Size added in v1.1.0 

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

type Event_ResourceDeleted added in v1.1.0 

type Event_ResourceDeleted 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_ResourceDeleted) Descriptor added in v1.1.0 

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

func (*Event_ResourceDeleted) GetContent added in v1.1.0 

func (m *Event_ResourceDeleted) GetContent() *Content

func (*Event_ResourceDeleted) GetCorrelationId added in v1.1.0 

func (m *Event_ResourceDeleted) GetCorrelationId() string

func (*Event_ResourceDeleted) GetResourceId added in v1.1.0 

func (m *Event_ResourceDeleted) GetResourceId() *ResourceId

func (*Event_ResourceDeleted) GetStatus added in v1.1.0 

func (m *Event_ResourceDeleted) GetStatus() Status

func (*Event_ResourceDeleted) Marshal added in v1.1.0 

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

func (*Event_ResourceDeleted) MarshalTo added in v1.1.0 

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

func (*Event_ResourceDeleted) MarshalToSizedBuffer added in v1.1.0 

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

func (*Event_ResourceDeleted) ProtoMessage added in v1.1.0 

func (*Event_ResourceDeleted) ProtoMessage()

func (*Event_ResourceDeleted) Reset added in v1.1.0 

func (m *Event_ResourceDeleted) Reset()

func (*Event_ResourceDeleted) Size added in v1.1.0 

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

func (*Event_ResourceDeleted) String added in v1.1.0 

func (m *Event_ResourceDeleted) String() string

func (*Event_ResourceDeleted) Unmarshal added in v1.1.0 

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

func (*Event_ResourceDeleted) XXX_DiscardUnknown added in v1.1.0 

func (m *Event_ResourceDeleted) XXX_DiscardUnknown()

func (*Event_ResourceDeleted) XXX_Marshal added in v1.1.0 

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

func (*Event_ResourceDeleted) XXX_Merge added in v1.1.0 

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

func (*Event_ResourceDeleted) XXX_Size added in v1.1.0 

func (m *Event_ResourceDeleted) XXX_Size() int

func (*Event_ResourceDeleted) XXX_Unmarshal added in v1.1.0 

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

type Event_ResourceDeleted_ added in v1.1.0 

type Event_ResourceDeleted_ struct {
	ResourceDeleted *Event_ResourceDeleted `protobuf:"bytes,17,opt,name=resource_deleted,json=resourceDeleted,proto3,oneof" json:"resource_deleted,omitempty"`
}

func (*Event_ResourceDeleted_) MarshalTo added in v1.1.0 

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

func (*Event_ResourceDeleted_) MarshalToSizedBuffer added in v1.1.0 

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

func (*Event_ResourceDeleted_) Size added in v1.1.0 

func (m *Event_ResourceDeleted_) 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 (m *Event_ResourceRetrievePending) String() 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)
	// Delete resource at the device.
	DeleteResource(ctx context.Context, in *DeleteResourceRequest, opts ...grpc.CallOption) (*DeleteResourceResponse, 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

func NewGrpcGatewayClient 

func NewGrpcGatewayClient(cc grpc.ClientConnInterface) 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)
	// Delete resource at the device.
	DeleteResource(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, 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 (m *RetrieveResourceFromDeviceRequest) Reset()

func (*RetrieveResourceFromDeviceRequest) Size 

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

func (*RetrieveResourceFromDeviceRequest) String 

func (m *RetrieveResourceFromDeviceRequest) String() 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 (m *RetrieveResourceFromDeviceRequest) XXX_Merge(src proto.Message)

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 (m *RetrieveResourceFromDeviceResponse) GetContent() *Content

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 (m *RetrieveResourceFromDeviceResponse) Reset()

func (*RetrieveResourceFromDeviceResponse) Size 

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

func (*RetrieveResourceFromDeviceResponse) String 

func (m *RetrieveResourceFromDeviceResponse) String() 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 (m *RetrieveResourceFromDeviceResponse) XXX_Merge(src proto.Message)

func (*RetrieveResourceFromDeviceResponse) XXX_Size 

func (m *RetrieveResourceFromDeviceResponse) XXX_Size() int

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 (m *RetrieveResourcesValuesRequest) String() 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
	Status_METHOD_NOT_ALLOWED Status = 10
)

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 (m *SubscribeForEvents) GetDeviceEvent() *SubscribeForEvents_DeviceEventFilter

func (*SubscribeForEvents) GetDevicesEvent 

func (m *SubscribeForEvents) GetDevicesEvent() *SubscribeForEvents_DevicesEventFilter

func (*SubscribeForEvents) GetFilterBy 

func (m *SubscribeForEvents) GetFilterBy() isSubscribeForEvents_FilterBy

func (*SubscribeForEvents) GetResourceEvent 

func (m *SubscribeForEvents) GetResourceEvent() *SubscribeForEvents_ResourceEventFilter

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 (m *SubscribeForEvents_CancelSubscription) Reset()

func (*SubscribeForEvents_CancelSubscription) Size 

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

func (*SubscribeForEvents_CancelSubscription) String 

func (m *SubscribeForEvents_CancelSubscription) String() 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 (m *SubscribeForEvents_CancelSubscription) XXX_Merge(src proto.Message)

func (*SubscribeForEvents_CancelSubscription) XXX_Size 

func (m *SubscribeForEvents_CancelSubscription) XXX_Size() int

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 

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

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 (m *SubscribeForEvents_DeviceEventFilter) GetDeviceId() string

func (*SubscribeForEvents_DeviceEventFilter) GetFilterEvents 

func (m *SubscribeForEvents_DeviceEventFilter) GetFilterEvents() []SubscribeForEvents_DeviceEventFilter_Event

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 (m *SubscribeForEvents_DeviceEventFilter) Reset()

func (*SubscribeForEvents_DeviceEventFilter) Size 

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

func (*SubscribeForEvents_DeviceEventFilter) String 

func (m *SubscribeForEvents_DeviceEventFilter) String() 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 (m *SubscribeForEvents_DeviceEventFilter) XXX_Merge(src proto.Message)

func (*SubscribeForEvents_DeviceEventFilter) XXX_Size 

func (m *SubscribeForEvents_DeviceEventFilter) XXX_Size() int

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
	SubscribeForEvents_DeviceEventFilter_RESOURCE_DELETE_PENDING   SubscribeForEvents_DeviceEventFilter_Event = 6
	SubscribeForEvents_DeviceEventFilter_RESOURCE_DELETED          SubscribeForEvents_DeviceEventFilter_Event = 7
)

func (SubscribeForEvents_DeviceEventFilter_Event) EnumDescriptor 

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

func (SubscribeForEvents_DeviceEventFilter_Event) String 

func (x SubscribeForEvents_DeviceEventFilter_Event) String() 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 (m *SubscribeForEvents_DevicesEventFilter) GetFilterEvents() []SubscribeForEvents_DevicesEventFilter_Event

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 (m *SubscribeForEvents_DevicesEventFilter) Reset()

func (*SubscribeForEvents_DevicesEventFilter) Size 

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

func (*SubscribeForEvents_DevicesEventFilter) String 

func (m *SubscribeForEvents_DevicesEventFilter) String() 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 (m *SubscribeForEvents_DevicesEventFilter) XXX_Merge(src proto.Message)

func (*SubscribeForEvents_DevicesEventFilter) XXX_Size 

func (m *SubscribeForEvents_DevicesEventFilter) XXX_Size() int

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 

func (x SubscribeForEvents_DevicesEventFilter_Event) String() 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 (m *SubscribeForEvents_ResourceEventFilter) GetFilterEvents() []SubscribeForEvents_ResourceEventFilter_Event

func (*SubscribeForEvents_ResourceEventFilter) GetResourceId 

func (m *SubscribeForEvents_ResourceEventFilter) GetResourceId() *ResourceId

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

func (*SubscribeForEvents_ResourceEventFilter) Reset 

func (m *SubscribeForEvents_ResourceEventFilter) Reset()

func (*SubscribeForEvents_ResourceEventFilter) Size 

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

func (*SubscribeForEvents_ResourceEventFilter) String 

func (m *SubscribeForEvents_ResourceEventFilter) String() 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 (m *SubscribeForEvents_ResourceEventFilter) XXX_Merge(src proto.Message)

func (*SubscribeForEvents_ResourceEventFilter) XXX_Size 

func (m *SubscribeForEvents_ResourceEventFilter) XXX_Size() int

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 

func (x SubscribeForEvents_ResourceEventFilter_Event) String() string

type UnimplementedGrpcGatewayServer 

type UnimplementedGrpcGatewayServer struct {
}

UnimplementedGrpcGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedGrpcGatewayServer) DeleteResource added in v1.1.0 

func (*UnimplementedGrpcGatewayServer) DeleteResource(ctx context.Context, req *DeleteResourceRequest) (*DeleteResourceResponse, error)

func (*UnimplementedGrpcGatewayServer) GetClientConfiguration 

func (*UnimplementedGrpcGatewayServer) GetClientConfiguration(ctx context.Context, req *ClientConfigurationRequest) (*ClientConfigurationResponse, error)

func (*UnimplementedGrpcGatewayServer) GetDevices 

func (*UnimplementedGrpcGatewayServer) GetDevices(req *GetDevicesRequest, srv GrpcGateway_GetDevicesServer) error
func (*UnimplementedGrpcGatewayServer) GetResourceLinks(req *GetResourceLinksRequest, srv GrpcGateway_GetResourceLinksServer) error

func (*UnimplementedGrpcGatewayServer) RetrieveResourceFromDevice 

func (*UnimplementedGrpcGatewayServer) RetrieveResourceFromDevice(ctx context.Context, req *RetrieveResourceFromDeviceRequest) (*RetrieveResourceFromDeviceResponse, error)

func (*UnimplementedGrpcGatewayServer) RetrieveResourcesValues 

func (*UnimplementedGrpcGatewayServer) RetrieveResourcesValues(req *RetrieveResourcesValuesRequest, srv GrpcGateway_RetrieveResourcesValuesServer) error

func (*UnimplementedGrpcGatewayServer) SubscribeForEvents 

func (*UnimplementedGrpcGatewayServer) SubscribeForEvents(srv GrpcGateway_SubscribeForEventsServer) error

func (*UnimplementedGrpcGatewayServer) UpdateResourcesValues 

func (*UnimplementedGrpcGatewayServer) UpdateResourcesValues(ctx context.Context, req *UpdateResourceValuesRequest) (*UpdateResourceValuesResponse, error)

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 (m *UpdateResourceValuesResponse) String() 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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