device

package
v1.2.15-1 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_get_object_content_proto protoreflect.FileDescriptor
View Source 
var File_get_object_proto protoreflect.FileDescriptor
View Source 
var File_get_object_streaming_content_proto protoreflect.FileDescriptor
View Source 
var File_heartbeat_proto protoreflect.FileDescriptor
View Source 
var File_issue_module_token_proto protoreflect.FileDescriptor
View Source 
var File_list_objects_proto protoreflect.FileDescriptor
View Source 
var File_push_frame_to_flow_once_proto protoreflect.FileDescriptor
View Source 
var File_push_frame_to_flow_proto protoreflect.FileDescriptor
View Source 
var File_put_object_proto protoreflect.FileDescriptor
View Source 
var File_put_object_streaming_proto protoreflect.FileDescriptor
View Source 
var File_remove_object_proto protoreflect.FileDescriptor
View Source 
var File_rename_object_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var File_show_module_firmware_descriptor_proto protoreflect.FileDescriptor
View Source 
var File_show_module_proto protoreflect.FileDescriptor

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 *emptypb.Empty, opts ...grpc.CallOption) (*ShowModuleResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PushFrameToFlow(ctx context.Context, opts ...grpc.CallOption) (DeviceService_PushFrameToFlowClient, error)
	PushFrameToFlowOnce(ctx context.Context, in *PushFrameToFlowOnceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PutObjectStreaming(ctx context.Context, opts ...grpc.CallOption) (DeviceService_PutObjectStreamingClient, error)
	RemoveObject(ctx context.Context, in *RemoveObjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RenameObject(ctx context.Context, in *RenameObjectRequest, opts ...grpc.CallOption) (*emptypb.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)
	ShowModuleFirmwareDescriptor(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ShowModuleFirmwareDescriptorResponse, 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.ClientConnInterface) DeviceServiceClient

type DeviceServiceServer 

type DeviceServiceServer interface {
	IssueModuleToken(context.Context, *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)
	ShowModule(context.Context, *emptypb.Empty) (*ShowModuleResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*emptypb.Empty, error)
	PushFrameToFlow(DeviceService_PushFrameToFlowServer) error
	PushFrameToFlowOnce(context.Context, *PushFrameToFlowOnceRequest) (*emptypb.Empty, error)
	PutObject(context.Context, *PutObjectRequest) (*emptypb.Empty, error)
	PutObjectStreaming(DeviceService_PutObjectStreamingServer) error
	RemoveObject(context.Context, *RemoveObjectRequest) (*emptypb.Empty, error)
	RenameObject(context.Context, *RenameObjectRequest) (*emptypb.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)
	ShowModuleFirmwareDescriptor(context.Context, *emptypb.Empty) (*ShowModuleFirmwareDescriptorResponse, 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 DeviceService_PutObjectStreamingClient 

type DeviceService_PutObjectStreamingClient interface {
	Send(*PutObjectStreamingRequest) error
	Recv() (*PutObjectStreamingResponse, error)
	grpc.ClientStream
}

type DeviceService_PutObjectStreamingServer 

type DeviceService_PutObjectStreamingServer interface {
	Send(*PutObjectStreamingResponse) error
	Recv() (*PutObjectStreamingRequest, error)
	grpc.ServerStream
}

type GetObjectContentRequest 

type GetObjectContentRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectContentRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectContentRequest.ProtoReflect.Descriptor instead.

func (*GetObjectContentRequest) GetObject 

func (x *GetObjectContentRequest) GetObject() *deviced.OpObject

func (*GetObjectContentRequest) ProtoMessage 

func (*GetObjectContentRequest) ProtoMessage()

func (*GetObjectContentRequest) ProtoReflect added in v1.2.14 

func (x *GetObjectContentRequest) ProtoReflect() protoreflect.Message

func (*GetObjectContentRequest) Reset 

func (x *GetObjectContentRequest) Reset()

func (*GetObjectContentRequest) String 

func (x *GetObjectContentRequest) String() string

type GetObjectContentResponse 

type GetObjectContentResponse struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectContentResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectContentResponse.ProtoReflect.Descriptor instead.

func (*GetObjectContentResponse) GetContent 

func (x *GetObjectContentResponse) GetContent() []byte

func (*GetObjectContentResponse) ProtoMessage 

func (*GetObjectContentResponse) ProtoMessage()

func (*GetObjectContentResponse) ProtoReflect added in v1.2.14 

func (x *GetObjectContentResponse) ProtoReflect() protoreflect.Message

func (*GetObjectContentResponse) Reset 

func (x *GetObjectContentResponse) Reset()

func (*GetObjectContentResponse) String 

func (x *GetObjectContentResponse) String() string

type GetObjectRequest 

type GetObjectRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectRequest.ProtoReflect.Descriptor instead.

func (*GetObjectRequest) GetObject 

func (x *GetObjectRequest) GetObject() *deviced.OpObject

func (*GetObjectRequest) ProtoMessage 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) ProtoReflect added in v1.2.14 

func (x *GetObjectRequest) ProtoReflect() protoreflect.Message

func (*GetObjectRequest) Reset 

func (x *GetObjectRequest) Reset()

func (*GetObjectRequest) String 

func (x *GetObjectRequest) String() string

type GetObjectResponse 

type GetObjectResponse struct {
	Object *deviced.Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectResponse.ProtoReflect.Descriptor instead.

func (*GetObjectResponse) GetObject 

func (x *GetObjectResponse) GetObject() *deviced.Object

func (*GetObjectResponse) ProtoMessage 

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) ProtoReflect added in v1.2.14 

func (x *GetObjectResponse) ProtoReflect() protoreflect.Message

func (*GetObjectResponse) Reset 

func (x *GetObjectResponse) Reset()

func (*GetObjectResponse) String 

func (x *GetObjectResponse) String() string

type GetObjectStreamingContentRequest 

type GetObjectStreamingContentRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectStreamingContentRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectStreamingContentRequest.ProtoReflect.Descriptor instead.

func (*GetObjectStreamingContentRequest) GetObject 

func (x *GetObjectStreamingContentRequest) GetObject() *deviced.OpObject

func (*GetObjectStreamingContentRequest) ProtoMessage 

func (*GetObjectStreamingContentRequest) ProtoMessage()

func (*GetObjectStreamingContentRequest) ProtoReflect added in v1.2.14 

func (x *GetObjectStreamingContentRequest) ProtoReflect() protoreflect.Message

func (*GetObjectStreamingContentRequest) Reset 

func (x *GetObjectStreamingContentRequest) Reset()

func (*GetObjectStreamingContentRequest) String 

func (x *GetObjectStreamingContentRequest) String() string

type GetObjectStreamingContentResponse 

type GetObjectStreamingContentResponse struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectStreamingContentResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectStreamingContentResponse.ProtoReflect.Descriptor instead.

func (*GetObjectStreamingContentResponse) GetContent 

func (x *GetObjectStreamingContentResponse) GetContent() []byte

func (*GetObjectStreamingContentResponse) ProtoMessage 

func (*GetObjectStreamingContentResponse) ProtoMessage()

func (*GetObjectStreamingContentResponse) ProtoReflect added in v1.2.14 

func (x *GetObjectStreamingContentResponse) ProtoReflect() protoreflect.Message

func (*GetObjectStreamingContentResponse) Reset 

func (x *GetObjectStreamingContentResponse) Reset()

func (*GetObjectStreamingContentResponse) String 

func (x *GetObjectStreamingContentResponse) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Module *deviced.OpModule `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetModule 

func (x *HeartbeatRequest) GetModule() *deviced.OpModule

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect added in v1.2.14 

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type IssueModuleTokenRequest 

type IssueModuleTokenRequest struct {
	Credential *identityd2.OpCredential `protobuf:"bytes,1,opt,name=credential,proto3" json:"credential,omitempty"`
	Timestamp  *timestamppb.Timestamp   `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Nonce      *wrapperspb.Int64Value   `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Hmac       *wrapperspb.StringValue  `protobuf:"bytes,4,opt,name=hmac,proto3" json:"hmac,omitempty"`
	// contains filtered or unexported fields
}

func (*IssueModuleTokenRequest) Descriptor deprecated 

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

Deprecated: Use IssueModuleTokenRequest.ProtoReflect.Descriptor instead.

func (*IssueModuleTokenRequest) GetCredential 

func (x *IssueModuleTokenRequest) GetCredential() *identityd2.OpCredential

func (*IssueModuleTokenRequest) GetHmac 

func (x *IssueModuleTokenRequest) GetHmac() *wrapperspb.StringValue

func (*IssueModuleTokenRequest) GetNonce 

func (x *IssueModuleTokenRequest) GetNonce() *wrapperspb.Int64Value

func (*IssueModuleTokenRequest) GetTimestamp 

func (x *IssueModuleTokenRequest) GetTimestamp() *timestamppb.Timestamp

func (*IssueModuleTokenRequest) ProtoMessage 

func (*IssueModuleTokenRequest) ProtoMessage()

func (*IssueModuleTokenRequest) ProtoReflect added in v1.2.14 

func (x *IssueModuleTokenRequest) ProtoReflect() protoreflect.Message

func (*IssueModuleTokenRequest) Reset 

func (x *IssueModuleTokenRequest) Reset()

func (*IssueModuleTokenRequest) String 

func (x *IssueModuleTokenRequest) String() string

type IssueModuleTokenResponse 

type IssueModuleTokenResponse struct {
	Token *identityd2.Token `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*IssueModuleTokenResponse) Descriptor deprecated 

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

Deprecated: Use IssueModuleTokenResponse.ProtoReflect.Descriptor instead.

func (*IssueModuleTokenResponse) GetToken 

func (x *IssueModuleTokenResponse) GetToken() *identityd2.Token

func (*IssueModuleTokenResponse) ProtoMessage 

func (*IssueModuleTokenResponse) ProtoMessage()

func (*IssueModuleTokenResponse) ProtoReflect added in v1.2.14 

func (x *IssueModuleTokenResponse) ProtoReflect() protoreflect.Message

func (*IssueModuleTokenResponse) Reset 

func (x *IssueModuleTokenResponse) Reset()

func (*IssueModuleTokenResponse) String 

func (x *IssueModuleTokenResponse) String() string

type ListObjectsRequest 

type ListObjectsRequest struct {
	Object    *deviced.OpObject      `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Recursive *wrapperspb.BoolValue  `protobuf:"bytes,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	Depth     *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=depth,proto3" json:"depth,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListObjectsRequest) GetDepth added in v1.2.9 

func (x *ListObjectsRequest) GetDepth() *wrapperspb.Int32Value

func (*ListObjectsRequest) GetObject 

func (x *ListObjectsRequest) GetObject() *deviced.OpObject

func (*ListObjectsRequest) GetRecursive added in v1.2.9 

func (x *ListObjectsRequest) GetRecursive() *wrapperspb.BoolValue

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) ProtoReflect added in v1.2.14 

func (x *ListObjectsRequest) ProtoReflect() protoreflect.Message

func (*ListObjectsRequest) Reset 

func (x *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String 

func (x *ListObjectsRequest) String() string

type ListObjectsResponse 

type ListObjectsResponse struct {
	Objects []*deviced.Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListObjectsResponse) GetObjects 

func (x *ListObjectsResponse) GetObjects() []*deviced.Object

func (*ListObjectsResponse) ProtoMessage 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) ProtoReflect added in v1.2.14 

func (x *ListObjectsResponse) ProtoReflect() protoreflect.Message

func (*ListObjectsResponse) Reset 

func (x *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String 

func (x *ListObjectsResponse) String() string

type PushFrameToFlowOnceRequest added in v1.2.9 

type PushFrameToFlowOnceRequest struct {
	Id    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Flow  *deviced.OpFlow         `protobuf:"bytes,2,opt,name=flow,proto3" json:"flow,omitempty"`
	Frame *deviced.OpFrame        `protobuf:"bytes,3,opt,name=frame,proto3" json:"frame,omitempty"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowOnceRequest) Descriptor deprecated added in v1.2.9 

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

Deprecated: Use PushFrameToFlowOnceRequest.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowOnceRequest) GetFlow added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) GetFlow() *deviced.OpFlow

func (*PushFrameToFlowOnceRequest) GetFrame added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) GetFrame() *deviced.OpFrame

func (*PushFrameToFlowOnceRequest) GetId added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) GetId() *wrapperspb.StringValue

func (*PushFrameToFlowOnceRequest) ProtoMessage added in v1.2.9 

func (*PushFrameToFlowOnceRequest) ProtoMessage()

func (*PushFrameToFlowOnceRequest) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowOnceRequest) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowOnceRequest) Reset added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) Reset()

func (*PushFrameToFlowOnceRequest) String added in v1.2.9 

func (x *PushFrameToFlowOnceRequest) String() string

type PushFrameToFlowRequest 

type PushFrameToFlowRequest struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//	*PushFrameToFlowRequest_Config_
	//	*PushFrameToFlowRequest_Ping_
	//	*PushFrameToFlowRequest_Frame
	Request isPushFrameToFlowRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowRequest) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowRequest.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowRequest) GetConfig 

func (x *PushFrameToFlowRequest) GetConfig() *PushFrameToFlowRequest_Config

func (*PushFrameToFlowRequest) GetFrame 

func (x *PushFrameToFlowRequest) GetFrame() *deviced.OpFrame

func (*PushFrameToFlowRequest) GetId 

func (x *PushFrameToFlowRequest) GetId() *wrapperspb.StringValue

func (*PushFrameToFlowRequest) GetPing 

func (x *PushFrameToFlowRequest) GetPing() *PushFrameToFlowRequest_Ping

func (*PushFrameToFlowRequest) GetRequest 

func (m *PushFrameToFlowRequest) GetRequest() isPushFrameToFlowRequest_Request

func (*PushFrameToFlowRequest) ProtoMessage 

func (*PushFrameToFlowRequest) ProtoMessage()

func (*PushFrameToFlowRequest) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowRequest) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowRequest) Reset 

func (x *PushFrameToFlowRequest) Reset()

func (*PushFrameToFlowRequest) String 

func (x *PushFrameToFlowRequest) String() string

type PushFrameToFlowRequest_Config 

type PushFrameToFlowRequest_Config struct {
	Flow      *deviced.OpFlow       `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	ConfigAck *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	PushAck   *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=push_ack,json=pushAck,proto3" json:"push_ack,omitempty"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowRequest_Config) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowRequest_Config.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowRequest_Config) GetConfigAck 

func (x *PushFrameToFlowRequest_Config) GetConfigAck() *wrapperspb.BoolValue

func (*PushFrameToFlowRequest_Config) GetFlow 

func (x *PushFrameToFlowRequest_Config) GetFlow() *deviced.OpFlow

func (*PushFrameToFlowRequest_Config) GetPushAck 

func (x *PushFrameToFlowRequest_Config) GetPushAck() *wrapperspb.BoolValue

func (*PushFrameToFlowRequest_Config) ProtoMessage 

func (*PushFrameToFlowRequest_Config) ProtoMessage()

func (*PushFrameToFlowRequest_Config) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowRequest_Config) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowRequest_Config) Reset 

func (x *PushFrameToFlowRequest_Config) Reset()

func (*PushFrameToFlowRequest_Config) String 

func (x *PushFrameToFlowRequest_Config) String() string

type PushFrameToFlowRequest_Config_ 

type PushFrameToFlowRequest_Config_ struct {
	Config *PushFrameToFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PushFrameToFlowRequest_Frame 

type PushFrameToFlowRequest_Frame struct {
	Frame *deviced.OpFrame `protobuf:"bytes,4,opt,name=frame,proto3,oneof"`
}

type PushFrameToFlowRequest_Ping 

type PushFrameToFlowRequest_Ping struct {
	// contains filtered or unexported fields
}

func (*PushFrameToFlowRequest_Ping) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowRequest_Ping.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowRequest_Ping) ProtoMessage 

func (*PushFrameToFlowRequest_Ping) ProtoMessage()

func (*PushFrameToFlowRequest_Ping) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowRequest_Ping) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowRequest_Ping) Reset 

func (x *PushFrameToFlowRequest_Ping) Reset()

func (*PushFrameToFlowRequest_Ping) String 

func (x *PushFrameToFlowRequest_Ping) String() string

type PushFrameToFlowRequest_Ping_ 

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 assignable to Response:
	//	*PushFrameToFlowResponse_Config_
	//	*PushFrameToFlowResponse_Pong_
	//	*PushFrameToFlowResponse_Ack_
	Response isPushFrameToFlowResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowResponse) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse) GetAck 

