resource_shadow

package
v0.0.0-...-1c3cffe Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2020 License: MIT Imports: 12 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQueries        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueries          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueries = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterResourceShadowServer 

func RegisterResourceShadowServer(s *grpc.Server, srv ResourceShadowServer)

Types

type ResourceShadowClient 

type ResourceShadowClient interface {
	RetrieveResourcesValues(ctx context.Context, in *RetrieveResourcesValuesRequest, opts ...grpc.CallOption) (ResourceShadow_RetrieveResourcesValuesClient, error)
}

ResourceShadowClient is the client API for ResourceShadow service.

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

func NewResourceShadowClient 

func NewResourceShadowClient(cc *grpc.ClientConn) ResourceShadowClient

type ResourceShadowServer 

type ResourceShadowServer interface {
	RetrieveResourcesValues(*RetrieveResourcesValuesRequest, ResourceShadow_RetrieveResourcesValuesServer) error
}

ResourceShadowServer is the server API for ResourceShadow service.

type ResourceShadow_RetrieveResourcesValuesClient 

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

type ResourceShadow_RetrieveResourcesValuesServer 

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

type ResourceValue 

type ResourceValue struct {
	ResourceId string      `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	DeviceId   string      `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Href       string      `protobuf:"bytes,3,opt,name=href,proto3" json:"href,omitempty"`
	Types      []string    `protobuf:"bytes,4,rep,name=types,proto3" json:"types,omitempty"`
	Content    *pb.Content `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Status     pb.Status   `protobuf:"varint,6,opt,name=status,proto3,enum=ocf.cloud.resourceaggregate.pb.Status" json:"status,omitempty"`
}

func (*ResourceValue) Descriptor 

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

func (*ResourceValue) GetContent 

func (m *ResourceValue) GetContent() *pb.Content

func (*ResourceValue) GetDeviceId 

func (m *ResourceValue) GetDeviceId() string

func (*ResourceValue) GetHref 

func (m *ResourceValue) GetHref() string

func (*ResourceValue) GetResourceId 

func (m *ResourceValue) GetResourceId() string

func (*ResourceValue) GetStatus 

func (m *ResourceValue) GetStatus() pb.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 RetrieveResourcesValuesRequest 

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

func (*RetrieveResourcesValuesRequest) Descriptor 

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

func (*RetrieveResourcesValuesRequest) GetAuthorizationContext 

func (m *RetrieveResourcesValuesRequest) GetAuthorizationContext() *pb.AuthorizationContext

func (*RetrieveResourcesValuesRequest) GetDeviceIdsFilter 

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

func (*RetrieveResourcesValuesRequest) GetResourceIdsFilter 

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

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 UnimplementedResourceShadowServer 

type UnimplementedResourceShadowServer struct {
}

UnimplementedResourceShadowServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceShadowServer) RetrieveResourcesValues 

func (*UnimplementedResourceShadowServer) RetrieveResourcesValues(req *RetrieveResourcesValuesRequest, srv ResourceShadow_RetrieveResourcesValuesServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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