Documentation ¶
Index ¶
- func RegisterDeviceServiceServer(s *grpc.Server, srv DeviceServiceServer)
- type DeviceServiceClient
- type DeviceServiceServer
- type DeviceService_PushFrameToFlowClient
- type DeviceService_PushFrameToFlowServer
- type GetObjectContentRequest
- func (*GetObjectContentRequest) Descriptor() ([]byte, []int)
- func (m *GetObjectContentRequest) GetObject() *deviced.OpObject
- func (*GetObjectContentRequest) ProtoMessage()
- func (m *GetObjectContentRequest) Reset()
- func (m *GetObjectContentRequest) String() string
- func (this *GetObjectContentRequest) Validate() error
- func (m *GetObjectContentRequest) XXX_DiscardUnknown()
- func (m *GetObjectContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectContentRequest) XXX_Merge(src proto.Message)
- func (m *GetObjectContentRequest) XXX_Size() int
- func (m *GetObjectContentRequest) XXX_Unmarshal(b []byte) error
- type GetObjectContentResponse
- func (*GetObjectContentResponse) Descriptor() ([]byte, []int)
- func (m *GetObjectContentResponse) GetContent() []byte
- func (*GetObjectContentResponse) ProtoMessage()
- func (m *GetObjectContentResponse) Reset()
- func (m *GetObjectContentResponse) String() string
- func (this *GetObjectContentResponse) Validate() error
- func (m *GetObjectContentResponse) XXX_DiscardUnknown()
- func (m *GetObjectContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectContentResponse) XXX_Merge(src proto.Message)
- func (m *GetObjectContentResponse) XXX_Size() int
- func (m *GetObjectContentResponse) XXX_Unmarshal(b []byte) error
- type GetObjectRequest
- func (*GetObjectRequest) Descriptor() ([]byte, []int)
- func (m *GetObjectRequest) GetObject() *deviced.OpObject
- func (*GetObjectRequest) ProtoMessage()
- func (m *GetObjectRequest) Reset()
- func (m *GetObjectRequest) String() string
- func (this *GetObjectRequest) Validate() error
- func (m *GetObjectRequest) XXX_DiscardUnknown()
- func (m *GetObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectRequest) XXX_Merge(src proto.Message)
- func (m *GetObjectRequest) XXX_Size() int
- func (m *GetObjectRequest) XXX_Unmarshal(b []byte) error
- type GetObjectResponse
- func (*GetObjectResponse) Descriptor() ([]byte, []int)
- func (m *GetObjectResponse) GetObject() *deviced.Object
- func (*GetObjectResponse) ProtoMessage()
- func (m *GetObjectResponse) Reset()
- func (m *GetObjectResponse) String() string
- func (this *GetObjectResponse) Validate() error
- func (m *GetObjectResponse) XXX_DiscardUnknown()
- func (m *GetObjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectResponse) XXX_Merge(src proto.Message)
- func (m *GetObjectResponse) XXX_Size() int
- func (m *GetObjectResponse) XXX_Unmarshal(b []byte) error
- type GetObjectStreamingContentRequest
- func (*GetObjectStreamingContentRequest) Descriptor() ([]byte, []int)
- func (m *GetObjectStreamingContentRequest) GetObject() *deviced.OpObject
- func (*GetObjectStreamingContentRequest) ProtoMessage()
- func (m *GetObjectStreamingContentRequest) Reset()
- func (m *GetObjectStreamingContentRequest) String() string
- func (this *GetObjectStreamingContentRequest) Validate() error
- func (m *GetObjectStreamingContentRequest) XXX_DiscardUnknown()
- func (m *GetObjectStreamingContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectStreamingContentRequest) XXX_Merge(src proto.Message)
- func (m *GetObjectStreamingContentRequest) XXX_Size() int
- func (m *GetObjectStreamingContentRequest) XXX_Unmarshal(b []byte) error
- type GetObjectStreamingContentResponse
- func (*GetObjectStreamingContentResponse) Descriptor() ([]byte, []int)
- func (m *GetObjectStreamingContentResponse) GetContent() []byte
- func (*GetObjectStreamingContentResponse) ProtoMessage()
- func (m *GetObjectStreamingContentResponse) Reset()
- func (m *GetObjectStreamingContentResponse) String() string
- func (this *GetObjectStreamingContentResponse) Validate() error
- func (m *GetObjectStreamingContentResponse) XXX_DiscardUnknown()
- func (m *GetObjectStreamingContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetObjectStreamingContentResponse) XXX_Merge(src proto.Message)
- func (m *GetObjectStreamingContentResponse) XXX_Size() int
- func (m *GetObjectStreamingContentResponse) XXX_Unmarshal(b []byte) error
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *HeartbeatRequest) GetModule() *deviced.OpModule
- func (*HeartbeatRequest) ProtoMessage()
- func (m *HeartbeatRequest) Reset()
- func (m *HeartbeatRequest) String() string
- func (this *HeartbeatRequest) Validate() error
- func (m *HeartbeatRequest) XXX_DiscardUnknown()
- func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *HeartbeatRequest) XXX_Size() int
- func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
- type IssueModuleTokenRequest
- func (*IssueModuleTokenRequest) Descriptor() ([]byte, []int)
- func (m *IssueModuleTokenRequest) GetCredential() *identityd2.OpCredential
- func (m *IssueModuleTokenRequest) GetHmac() *wrappers.StringValue
- func (m *IssueModuleTokenRequest) GetNonce() *wrappers.Int64Value
- func (m *IssueModuleTokenRequest) GetTimestamp() *timestamp.Timestamp
- func (*IssueModuleTokenRequest) ProtoMessage()
- func (m *IssueModuleTokenRequest) Reset()
- func (m *IssueModuleTokenRequest) String() string
- func (this *IssueModuleTokenRequest) Validate() error
- func (m *IssueModuleTokenRequest) XXX_DiscardUnknown()
- func (m *IssueModuleTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IssueModuleTokenRequest) XXX_Merge(src proto.Message)
- func (m *IssueModuleTokenRequest) XXX_Size() int
- func (m *IssueModuleTokenRequest) XXX_Unmarshal(b []byte) error
- type IssueModuleTokenResponse
- func (*IssueModuleTokenResponse) Descriptor() ([]byte, []int)
- func (m *IssueModuleTokenResponse) GetToken() *identityd2.Token
- func (*IssueModuleTokenResponse) ProtoMessage()
- func (m *IssueModuleTokenResponse) Reset()
- func (m *IssueModuleTokenResponse) String() string
- func (this *IssueModuleTokenResponse) Validate() error
- func (m *IssueModuleTokenResponse) XXX_DiscardUnknown()
- func (m *IssueModuleTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IssueModuleTokenResponse) XXX_Merge(src proto.Message)
- func (m *IssueModuleTokenResponse) XXX_Size() int
- func (m *IssueModuleTokenResponse) XXX_Unmarshal(b []byte) error
- type ListObjectsRequest
- func (*ListObjectsRequest) Descriptor() ([]byte, []int)
- func (m *ListObjectsRequest) GetObject() *deviced.OpObject
- func (*ListObjectsRequest) ProtoMessage()
- func (m *ListObjectsRequest) Reset()
- func (m *ListObjectsRequest) String() string
- func (this *ListObjectsRequest) Validate() error
- func (m *ListObjectsRequest) XXX_DiscardUnknown()
- func (m *ListObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListObjectsRequest) XXX_Merge(src proto.Message)
- func (m *ListObjectsRequest) XXX_Size() int
- func (m *ListObjectsRequest) XXX_Unmarshal(b []byte) error
- type ListObjectsResponse
- func (*ListObjectsResponse) Descriptor() ([]byte, []int)
- func (m *ListObjectsResponse) GetObjects() []*deviced.Object
- func (*ListObjectsResponse) ProtoMessage()
- func (m *ListObjectsResponse) Reset()
- func (m *ListObjectsResponse) String() string
- func (this *ListObjectsResponse) Validate() error
- func (m *ListObjectsResponse) XXX_DiscardUnknown()
- func (m *ListObjectsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListObjectsResponse) XXX_Merge(src proto.Message)
- func (m *ListObjectsResponse) XXX_Size() int
- func (m *ListObjectsResponse) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowRequest
- func (*PushFrameToFlowRequest) Descriptor() ([]byte, []int)
- func (m *PushFrameToFlowRequest) GetConfig() *PushFrameToFlowRequest_Config
- func (m *PushFrameToFlowRequest) GetFrame() *deviced.OpFrame
- func (m *PushFrameToFlowRequest) GetId() *wrappers.StringValue
- func (m *PushFrameToFlowRequest) GetPing() *PushFrameToFlowRequest_Ping
- func (m *PushFrameToFlowRequest) GetRequest() isPushFrameToFlowRequest_Request
- func (*PushFrameToFlowRequest) ProtoMessage()
- func (m *PushFrameToFlowRequest) Reset()
- func (m *PushFrameToFlowRequest) String() string
- func (this *PushFrameToFlowRequest) Validate() error
- func (m *PushFrameToFlowRequest) XXX_DiscardUnknown()
- func (m *PushFrameToFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowRequest) XXX_Merge(src proto.Message)
- func (*PushFrameToFlowRequest) XXX_OneofWrappers() []interface{}
- func (m *PushFrameToFlowRequest) XXX_Size() int
- func (m *PushFrameToFlowRequest) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowRequest_Config
- func (*PushFrameToFlowRequest_Config) Descriptor() ([]byte, []int)
- func (m *PushFrameToFlowRequest_Config) GetConfigAck() *wrappers.BoolValue
- func (m *PushFrameToFlowRequest_Config) GetFlow() *deviced.OpFlow
- func (m *PushFrameToFlowRequest_Config) GetPushAck() *wrappers.BoolValue
- func (*PushFrameToFlowRequest_Config) ProtoMessage()
- func (m *PushFrameToFlowRequest_Config) Reset()
- func (m *PushFrameToFlowRequest_Config) String() string
- func (this *PushFrameToFlowRequest_Config) Validate() error
- func (m *PushFrameToFlowRequest_Config) XXX_DiscardUnknown()
- func (m *PushFrameToFlowRequest_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowRequest_Config) XXX_Merge(src proto.Message)
- func (m *PushFrameToFlowRequest_Config) XXX_Size() int
- func (m *PushFrameToFlowRequest_Config) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowRequest_Config_
- type PushFrameToFlowRequest_Frame
- type PushFrameToFlowRequest_Ping
- func (*PushFrameToFlowRequest_Ping) Descriptor() ([]byte, []int)
- func (*PushFrameToFlowRequest_Ping) ProtoMessage()
- func (m *PushFrameToFlowRequest_Ping) Reset()
- func (m *PushFrameToFlowRequest_Ping) String() string
- func (this *PushFrameToFlowRequest_Ping) Validate() error
- func (m *PushFrameToFlowRequest_Ping) XXX_DiscardUnknown()
- func (m *PushFrameToFlowRequest_Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowRequest_Ping) XXX_Merge(src proto.Message)
- func (m *PushFrameToFlowRequest_Ping) XXX_Size() int
- func (m *PushFrameToFlowRequest_Ping) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowRequest_Ping_
- type PushFrameToFlowResponse
- func (*PushFrameToFlowResponse) Descriptor() ([]byte, []int)
- func (m *PushFrameToFlowResponse) GetAck() *PushFrameToFlowResponse_Ack
- func (m *PushFrameToFlowResponse) GetConfig() *PushFrameToFlowResponse_Config
- func (m *PushFrameToFlowResponse) GetId() string
- func (m *PushFrameToFlowResponse) GetPong() *PushFrameToFlowResponse_Pong
- func (m *PushFrameToFlowResponse) GetResponse() isPushFrameToFlowResponse_Response
- func (*PushFrameToFlowResponse) ProtoMessage()
- func (m *PushFrameToFlowResponse) Reset()
- func (m *PushFrameToFlowResponse) String() string
- func (this *PushFrameToFlowResponse) Validate() error
- func (m *PushFrameToFlowResponse) XXX_DiscardUnknown()
- func (m *PushFrameToFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowResponse) XXX_Merge(src proto.Message)
- func (*PushFrameToFlowResponse) XXX_OneofWrappers() []interface{}
- func (m *PushFrameToFlowResponse) XXX_Size() int
- func (m *PushFrameToFlowResponse) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowResponse_Ack
- func (*PushFrameToFlowResponse_Ack) Descriptor() ([]byte, []int)
- func (*PushFrameToFlowResponse_Ack) ProtoMessage()
- func (m *PushFrameToFlowResponse_Ack) Reset()
- func (m *PushFrameToFlowResponse_Ack) String() string
- func (this *PushFrameToFlowResponse_Ack) Validate() error
- func (m *PushFrameToFlowResponse_Ack) XXX_DiscardUnknown()
- func (m *PushFrameToFlowResponse_Ack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowResponse_Ack) XXX_Merge(src proto.Message)
- func (m *PushFrameToFlowResponse_Ack) XXX_Size() int
- func (m *PushFrameToFlowResponse_Ack) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowResponse_Ack_
- type PushFrameToFlowResponse_Config
- func (*PushFrameToFlowResponse_Config) Descriptor() ([]byte, []int)
- func (m *PushFrameToFlowResponse_Config) GetSession() string
- func (*PushFrameToFlowResponse_Config) ProtoMessage()
- func (m *PushFrameToFlowResponse_Config) Reset()
- func (m *PushFrameToFlowResponse_Config) String() string
- func (this *PushFrameToFlowResponse_Config) Validate() error
- func (m *PushFrameToFlowResponse_Config) XXX_DiscardUnknown()
- func (m *PushFrameToFlowResponse_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowResponse_Config) XXX_Merge(src proto.Message)
- func (m *PushFrameToFlowResponse_Config) XXX_Size() int
- func (m *PushFrameToFlowResponse_Config) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowResponse_Config_
- type PushFrameToFlowResponse_Pong
- func (*PushFrameToFlowResponse_Pong) Descriptor() ([]byte, []int)
- func (*PushFrameToFlowResponse_Pong) ProtoMessage()
- func (m *PushFrameToFlowResponse_Pong) Reset()
- func (m *PushFrameToFlowResponse_Pong) String() string
- func (this *PushFrameToFlowResponse_Pong) Validate() error
- func (m *PushFrameToFlowResponse_Pong) XXX_DiscardUnknown()
- func (m *PushFrameToFlowResponse_Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushFrameToFlowResponse_Pong) XXX_Merge(src proto.Message)
- func (m *PushFrameToFlowResponse_Pong) XXX_Size() int
- func (m *PushFrameToFlowResponse_Pong) XXX_Unmarshal(b []byte) error
- type PushFrameToFlowResponse_Pong_
- type PutObjectRequest
- func (*PutObjectRequest) Descriptor() ([]byte, []int)
- func (m *PutObjectRequest) GetContent() *wrappers.BytesValue
- func (m *PutObjectRequest) GetObject() *deviced.OpObject
- func (*PutObjectRequest) ProtoMessage()
- func (m *PutObjectRequest) Reset()
- func (m *PutObjectRequest) String() string
- func (this *PutObjectRequest) Validate() error
- func (m *PutObjectRequest) XXX_DiscardUnknown()
- func (m *PutObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutObjectRequest) XXX_Merge(src proto.Message)
- func (m *PutObjectRequest) XXX_Size() int
- func (m *PutObjectRequest) XXX_Unmarshal(b []byte) error
- type RemoveObjectRequest
- func (*RemoveObjectRequest) Descriptor() ([]byte, []int)
- func (m *RemoveObjectRequest) GetObject() *deviced.OpObject
- func (*RemoveObjectRequest) ProtoMessage()
- func (m *RemoveObjectRequest) Reset()
- func (m *RemoveObjectRequest) String() string
- func (this *RemoveObjectRequest) Validate() error
- func (m *RemoveObjectRequest) XXX_DiscardUnknown()
- func (m *RemoveObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveObjectRequest) XXX_Merge(src proto.Message)
- func (m *RemoveObjectRequest) XXX_Size() int
- func (m *RemoveObjectRequest) XXX_Unmarshal(b []byte) error
- type RenameObjectRequest
- func (*RenameObjectRequest) Descriptor() ([]byte, []int)
- func (m *RenameObjectRequest) GetDestination() *deviced.OpObject
- func (m *RenameObjectRequest) GetSource() *deviced.OpObject
- func (*RenameObjectRequest) ProtoMessage()
- func (m *RenameObjectRequest) Reset()
- func (m *RenameObjectRequest) String() string
- func (this *RenameObjectRequest) Validate() error
- func (m *RenameObjectRequest) XXX_DiscardUnknown()
- func (m *RenameObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenameObjectRequest) XXX_Merge(src proto.Message)
- func (m *RenameObjectRequest) XXX_Size() int
- func (m *RenameObjectRequest) XXX_Unmarshal(b []byte) error
- type ShowModuleResponse
- func (*ShowModuleResponse) Descriptor() ([]byte, []int)
- func (m *ShowModuleResponse) GetModule() *deviced.Module
- func (*ShowModuleResponse) ProtoMessage()
- func (m *ShowModuleResponse) Reset()
- func (m *ShowModuleResponse) String() string
- func (this *ShowModuleResponse) Validate() error
- func (m *ShowModuleResponse) XXX_DiscardUnknown()
- func (m *ShowModuleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowModuleResponse) XXX_Merge(src proto.Message)
- func (m *ShowModuleResponse) XXX_Size() int
- func (m *ShowModuleResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedDeviceServiceServer
- func (*UnimplementedDeviceServiceServer) GetObject(ctx context.Context, req *GetObjectRequest) (*GetObjectResponse, error)
- func (*UnimplementedDeviceServiceServer) GetObjectContent(ctx context.Context, req *GetObjectContentRequest) (*GetObjectContentResponse, error)
- func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent(ctx context.Context, req *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)
- func (*UnimplementedDeviceServiceServer) Heartbeat(ctx context.Context, req *HeartbeatRequest) (*empty.Empty, error)
- func (*UnimplementedDeviceServiceServer) IssueModuleToken(ctx context.Context, req *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)
- func (*UnimplementedDeviceServiceServer) ListObjects(ctx context.Context, req *ListObjectsRequest) (*ListObjectsResponse, error)
- func (*UnimplementedDeviceServiceServer) PushFrameToFlow(srv DeviceService_PushFrameToFlowServer) error
- func (*UnimplementedDeviceServiceServer) PutObject(ctx context.Context, req *PutObjectRequest) (*empty.Empty, error)
- func (*UnimplementedDeviceServiceServer) RemoveObject(ctx context.Context, req *RemoveObjectRequest) (*empty.Empty, error)
- func (*UnimplementedDeviceServiceServer) RenameObject(ctx context.Context, req *RenameObjectRequest) (*empty.Empty, error)
- func (*UnimplementedDeviceServiceServer) ShowModule(ctx context.Context, req *empty.Empty) (*ShowModuleResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDeviceServiceServer ¶
func RegisterDeviceServiceServer(s *grpc.Server, srv DeviceServiceServer)
Types ¶
type DeviceServiceClient ¶
type DeviceServiceClient interface { IssueModuleToken(ctx context.Context, in *IssueModuleTokenRequest, opts ...grpc.CallOption) (*IssueModuleTokenResponse, error) ShowModule(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ShowModuleResponse, error) Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*empty.Empty, error) PushFrameToFlow(ctx context.Context, opts ...grpc.CallOption) (DeviceService_PushFrameToFlowClient, error) PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error) RemoveObject(ctx context.Context, in *RemoveObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error) RenameObject(ctx context.Context, in *RenameObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error) GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (*GetObjectResponse, error) GetObjectContent(ctx context.Context, in *GetObjectContentRequest, opts ...grpc.CallOption) (*GetObjectContentResponse, error) GetObjectStreamingContent(ctx context.Context, in *GetObjectStreamingContentRequest, opts ...grpc.CallOption) (*GetObjectStreamingContentResponse, error) ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error) }
DeviceServiceClient is the client API for DeviceService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDeviceServiceClient ¶
func NewDeviceServiceClient(cc *grpc.ClientConn) DeviceServiceClient
type DeviceServiceServer ¶
type DeviceServiceServer interface { IssueModuleToken(context.Context, *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error) ShowModule(context.Context, *empty.Empty) (*ShowModuleResponse, error) Heartbeat(context.Context, *HeartbeatRequest) (*empty.Empty, error) PushFrameToFlow(DeviceService_PushFrameToFlowServer) error PutObject(context.Context, *PutObjectRequest) (*empty.Empty, error) RemoveObject(context.Context, *RemoveObjectRequest) (*empty.Empty, error) RenameObject(context.Context, *RenameObjectRequest) (*empty.Empty, error) GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error) GetObjectContent(context.Context, *GetObjectContentRequest) (*GetObjectContentResponse, error) GetObjectStreamingContent(context.Context, *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error) ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error) }
DeviceServiceServer is the server API for DeviceService service.
type DeviceService_PushFrameToFlowClient ¶
type DeviceService_PushFrameToFlowClient interface { Send(*PushFrameToFlowRequest) error Recv() (*PushFrameToFlowResponse, error) grpc.ClientStream }
type DeviceService_PushFrameToFlowServer ¶
type DeviceService_PushFrameToFlowServer interface { Send(*PushFrameToFlowResponse) error Recv() (*PushFrameToFlowRequest, error) grpc.ServerStream }
type GetObjectContentRequest ¶
type GetObjectContentRequest struct { Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectContentRequest) Descriptor ¶
func (*GetObjectContentRequest) Descriptor() ([]byte, []int)
func (*GetObjectContentRequest) GetObject ¶
func (m *GetObjectContentRequest) GetObject() *deviced.OpObject
func (*GetObjectContentRequest) ProtoMessage ¶
func (*GetObjectContentRequest) ProtoMessage()
func (*GetObjectContentRequest) Reset ¶
func (m *GetObjectContentRequest) Reset()
func (*GetObjectContentRequest) String ¶
func (m *GetObjectContentRequest) String() string
func (*GetObjectContentRequest) Validate ¶
func (this *GetObjectContentRequest) Validate() error
func (*GetObjectContentRequest) XXX_DiscardUnknown ¶
func (m *GetObjectContentRequest) XXX_DiscardUnknown()
func (*GetObjectContentRequest) XXX_Marshal ¶
func (m *GetObjectContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectContentRequest) XXX_Merge ¶
func (m *GetObjectContentRequest) XXX_Merge(src proto.Message)
func (*GetObjectContentRequest) XXX_Size ¶
func (m *GetObjectContentRequest) XXX_Size() int
func (*GetObjectContentRequest) XXX_Unmarshal ¶
func (m *GetObjectContentRequest) XXX_Unmarshal(b []byte) error
type GetObjectContentResponse ¶
type GetObjectContentResponse struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectContentResponse) Descriptor ¶
func (*GetObjectContentResponse) Descriptor() ([]byte, []int)
func (*GetObjectContentResponse) GetContent ¶
func (m *GetObjectContentResponse) GetContent() []byte
func (*GetObjectContentResponse) ProtoMessage ¶
func (*GetObjectContentResponse) ProtoMessage()
func (*GetObjectContentResponse) Reset ¶
func (m *GetObjectContentResponse) Reset()
func (*GetObjectContentResponse) String ¶
func (m *GetObjectContentResponse) String() string
func (*GetObjectContentResponse) Validate ¶
func (this *GetObjectContentResponse) Validate() error
func (*GetObjectContentResponse) XXX_DiscardUnknown ¶
func (m *GetObjectContentResponse) XXX_DiscardUnknown()
func (*GetObjectContentResponse) XXX_Marshal ¶
func (m *GetObjectContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectContentResponse) XXX_Merge ¶
func (m *GetObjectContentResponse) XXX_Merge(src proto.Message)
func (*GetObjectContentResponse) XXX_Size ¶
func (m *GetObjectContentResponse) XXX_Size() int
func (*GetObjectContentResponse) XXX_Unmarshal ¶
func (m *GetObjectContentResponse) XXX_Unmarshal(b []byte) error
type GetObjectRequest ¶
type GetObjectRequest struct { Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectRequest) Descriptor ¶
func (*GetObjectRequest) Descriptor() ([]byte, []int)
func (*GetObjectRequest) GetObject ¶
func (m *GetObjectRequest) GetObject() *deviced.OpObject
func (*GetObjectRequest) ProtoMessage ¶
func (*GetObjectRequest) ProtoMessage()
func (*GetObjectRequest) Reset ¶
func (m *GetObjectRequest) Reset()
func (*GetObjectRequest) String ¶
func (m *GetObjectRequest) String() string
func (*GetObjectRequest) Validate ¶
func (this *GetObjectRequest) Validate() error
func (*GetObjectRequest) XXX_DiscardUnknown ¶
func (m *GetObjectRequest) XXX_DiscardUnknown()
func (*GetObjectRequest) XXX_Marshal ¶
func (m *GetObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectRequest) XXX_Merge ¶
func (m *GetObjectRequest) XXX_Merge(src proto.Message)
func (*GetObjectRequest) XXX_Size ¶
func (m *GetObjectRequest) XXX_Size() int
func (*GetObjectRequest) XXX_Unmarshal ¶
func (m *GetObjectRequest) XXX_Unmarshal(b []byte) error
type GetObjectResponse ¶
type GetObjectResponse struct { Object *deviced.Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectResponse) Descriptor ¶
func (*GetObjectResponse) Descriptor() ([]byte, []int)
func (*GetObjectResponse) GetObject ¶
func (m *GetObjectResponse) GetObject() *deviced.Object
func (*GetObjectResponse) ProtoMessage ¶
func (*GetObjectResponse) ProtoMessage()
func (*GetObjectResponse) Reset ¶
func (m *GetObjectResponse) Reset()
func (*GetObjectResponse) String ¶
func (m *GetObjectResponse) String() string
func (*GetObjectResponse) Validate ¶
func (this *GetObjectResponse) Validate() error
func (*GetObjectResponse) XXX_DiscardUnknown ¶
func (m *GetObjectResponse) XXX_DiscardUnknown()
func (*GetObjectResponse) XXX_Marshal ¶
func (m *GetObjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectResponse) XXX_Merge ¶
func (m *GetObjectResponse) XXX_Merge(src proto.Message)
func (*GetObjectResponse) XXX_Size ¶
func (m *GetObjectResponse) XXX_Size() int
func (*GetObjectResponse) XXX_Unmarshal ¶
func (m *GetObjectResponse) XXX_Unmarshal(b []byte) error
type GetObjectStreamingContentRequest ¶
type GetObjectStreamingContentRequest struct { Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectStreamingContentRequest) Descriptor ¶
func (*GetObjectStreamingContentRequest) Descriptor() ([]byte, []int)
func (*GetObjectStreamingContentRequest) GetObject ¶
func (m *GetObjectStreamingContentRequest) GetObject() *deviced.OpObject
func (*GetObjectStreamingContentRequest) ProtoMessage ¶
func (*GetObjectStreamingContentRequest) ProtoMessage()
func (*GetObjectStreamingContentRequest) Reset ¶
func (m *GetObjectStreamingContentRequest) Reset()
func (*GetObjectStreamingContentRequest) String ¶
func (m *GetObjectStreamingContentRequest) String() string
func (*GetObjectStreamingContentRequest) Validate ¶
func (this *GetObjectStreamingContentRequest) Validate() error
func (*GetObjectStreamingContentRequest) XXX_DiscardUnknown ¶
func (m *GetObjectStreamingContentRequest) XXX_DiscardUnknown()
func (*GetObjectStreamingContentRequest) XXX_Marshal ¶
func (m *GetObjectStreamingContentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectStreamingContentRequest) XXX_Merge ¶
func (m *GetObjectStreamingContentRequest) XXX_Merge(src proto.Message)
func (*GetObjectStreamingContentRequest) XXX_Size ¶
func (m *GetObjectStreamingContentRequest) XXX_Size() int
func (*GetObjectStreamingContentRequest) XXX_Unmarshal ¶
func (m *GetObjectStreamingContentRequest) XXX_Unmarshal(b []byte) error
type GetObjectStreamingContentResponse ¶
type GetObjectStreamingContentResponse struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetObjectStreamingContentResponse) Descriptor ¶
func (*GetObjectStreamingContentResponse) Descriptor() ([]byte, []int)
func (*GetObjectStreamingContentResponse) GetContent ¶
func (m *GetObjectStreamingContentResponse) GetContent() []byte
func (*GetObjectStreamingContentResponse) ProtoMessage ¶
func (*GetObjectStreamingContentResponse) ProtoMessage()
func (*GetObjectStreamingContentResponse) Reset ¶
func (m *GetObjectStreamingContentResponse) Reset()
func (*GetObjectStreamingContentResponse) String ¶
func (m *GetObjectStreamingContentResponse) String() string
func (*GetObjectStreamingContentResponse) Validate ¶
func (this *GetObjectStreamingContentResponse) Validate() error
func (*GetObjectStreamingContentResponse) XXX_DiscardUnknown ¶
func (m *GetObjectStreamingContentResponse) XXX_DiscardUnknown()
func (*GetObjectStreamingContentResponse) XXX_Marshal ¶
func (m *GetObjectStreamingContentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetObjectStreamingContentResponse) XXX_Merge ¶
func (m *GetObjectStreamingContentResponse) XXX_Merge(src proto.Message)
func (*GetObjectStreamingContentResponse) XXX_Size ¶
func (m *GetObjectStreamingContentResponse) XXX_Size() int
func (*GetObjectStreamingContentResponse) XXX_Unmarshal ¶
func (m *GetObjectStreamingContentResponse) XXX_Unmarshal(b []byte) error
type HeartbeatRequest ¶
type HeartbeatRequest struct { Module *deviced.OpModule `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatRequest) Descriptor ¶
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
func (*HeartbeatRequest) GetModule ¶
func (m *HeartbeatRequest) GetModule() *deviced.OpModule
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) Reset ¶
func (m *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (m *HeartbeatRequest) String() string
func (*HeartbeatRequest) Validate ¶
func (this *HeartbeatRequest) Validate() error
func (*HeartbeatRequest) XXX_DiscardUnknown ¶
func (m *HeartbeatRequest) XXX_DiscardUnknown()
func (*HeartbeatRequest) XXX_Marshal ¶
func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatRequest) XXX_Merge ¶
func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
func (*HeartbeatRequest) XXX_Size ¶
func (m *HeartbeatRequest) XXX_Size() int
func (*HeartbeatRequest) XXX_Unmarshal ¶
func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
type IssueModuleTokenRequest ¶
type IssueModuleTokenRequest struct { Credential *identityd2.OpCredential `protobuf:"bytes,1,opt,name=credential,proto3" json:"credential,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Nonce *wrappers.Int64Value `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"` Hmac *wrappers.StringValue `protobuf:"bytes,4,opt,name=hmac,proto3" json:"hmac,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IssueModuleTokenRequest) Descriptor ¶
func (*IssueModuleTokenRequest) Descriptor() ([]byte, []int)
func (*IssueModuleTokenRequest) GetCredential ¶
func (m *IssueModuleTokenRequest) GetCredential() *identityd2.OpCredential
func (*IssueModuleTokenRequest) GetHmac ¶
func (m *IssueModuleTokenRequest) GetHmac() *wrappers.StringValue
func (*IssueModuleTokenRequest) GetNonce ¶
func (m *IssueModuleTokenRequest) GetNonce() *wrappers.Int64Value
func (*IssueModuleTokenRequest) GetTimestamp ¶
func (m *IssueModuleTokenRequest) GetTimestamp() *timestamp.Timestamp
func (*IssueModuleTokenRequest) ProtoMessage ¶
func (*IssueModuleTokenRequest) ProtoMessage()
func (*IssueModuleTokenRequest) Reset ¶
func (m *IssueModuleTokenRequest) Reset()
func (*IssueModuleTokenRequest) String ¶
func (m *IssueModuleTokenRequest) String() string
func (*IssueModuleTokenRequest) Validate ¶
func (this *IssueModuleTokenRequest) Validate() error
func (*IssueModuleTokenRequest) XXX_DiscardUnknown ¶
func (m *IssueModuleTokenRequest) XXX_DiscardUnknown()
func (*IssueModuleTokenRequest) XXX_Marshal ¶
func (m *IssueModuleTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IssueModuleTokenRequest) XXX_Merge ¶
func (m *IssueModuleTokenRequest) XXX_Merge(src proto.Message)
func (*IssueModuleTokenRequest) XXX_Size ¶
func (m *IssueModuleTokenRequest) XXX_Size() int
func (*IssueModuleTokenRequest) XXX_Unmarshal ¶
func (m *IssueModuleTokenRequest) XXX_Unmarshal(b []byte) error
type IssueModuleTokenResponse ¶
type IssueModuleTokenResponse struct { Token *identityd2.Token `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IssueModuleTokenResponse) Descriptor ¶
func (*IssueModuleTokenResponse) Descriptor() ([]byte, []int)
func (*IssueModuleTokenResponse) GetToken ¶
func (m *IssueModuleTokenResponse) GetToken() *identityd2.Token
func (*IssueModuleTokenResponse) ProtoMessage ¶
func (*IssueModuleTokenResponse) ProtoMessage()
func (*IssueModuleTokenResponse) Reset ¶
func (m *IssueModuleTokenResponse) Reset()
func (*IssueModuleTokenResponse) String ¶
func (m *IssueModuleTokenResponse) String() string
func (*IssueModuleTokenResponse) Validate ¶
func (this *IssueModuleTokenResponse) Validate() error
func (*IssueModuleTokenResponse) XXX_DiscardUnknown ¶
func (m *IssueModuleTokenResponse) XXX_DiscardUnknown()
func (*IssueModuleTokenResponse) XXX_Marshal ¶
func (m *IssueModuleTokenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IssueModuleTokenResponse) XXX_Merge ¶
func (m *IssueModuleTokenResponse) XXX_Merge(src proto.Message)
func (*IssueModuleTokenResponse) XXX_Size ¶
func (m *IssueModuleTokenResponse) XXX_Size() int
func (*IssueModuleTokenResponse) XXX_Unmarshal ¶
func (m *IssueModuleTokenResponse) XXX_Unmarshal(b []byte) error
type ListObjectsRequest ¶
type ListObjectsRequest struct { Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListObjectsRequest) Descriptor ¶
func (*ListObjectsRequest) Descriptor() ([]byte, []int)
func (*ListObjectsRequest) GetObject ¶
func (m *ListObjectsRequest) GetObject() *deviced.OpObject
func (*ListObjectsRequest) ProtoMessage ¶
func (*ListObjectsRequest) ProtoMessage()
func (*ListObjectsRequest) Reset ¶
func (m *ListObjectsRequest) Reset()
func (*ListObjectsRequest) String ¶
func (m *ListObjectsRequest) String() string
func (*ListObjectsRequest) Validate ¶
func (this *ListObjectsRequest) Validate() error
func (*ListObjectsRequest) XXX_DiscardUnknown ¶
func (m *ListObjectsRequest) XXX_DiscardUnknown()
func (*ListObjectsRequest) XXX_Marshal ¶
func (m *ListObjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListObjectsRequest) XXX_Merge ¶
func (m *ListObjectsRequest) XXX_Merge(src proto.Message)
func (*ListObjectsRequest) XXX_Size ¶
func (m *ListObjectsRequest) XXX_Size() int
func (*ListObjectsRequest) XXX_Unmarshal ¶
func (m *ListObjectsRequest) XXX_Unmarshal(b []byte) error
type ListObjectsResponse ¶
type ListObjectsResponse struct { Objects []*deviced.Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListObjectsResponse) Descriptor ¶
func (*ListObjectsResponse) Descriptor() ([]byte, []int)
func (*ListObjectsResponse) GetObjects ¶
func (m *ListObjectsResponse) GetObjects() []*deviced.Object
func (*ListObjectsResponse) ProtoMessage ¶
func (*ListObjectsResponse) ProtoMessage()
func (*ListObjectsResponse) Reset ¶
func (m *ListObjectsResponse) Reset()
func (*ListObjectsResponse) String ¶
func (m *ListObjectsResponse) String() string
func (*ListObjectsResponse) Validate ¶
func (this *ListObjectsResponse) Validate() error
func (*ListObjectsResponse) XXX_DiscardUnknown ¶
func (m *ListObjectsResponse) XXX_DiscardUnknown()
func (*ListObjectsResponse) XXX_Marshal ¶
func (m *ListObjectsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListObjectsResponse) XXX_Merge ¶
func (m *ListObjectsResponse) XXX_Merge(src proto.Message)
func (*ListObjectsResponse) XXX_Size ¶
func (m *ListObjectsResponse) XXX_Size() int
func (*ListObjectsResponse) XXX_Unmarshal ¶
func (m *ListObjectsResponse) XXX_Unmarshal(b []byte) error
type PushFrameToFlowRequest ¶
type PushFrameToFlowRequest struct { Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are valid to be assigned to Request: // *PushFrameToFlowRequest_Config_ // *PushFrameToFlowRequest_Ping_ // *PushFrameToFlowRequest_Frame Request isPushFrameToFlowRequest_Request `protobuf_oneof:"request"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowRequest) Descriptor ¶
func (*PushFrameToFlowRequest) Descriptor() ([]byte, []int)
func (*PushFrameToFlowRequest) GetConfig ¶
func (m *PushFrameToFlowRequest) GetConfig() *PushFrameToFlowRequest_Config
func (*PushFrameToFlowRequest) GetFrame ¶
func (m *PushFrameToFlowRequest) GetFrame() *deviced.OpFrame
func (*PushFrameToFlowRequest) GetId ¶
func (m *PushFrameToFlowRequest) GetId() *wrappers.StringValue
func (*PushFrameToFlowRequest) GetPing ¶ added in v1.0.0
func (m *PushFrameToFlowRequest) GetPing() *PushFrameToFlowRequest_Ping
func (*PushFrameToFlowRequest) GetRequest ¶
func (m *PushFrameToFlowRequest) GetRequest() isPushFrameToFlowRequest_Request
func (*PushFrameToFlowRequest) ProtoMessage ¶
func (*PushFrameToFlowRequest) ProtoMessage()
func (*PushFrameToFlowRequest) Reset ¶
func (m *PushFrameToFlowRequest) Reset()
func (*PushFrameToFlowRequest) String ¶
func (m *PushFrameToFlowRequest) String() string
func (*PushFrameToFlowRequest) Validate ¶
func (this *PushFrameToFlowRequest) Validate() error
func (*PushFrameToFlowRequest) XXX_DiscardUnknown ¶
func (m *PushFrameToFlowRequest) XXX_DiscardUnknown()
func (*PushFrameToFlowRequest) XXX_Marshal ¶
func (m *PushFrameToFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowRequest) XXX_Merge ¶
func (m *PushFrameToFlowRequest) XXX_Merge(src proto.Message)
func (*PushFrameToFlowRequest) XXX_OneofWrappers ¶ added in v1.0.0
func (*PushFrameToFlowRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*PushFrameToFlowRequest) XXX_Size ¶
func (m *PushFrameToFlowRequest) XXX_Size() int
func (*PushFrameToFlowRequest) XXX_Unmarshal ¶
func (m *PushFrameToFlowRequest) XXX_Unmarshal(b []byte) error
type PushFrameToFlowRequest_Config ¶
type PushFrameToFlowRequest_Config struct { Flow *deviced.OpFlow `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"` ConfigAck *wrappers.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"` PushAck *wrappers.BoolValue `protobuf:"bytes,3,opt,name=push_ack,json=pushAck,proto3" json:"push_ack,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowRequest_Config) Descriptor ¶
func (*PushFrameToFlowRequest_Config) Descriptor() ([]byte, []int)
func (*PushFrameToFlowRequest_Config) GetConfigAck ¶
func (m *PushFrameToFlowRequest_Config) GetConfigAck() *wrappers.BoolValue
func (*PushFrameToFlowRequest_Config) GetFlow ¶
func (m *PushFrameToFlowRequest_Config) GetFlow() *deviced.OpFlow
func (*PushFrameToFlowRequest_Config) GetPushAck ¶
func (m *PushFrameToFlowRequest_Config) GetPushAck() *wrappers.BoolValue
func (*PushFrameToFlowRequest_Config) ProtoMessage ¶
func (*PushFrameToFlowRequest_Config) ProtoMessage()
func (*PushFrameToFlowRequest_Config) Reset ¶
func (m *PushFrameToFlowRequest_Config) Reset()
func (*PushFrameToFlowRequest_Config) String ¶
func (m *PushFrameToFlowRequest_Config) String() string
func (*PushFrameToFlowRequest_Config) Validate ¶
func (this *PushFrameToFlowRequest_Config) Validate() error
func (*PushFrameToFlowRequest_Config) XXX_DiscardUnknown ¶
func (m *PushFrameToFlowRequest_Config) XXX_DiscardUnknown()
func (*PushFrameToFlowRequest_Config) XXX_Marshal ¶
func (m *PushFrameToFlowRequest_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowRequest_Config) XXX_Merge ¶
func (m *PushFrameToFlowRequest_Config) XXX_Merge(src proto.Message)
func (*PushFrameToFlowRequest_Config) XXX_Size ¶
func (m *PushFrameToFlowRequest_Config) XXX_Size() int
func (*PushFrameToFlowRequest_Config) XXX_Unmarshal ¶
func (m *PushFrameToFlowRequest_Config) XXX_Unmarshal(b []byte) error
type PushFrameToFlowRequest_Config_ ¶
type PushFrameToFlowRequest_Config_ struct {
Config *PushFrameToFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}
type PushFrameToFlowRequest_Ping ¶ added in v1.0.0
type PushFrameToFlowRequest_Ping struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowRequest_Ping) Descriptor ¶ added in v1.0.0
func (*PushFrameToFlowRequest_Ping) Descriptor() ([]byte, []int)
func (*PushFrameToFlowRequest_Ping) ProtoMessage ¶ added in v1.0.0
func (*PushFrameToFlowRequest_Ping) ProtoMessage()
func (*PushFrameToFlowRequest_Ping) Reset ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) Reset()
func (*PushFrameToFlowRequest_Ping) String ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) String() string
func (*PushFrameToFlowRequest_Ping) Validate ¶ added in v1.0.0
func (this *PushFrameToFlowRequest_Ping) Validate() error
func (*PushFrameToFlowRequest_Ping) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) XXX_DiscardUnknown()
func (*PushFrameToFlowRequest_Ping) XXX_Marshal ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowRequest_Ping) XXX_Merge ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) XXX_Merge(src proto.Message)
func (*PushFrameToFlowRequest_Ping) XXX_Size ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) XXX_Size() int
func (*PushFrameToFlowRequest_Ping) XXX_Unmarshal ¶ added in v1.0.0
func (m *PushFrameToFlowRequest_Ping) XXX_Unmarshal(b []byte) error
type PushFrameToFlowRequest_Ping_ ¶ added in v1.0.0
type PushFrameToFlowRequest_Ping_ struct {
Ping *PushFrameToFlowRequest_Ping `protobuf:"bytes,3,opt,name=ping,proto3,oneof"`
}
type PushFrameToFlowResponse ¶
type PushFrameToFlowResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are valid to be assigned to Response: // *PushFrameToFlowResponse_Config_ // *PushFrameToFlowResponse_Pong_ // *PushFrameToFlowResponse_Ack_ Response isPushFrameToFlowResponse_Response `protobuf_oneof:"response"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowResponse) Descriptor ¶
func (*PushFrameToFlowResponse) Descriptor() ([]byte, []int)
func (*PushFrameToFlowResponse) GetAck ¶
func (m *PushFrameToFlowResponse) GetAck() *PushFrameToFlowResponse_Ack
func (*PushFrameToFlowResponse) GetConfig ¶ added in v1.0.0
func (m *PushFrameToFlowResponse) GetConfig() *PushFrameToFlowResponse_Config
func (*PushFrameToFlowResponse) GetId ¶
func (m *PushFrameToFlowResponse) GetId() string
func (*PushFrameToFlowResponse) GetPong ¶ added in v1.0.0
func (m *PushFrameToFlowResponse) GetPong() *PushFrameToFlowResponse_Pong
func (*PushFrameToFlowResponse) GetResponse ¶
func (m *PushFrameToFlowResponse) GetResponse() isPushFrameToFlowResponse_Response
func (*PushFrameToFlowResponse) ProtoMessage ¶
func (*PushFrameToFlowResponse) ProtoMessage()
func (*PushFrameToFlowResponse) Reset ¶
func (m *PushFrameToFlowResponse) Reset()
func (*PushFrameToFlowResponse) String ¶
func (m *PushFrameToFlowResponse) String() string
func (*PushFrameToFlowResponse) Validate ¶
func (this *PushFrameToFlowResponse) Validate() error
func (*PushFrameToFlowResponse) XXX_DiscardUnknown ¶
func (m *PushFrameToFlowResponse) XXX_DiscardUnknown()
func (*PushFrameToFlowResponse) XXX_Marshal ¶
func (m *PushFrameToFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowResponse) XXX_Merge ¶
func (m *PushFrameToFlowResponse) XXX_Merge(src proto.Message)
func (*PushFrameToFlowResponse) XXX_OneofWrappers ¶ added in v1.0.0
func (*PushFrameToFlowResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*PushFrameToFlowResponse) XXX_Size ¶
func (m *PushFrameToFlowResponse) XXX_Size() int
func (*PushFrameToFlowResponse) XXX_Unmarshal ¶
func (m *PushFrameToFlowResponse) XXX_Unmarshal(b []byte) error
type PushFrameToFlowResponse_Ack ¶
type PushFrameToFlowResponse_Ack struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowResponse_Ack) Descriptor ¶
func (*PushFrameToFlowResponse_Ack) Descriptor() ([]byte, []int)
func (*PushFrameToFlowResponse_Ack) ProtoMessage ¶
func (*PushFrameToFlowResponse_Ack) ProtoMessage()
func (*PushFrameToFlowResponse_Ack) Reset ¶
func (m *PushFrameToFlowResponse_Ack) Reset()
func (*PushFrameToFlowResponse_Ack) String ¶
func (m *PushFrameToFlowResponse_Ack) String() string
func (*PushFrameToFlowResponse_Ack) Validate ¶
func (this *PushFrameToFlowResponse_Ack) Validate() error
func (*PushFrameToFlowResponse_Ack) XXX_DiscardUnknown ¶
func (m *PushFrameToFlowResponse_Ack) XXX_DiscardUnknown()
func (*PushFrameToFlowResponse_Ack) XXX_Marshal ¶
func (m *PushFrameToFlowResponse_Ack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowResponse_Ack) XXX_Merge ¶
func (m *PushFrameToFlowResponse_Ack) XXX_Merge(src proto.Message)
func (*PushFrameToFlowResponse_Ack) XXX_Size ¶
func (m *PushFrameToFlowResponse_Ack) XXX_Size() int
func (*PushFrameToFlowResponse_Ack) XXX_Unmarshal ¶
func (m *PushFrameToFlowResponse_Ack) XXX_Unmarshal(b []byte) error
type PushFrameToFlowResponse_Ack_ ¶
type PushFrameToFlowResponse_Ack_ struct {
Ack *PushFrameToFlowResponse_Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof"`
}
type PushFrameToFlowResponse_Config ¶ added in v1.0.0
type PushFrameToFlowResponse_Config struct { Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowResponse_Config) Descriptor ¶ added in v1.0.0
func (*PushFrameToFlowResponse_Config) Descriptor() ([]byte, []int)
func (*PushFrameToFlowResponse_Config) GetSession ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) GetSession() string
func (*PushFrameToFlowResponse_Config) ProtoMessage ¶ added in v1.0.0
func (*PushFrameToFlowResponse_Config) ProtoMessage()
func (*PushFrameToFlowResponse_Config) Reset ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) Reset()
func (*PushFrameToFlowResponse_Config) String ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) String() string
func (*PushFrameToFlowResponse_Config) Validate ¶ added in v1.0.0
func (this *PushFrameToFlowResponse_Config) Validate() error
func (*PushFrameToFlowResponse_Config) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) XXX_DiscardUnknown()
func (*PushFrameToFlowResponse_Config) XXX_Marshal ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowResponse_Config) XXX_Merge ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) XXX_Merge(src proto.Message)
func (*PushFrameToFlowResponse_Config) XXX_Size ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) XXX_Size() int
func (*PushFrameToFlowResponse_Config) XXX_Unmarshal ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Config) XXX_Unmarshal(b []byte) error
type PushFrameToFlowResponse_Config_ ¶ added in v1.0.0
type PushFrameToFlowResponse_Config_ struct {
Config *PushFrameToFlowResponse_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}
type PushFrameToFlowResponse_Pong ¶ added in v1.0.0
type PushFrameToFlowResponse_Pong struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushFrameToFlowResponse_Pong) Descriptor ¶ added in v1.0.0
func (*PushFrameToFlowResponse_Pong) Descriptor() ([]byte, []int)
func (*PushFrameToFlowResponse_Pong) ProtoMessage ¶ added in v1.0.0
func (*PushFrameToFlowResponse_Pong) ProtoMessage()
func (*PushFrameToFlowResponse_Pong) Reset ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) Reset()
func (*PushFrameToFlowResponse_Pong) String ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) String() string
func (*PushFrameToFlowResponse_Pong) Validate ¶ added in v1.0.0
func (this *PushFrameToFlowResponse_Pong) Validate() error
func (*PushFrameToFlowResponse_Pong) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) XXX_DiscardUnknown()
func (*PushFrameToFlowResponse_Pong) XXX_Marshal ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushFrameToFlowResponse_Pong) XXX_Merge ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) XXX_Merge(src proto.Message)
func (*PushFrameToFlowResponse_Pong) XXX_Size ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) XXX_Size() int
func (*PushFrameToFlowResponse_Pong) XXX_Unmarshal ¶ added in v1.0.0
func (m *PushFrameToFlowResponse_Pong) XXX_Unmarshal(b []byte) error
type PushFrameToFlowResponse_Pong_ ¶ added in v1.0.0
type PushFrameToFlowResponse_Pong_ struct {
Pong *PushFrameToFlowResponse_Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}
type PutObjectRequest ¶
type PutObjectRequest struct { Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` Content *wrappers.BytesValue `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PutObjectRequest) Descriptor ¶
func (*PutObjectRequest) Descriptor() ([]byte, []int)
func (*PutObjectRequest) GetContent ¶
func (m *PutObjectRequest) GetContent() *wrappers.BytesValue
func (*PutObjectRequest) GetObject ¶
func (m *PutObjectRequest) GetObject() *deviced.OpObject
func (*PutObjectRequest) ProtoMessage ¶
func (*PutObjectRequest) ProtoMessage()
func (*PutObjectRequest) Reset ¶
func (m *PutObjectRequest) Reset()
func (*PutObjectRequest) String ¶
func (m *PutObjectRequest) String() string
func (*PutObjectRequest) Validate ¶
func (this *PutObjectRequest) Validate() error
func (*PutObjectRequest) XXX_DiscardUnknown ¶
func (m *PutObjectRequest) XXX_DiscardUnknown()
func (*PutObjectRequest) XXX_Marshal ¶
func (m *PutObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutObjectRequest) XXX_Merge ¶
func (m *PutObjectRequest) XXX_Merge(src proto.Message)
func (*PutObjectRequest) XXX_Size ¶
func (m *PutObjectRequest) XXX_Size() int
func (*PutObjectRequest) XXX_Unmarshal ¶
func (m *PutObjectRequest) XXX_Unmarshal(b []byte) error
type RemoveObjectRequest ¶
type RemoveObjectRequest struct { Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoveObjectRequest) Descriptor ¶
func (*RemoveObjectRequest) Descriptor() ([]byte, []int)
func (*RemoveObjectRequest) GetObject ¶
func (m *RemoveObjectRequest) GetObject() *deviced.OpObject
func (*RemoveObjectRequest) ProtoMessage ¶
func (*RemoveObjectRequest) ProtoMessage()
func (*RemoveObjectRequest) Reset ¶
func (m *RemoveObjectRequest) Reset()
func (*RemoveObjectRequest) String ¶
func (m *RemoveObjectRequest) String() string
func (*RemoveObjectRequest) Validate ¶
func (this *RemoveObjectRequest) Validate() error
func (*RemoveObjectRequest) XXX_DiscardUnknown ¶
func (m *RemoveObjectRequest) XXX_DiscardUnknown()
func (*RemoveObjectRequest) XXX_Marshal ¶
func (m *RemoveObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveObjectRequest) XXX_Merge ¶
func (m *RemoveObjectRequest) XXX_Merge(src proto.Message)
func (*RemoveObjectRequest) XXX_Size ¶
func (m *RemoveObjectRequest) XXX_Size() int
func (*RemoveObjectRequest) XXX_Unmarshal ¶
func (m *RemoveObjectRequest) XXX_Unmarshal(b []byte) error
type RenameObjectRequest ¶
type RenameObjectRequest struct { Source *deviced.OpObject `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Destination *deviced.OpObject `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RenameObjectRequest) Descriptor ¶
func (*RenameObjectRequest) Descriptor() ([]byte, []int)
func (*RenameObjectRequest) GetDestination ¶
func (m *RenameObjectRequest) GetDestination() *deviced.OpObject
func (*RenameObjectRequest) GetSource ¶
func (m *RenameObjectRequest) GetSource() *deviced.OpObject
func (*RenameObjectRequest) ProtoMessage ¶
func (*RenameObjectRequest) ProtoMessage()
func (*RenameObjectRequest) Reset ¶
func (m *RenameObjectRequest) Reset()
func (*RenameObjectRequest) String ¶
func (m *RenameObjectRequest) String() string
func (*RenameObjectRequest) Validate ¶
func (this *RenameObjectRequest) Validate() error
func (*RenameObjectRequest) XXX_DiscardUnknown ¶
func (m *RenameObjectRequest) XXX_DiscardUnknown()
func (*RenameObjectRequest) XXX_Marshal ¶
func (m *RenameObjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RenameObjectRequest) XXX_Merge ¶
func (m *RenameObjectRequest) XXX_Merge(src proto.Message)
func (*RenameObjectRequest) XXX_Size ¶
func (m *RenameObjectRequest) XXX_Size() int
func (*RenameObjectRequest) XXX_Unmarshal ¶
func (m *RenameObjectRequest) XXX_Unmarshal(b []byte) error
type ShowModuleResponse ¶
type ShowModuleResponse struct { Module *deviced.Module `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ShowModuleResponse) Descriptor ¶
func (*ShowModuleResponse) Descriptor() ([]byte, []int)
func (*ShowModuleResponse) GetModule ¶
func (m *ShowModuleResponse) GetModule() *deviced.Module
func (*ShowModuleResponse) ProtoMessage ¶
func (*ShowModuleResponse) ProtoMessage()
func (*ShowModuleResponse) Reset ¶
func (m *ShowModuleResponse) Reset()
func (*ShowModuleResponse) String ¶
func (m *ShowModuleResponse) String() string
func (*ShowModuleResponse) Validate ¶
func (this *ShowModuleResponse) Validate() error
func (*ShowModuleResponse) XXX_DiscardUnknown ¶
func (m *ShowModuleResponse) XXX_DiscardUnknown()
func (*ShowModuleResponse) XXX_Marshal ¶
func (m *ShowModuleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowModuleResponse) XXX_Merge ¶
func (m *ShowModuleResponse) XXX_Merge(src proto.Message)
func (*ShowModuleResponse) XXX_Size ¶
func (m *ShowModuleResponse) XXX_Size() int
func (*ShowModuleResponse) XXX_Unmarshal ¶
func (m *ShowModuleResponse) XXX_Unmarshal(b []byte) error
type UnimplementedDeviceServiceServer ¶ added in v1.0.0
type UnimplementedDeviceServiceServer struct { }
UnimplementedDeviceServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedDeviceServiceServer) GetObject ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) GetObject(ctx context.Context, req *GetObjectRequest) (*GetObjectResponse, error)
func (*UnimplementedDeviceServiceServer) GetObjectContent ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) GetObjectContent(ctx context.Context, req *GetObjectContentRequest) (*GetObjectContentResponse, error)
func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent(ctx context.Context, req *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)
func (*UnimplementedDeviceServiceServer) Heartbeat ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) Heartbeat(ctx context.Context, req *HeartbeatRequest) (*empty.Empty, error)
func (*UnimplementedDeviceServiceServer) IssueModuleToken ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) IssueModuleToken(ctx context.Context, req *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)
func (*UnimplementedDeviceServiceServer) ListObjects ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) ListObjects(ctx context.Context, req *ListObjectsRequest) (*ListObjectsResponse, error)
func (*UnimplementedDeviceServiceServer) PushFrameToFlow ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) PushFrameToFlow(srv DeviceService_PushFrameToFlowServer) error
func (*UnimplementedDeviceServiceServer) PutObject ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) PutObject(ctx context.Context, req *PutObjectRequest) (*empty.Empty, error)
func (*UnimplementedDeviceServiceServer) RemoveObject ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) RemoveObject(ctx context.Context, req *RemoveObjectRequest) (*empty.Empty, error)
func (*UnimplementedDeviceServiceServer) RenameObject ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) RenameObject(ctx context.Context, req *RenameObjectRequest) (*empty.Empty, error)
func (*UnimplementedDeviceServiceServer) ShowModule ¶ added in v1.0.0
func (*UnimplementedDeviceServiceServer) ShowModule(ctx context.Context, req *empty.Empty) (*ShowModuleResponse, error)
Source Files ¶
- get_object.pb.go
- get_object.validator.pb.go
- get_object_content.pb.go
- get_object_content.validator.pb.go
- get_object_streaming_content.pb.go
- get_object_streaming_content.validator.pb.go
- heartbeat.pb.go
- heartbeat.validator.pb.go
- issue_module_token.pb.go
- issue_module_token.validator.pb.go
- list_objects.pb.go
- list_objects.validator.pb.go
- push_frame_to_flow.pb.go
- push_frame_to_flow.validator.pb.go
- put_object.pb.go
- put_object.validator.pb.go
- remove_object.pb.go
- remove_object.validator.pb.go
- rename_object.pb.go
- rename_object.validator.pb.go
- service.pb.go
- service.validator.pb.go
- show_module.pb.go
- show_module.validator.pb.go
Click to show internal directories.
Click to hide internal directories.