func (x *PushFrameToFlowResponse) GetAck() *PushFrameToFlowResponse_Ack

func (*PushFrameToFlowResponse) GetConfig 

func (x *PushFrameToFlowResponse) GetConfig() *PushFrameToFlowResponse_Config

func (*PushFrameToFlowResponse) GetId 

func (x *PushFrameToFlowResponse) GetId() string

func (*PushFrameToFlowResponse) GetPong 

func (x *PushFrameToFlowResponse) GetPong() *PushFrameToFlowResponse_Pong

func (*PushFrameToFlowResponse) GetResponse 

func (m *PushFrameToFlowResponse) GetResponse() isPushFrameToFlowResponse_Response

func (*PushFrameToFlowResponse) ProtoMessage 

func (*PushFrameToFlowResponse) ProtoMessage()

func (*PushFrameToFlowResponse) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowResponse) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowResponse) Reset 

func (x *PushFrameToFlowResponse) Reset()

func (*PushFrameToFlowResponse) String 

func (x *PushFrameToFlowResponse) String() string

type PushFrameToFlowResponse_Ack 

type PushFrameToFlowResponse_Ack struct {
	// contains filtered or unexported fields
}

func (*PushFrameToFlowResponse_Ack) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse_Ack.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse_Ack) ProtoMessage 

func (*PushFrameToFlowResponse_Ack) ProtoMessage()

func (*PushFrameToFlowResponse_Ack) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowResponse_Ack) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowResponse_Ack) Reset 

func (x *PushFrameToFlowResponse_Ack) Reset()

func (*PushFrameToFlowResponse_Ack) String 

func (x *PushFrameToFlowResponse_Ack) String() string

type PushFrameToFlowResponse_Ack_ 

type PushFrameToFlowResponse_Ack_ struct {
	Ack *PushFrameToFlowResponse_Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof"`
}

type PushFrameToFlowResponse_Config 

type PushFrameToFlowResponse_Config struct {
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*PushFrameToFlowResponse_Config) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse_Config.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse_Config) GetSession 

func (x *PushFrameToFlowResponse_Config) GetSession() string

func (*PushFrameToFlowResponse_Config) ProtoMessage 

func (*PushFrameToFlowResponse_Config) ProtoMessage()

func (*PushFrameToFlowResponse_Config) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowResponse_Config) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowResponse_Config) Reset 

func (x *PushFrameToFlowResponse_Config) Reset()

func (*PushFrameToFlowResponse_Config) String 

func (x *PushFrameToFlowResponse_Config) String() string

type PushFrameToFlowResponse_Config_ 

type PushFrameToFlowResponse_Config_ struct {
	Config *PushFrameToFlowResponse_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PushFrameToFlowResponse_Pong 

type PushFrameToFlowResponse_Pong struct {
	// contains filtered or unexported fields
}

func (*PushFrameToFlowResponse_Pong) Descriptor deprecated 

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

Deprecated: Use PushFrameToFlowResponse_Pong.ProtoReflect.Descriptor instead.

func (*PushFrameToFlowResponse_Pong) ProtoMessage 

func (*PushFrameToFlowResponse_Pong) ProtoMessage()

func (*PushFrameToFlowResponse_Pong) ProtoReflect added in v1.2.14 

func (x *PushFrameToFlowResponse_Pong) ProtoReflect() protoreflect.Message

func (*PushFrameToFlowResponse_Pong) Reset 

func (x *PushFrameToFlowResponse_Pong) Reset()

func (*PushFrameToFlowResponse_Pong) String 

func (x *PushFrameToFlowResponse_Pong) String() string

type PushFrameToFlowResponse_Pong_ 

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 *wrapperspb.BytesValue `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectRequest) Descriptor deprecated 

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

Deprecated: Use PutObjectRequest.ProtoReflect.Descriptor instead.

func (*PutObjectRequest) GetContent 

func (x *PutObjectRequest) GetContent() *wrapperspb.BytesValue

func (*PutObjectRequest) GetObject 

func (x *PutObjectRequest) GetObject() *deviced.OpObject

func (*PutObjectRequest) ProtoMessage 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) ProtoReflect added in v1.2.14 

func (x *PutObjectRequest) ProtoReflect() protoreflect.Message

func (*PutObjectRequest) Reset 

func (x *PutObjectRequest) Reset()

func (*PutObjectRequest) String 

func (x *PutObjectRequest) String() string

type PutObjectStreamingRequest 

type PutObjectStreamingRequest struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//	*PutObjectStreamingRequest_Metadata_
	//	*PutObjectStreamingRequest_Chunks
	Request isPutObjectStreamingRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*PutObjectStreamingRequest) Descriptor deprecated 

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

Deprecated: Use PutObjectStreamingRequest.ProtoReflect.Descriptor instead.

func (*PutObjectStreamingRequest) GetChunks 

func (x *PutObjectStreamingRequest) GetChunks() *deviced.OpObjectChunks

func (*PutObjectStreamingRequest) GetId 

func (x *PutObjectStreamingRequest) GetId() *wrapperspb.StringValue

func (*PutObjectStreamingRequest) GetMetadata 

func (x *PutObjectStreamingRequest) GetMetadata() *PutObjectStreamingRequest_Metadata

func (*PutObjectStreamingRequest) GetRequest 

func (m *PutObjectStreamingRequest) GetRequest() isPutObjectStreamingRequest_Request

func (*PutObjectStreamingRequest) ProtoMessage 

func (*PutObjectStreamingRequest) ProtoMessage()

func (*PutObjectStreamingRequest) ProtoReflect added in v1.2.14 

func (x *PutObjectStreamingRequest) ProtoReflect() protoreflect.Message

func (*PutObjectStreamingRequest) Reset 

func (x *PutObjectStreamingRequest) Reset()

func (*PutObjectStreamingRequest) String 

func (x *PutObjectStreamingRequest) String() string

type PutObjectStreamingRequest_Chunks 

type PutObjectStreamingRequest_Chunks struct {
	Chunks *deviced.OpObjectChunks `protobuf:"bytes,3,opt,name=chunks,proto3,oneof"`
}

type PutObjectStreamingRequest_Metadata 

type PutObjectStreamingRequest_Metadata struct {
	Object *deviced.OpObject       `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Sha1   *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=sha1,proto3" json:"sha1,omitempty"`
	// contains filtered or unexported fields
}

func (*PutObjectStreamingRequest_Metadata) Descriptor deprecated 

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

Deprecated: Use PutObjectStreamingRequest_Metadata.ProtoReflect.Descriptor instead.

func (*PutObjectStreamingRequest_Metadata) GetObject 

func (x *PutObjectStreamingRequest_Metadata) GetObject() *deviced.OpObject

func (*PutObjectStreamingRequest_Metadata) GetSha1 

func (x *PutObjectStreamingRequest_Metadata) GetSha1() *wrapperspb.StringValue

func (*PutObjectStreamingRequest_Metadata) ProtoMessage 

func (*PutObjectStreamingRequest_Metadata) ProtoMessage()

func (*PutObjectStreamingRequest_Metadata) ProtoReflect added in v1.2.14 

func (x *PutObjectStreamingRequest_Metadata) ProtoReflect() protoreflect.Message

func (*PutObjectStreamingRequest_Metadata) Reset 

func (x *PutObjectStreamingRequest_Metadata) Reset()

func (*PutObjectStreamingRequest_Metadata) String 

func (x *PutObjectStreamingRequest_Metadata) String() string

type PutObjectStreamingRequest_Metadata_ 

type PutObjectStreamingRequest_Metadata_ struct {
	Metadata *PutObjectStreamingRequest_Metadata `protobuf:"bytes,2,opt,name=metadata,proto3,oneof"`
}

type PutObjectStreamingResponse 

type PutObjectStreamingResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Response:
	//	*PutObjectStreamingResponse_Chunks
	Response isPutObjectStreamingResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*PutObjectStreamingResponse) Descriptor deprecated 

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

Deprecated: Use PutObjectStreamingResponse.ProtoReflect.Descriptor instead.

func (*PutObjectStreamingResponse) GetChunks 

func (x *PutObjectStreamingResponse) GetChunks() *deviced.ObjectChunks

func (*PutObjectStreamingResponse) GetId 

func (x *PutObjectStreamingResponse) GetId() string

func (*PutObjectStreamingResponse) GetResponse 

func (m *PutObjectStreamingResponse) GetResponse() isPutObjectStreamingResponse_Response

func (*PutObjectStreamingResponse) ProtoMessage 

func (*PutObjectStreamingResponse) ProtoMessage()

func (*PutObjectStreamingResponse) ProtoReflect added in v1.2.14 

func (x *PutObjectStreamingResponse) ProtoReflect() protoreflect.Message

func (*PutObjectStreamingResponse) Reset 

func (x *PutObjectStreamingResponse) Reset()

func (*PutObjectStreamingResponse) String 

func (x *PutObjectStreamingResponse) String() string

type PutObjectStreamingResponse_Chunks 

type PutObjectStreamingResponse_Chunks struct {
	Chunks *deviced.ObjectChunks `protobuf:"bytes,2,opt,name=chunks,proto3,oneof"`
}

type RemoveObjectRequest 

type RemoveObjectRequest struct {
	Object *deviced.OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveObjectRequest) Descriptor deprecated 

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

Deprecated: Use RemoveObjectRequest.ProtoReflect.Descriptor instead.

func (*RemoveObjectRequest) GetObject 

func (x *RemoveObjectRequest) GetObject() *deviced.OpObject

func (*RemoveObjectRequest) ProtoMessage 

func (*RemoveObjectRequest) ProtoMessage()

func (*RemoveObjectRequest) ProtoReflect added in v1.2.14 

func (x *RemoveObjectRequest) ProtoReflect() protoreflect.Message

func (*RemoveObjectRequest) Reset 

func (x *RemoveObjectRequest) Reset()

func (*RemoveObjectRequest) String 

func (x *RemoveObjectRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*RenameObjectRequest) Descriptor deprecated 

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

Deprecated: Use RenameObjectRequest.ProtoReflect.Descriptor instead.

func (*RenameObjectRequest) GetDestination 

func (x *RenameObjectRequest) GetDestination() *deviced.OpObject

func (*RenameObjectRequest) GetSource 

func (x *RenameObjectRequest) GetSource() *deviced.OpObject

func (*RenameObjectRequest) ProtoMessage 

func (*RenameObjectRequest) ProtoMessage()

func (*RenameObjectRequest) ProtoReflect added in v1.2.14 

func (x *RenameObjectRequest) ProtoReflect() protoreflect.Message

func (*RenameObjectRequest) Reset 

func (x *RenameObjectRequest) Reset()

func (*RenameObjectRequest) String 

func (x *RenameObjectRequest) String() string

type ShowModuleFirmwareDescriptorResponse 

type ShowModuleFirmwareDescriptorResponse struct {
	FirmwareDescriptor *deviced.FirmwareDescriptor `protobuf:"bytes,1,opt,name=firmware_descriptor,json=firmwareDescriptor,proto3" json:"firmware_descriptor,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowModuleFirmwareDescriptorResponse) Descriptor deprecated 

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

Deprecated: Use ShowModuleFirmwareDescriptorResponse.ProtoReflect.Descriptor instead.

func (*ShowModuleFirmwareDescriptorResponse) GetFirmwareDescriptor 

func (x *ShowModuleFirmwareDescriptorResponse) GetFirmwareDescriptor() *deviced.FirmwareDescriptor

func (*ShowModuleFirmwareDescriptorResponse) ProtoMessage 

func (*ShowModuleFirmwareDescriptorResponse) ProtoMessage()

func (*ShowModuleFirmwareDescriptorResponse) ProtoReflect added in v1.2.14 

func (x *ShowModuleFirmwareDescriptorResponse) ProtoReflect() protoreflect.Message

func (*ShowModuleFirmwareDescriptorResponse) Reset 

func (x *ShowModuleFirmwareDescriptorResponse) Reset()

func (*ShowModuleFirmwareDescriptorResponse) String 

func (x *ShowModuleFirmwareDescriptorResponse) String() string

type ShowModuleResponse 

type ShowModuleResponse struct {
	Module *deviced.Module `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowModuleResponse) Descriptor deprecated 

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

Deprecated: Use ShowModuleResponse.ProtoReflect.Descriptor instead.

func (*ShowModuleResponse) GetModule 

func (x *ShowModuleResponse) GetModule() *deviced.Module

func (*ShowModuleResponse) ProtoMessage 

func (*ShowModuleResponse) ProtoMessage()

func (*ShowModuleResponse) ProtoReflect added in v1.2.14 

func (x *ShowModuleResponse) ProtoReflect() protoreflect.Message

func (*ShowModuleResponse) Reset 

func (x *ShowModuleResponse) Reset()

func (*ShowModuleResponse) String 

func (x *ShowModuleResponse) String() string

type UnimplementedDeviceServiceServer added in v1.2.14 

type UnimplementedDeviceServiceServer struct {
}

UnimplementedDeviceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDeviceServiceServer) GetObject added in v1.2.14 

func (*UnimplementedDeviceServiceServer) GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)

func (*UnimplementedDeviceServiceServer) GetObjectContent added in v1.2.14 

func (*UnimplementedDeviceServiceServer) GetObjectContent(context.Context, *GetObjectContentRequest) (*GetObjectContentResponse, error)

func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent added in v1.2.14 

func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent(context.Context, *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)

func (*UnimplementedDeviceServiceServer) Heartbeat added in v1.2.14 

func (*UnimplementedDeviceServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*emptypb.Empty, error)

func (*UnimplementedDeviceServiceServer) IssueModuleToken added in v1.2.14 

func (*UnimplementedDeviceServiceServer) IssueModuleToken(context.Context, *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)

func (*UnimplementedDeviceServiceServer) ListObjects added in v1.2.14 

func (*UnimplementedDeviceServiceServer) ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)

func (*UnimplementedDeviceServiceServer) PushFrameToFlow added in v1.2.14 

func (*UnimplementedDeviceServiceServer) PushFrameToFlow(DeviceService_PushFrameToFlowServer) error

func (*UnimplementedDeviceServiceServer) PushFrameToFlowOnce added in v1.2.14 

func (*UnimplementedDeviceServiceServer) PushFrameToFlowOnce(context.Context, *PushFrameToFlowOnceRequest) (*emptypb.Empty, error)

func (*UnimplementedDeviceServiceServer) PutObject added in v1.2.14 

func (*UnimplementedDeviceServiceServer) PutObject(context.Context, *PutObjectRequest) (*emptypb.Empty, error)

func (*UnimplementedDeviceServiceServer) PutObjectStreaming added in v1.2.14 

func (*UnimplementedDeviceServiceServer) PutObjectStreaming(DeviceService_PutObjectStreamingServer) error

func (*UnimplementedDeviceServiceServer) RemoveObject added in v1.2.14 

func (*UnimplementedDeviceServiceServer) RemoveObject(context.Context, *RemoveObjectRequest) (*emptypb.Empty, error)

func (*UnimplementedDeviceServiceServer) RenameObject added in v1.2.14 

func (*UnimplementedDeviceServiceServer) RenameObject(context.Context, *RenameObjectRequest) (*emptypb.Empty, error)

func (*UnimplementedDeviceServiceServer) ShowModule added in v1.2.14 

func (*UnimplementedDeviceServiceServer) ShowModule(context.Context, *emptypb.Empty) (*ShowModuleResponse, error)

func (*UnimplementedDeviceServiceServer) ShowModuleFirmwareDescriptor added in v1.2.14 

func (*UnimplementedDeviceServiceServer) ShowModuleFirmwareDescriptor(context.Context, *emptypb.Empty) (*ShowModuleFirmwareDescriptorResponse, 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.