metathings_deviced_service

package
v1.3.0-alpha.5 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2024 License: MIT Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KIND_DEVICE = "deviced:device"
	KIND_MODULE = "deviced:module"
	KIND_FLOW   = "deviced:flow"

	RESOURCE_TYPE_FLOW    = "flow"
	RESOURCE_TYPE_FLOWSET = "flowset"

	DEVICED_PUSH_FRAME_TO_FLOW_ONCE                      = "deviced:push_frame_to_flow_once"
	DEVICED_LIST_FIRMWARE_HUBS                           = "deviced:list_firmware_hubs"
	DEVICED_PATCH_CONFIG                                 = "deviced:patch_config"
	DEVICED_REMOVE_FIRMWARE_DESCRIPTOR_FROM_FIRMWARE_HUB = "deviced:remove_firmware_descriptor_from_firmware_hub"
	DEVICED_PATCH_FLOW_SET                               = "deviced:patch_flow_set"
	DEVICED_GET_DEVICE_BY_MODULE                         = "deviced:get_device_by_module"
	DEVICED_DELETE_CONFIG                                = "deviced:delete_config"
	DEVICED_ADD_FLOWS_TO_FLOW_SET                        = "deviced:add_flows_to_flow_set"
	DEVICED_GET_FLOW_SET                                 = "deviced:get_flow_set"
	DEVICED_PATCH_DEVICE                                 = "deviced:patch_device"
	DEVICED_SYNC_DEVICE_FIRMWARE_DESCRIPTOR              = "deviced:sync_device_firmware_descriptor"
	DEVICED_PATCH_FIRMWARE_HUB                           = "deviced:patch_firmware_hub"
	DEVICED_DELETE_DEVICE                                = "deviced:delete_device"
	DEVICED_GET_OBJECT_CONTENT                           = "deviced:get_object_content"
	DEVICED_GET_DEVICE                                   = "deviced:get_device"
	DEVICED_REMOVE_DEVICES_FROM_FIRMWARE_HUB             = "deviced:remove_devices_from_firmware_hub"
	DEVICED_DELETE_FLOW_SET                              = "deviced:delete_flow_set"
	DEVICED_ADD_DEVICES_TO_FIRMWARE_HUB                  = "deviced:add_devices_to_firmware_hub"
	DEVICED_REMOVE_CONFIGS_FROM_DEVICE                   = "deviced:remove_configs_from_device"
	DEVICED_REMOVE_OBJECT                                = "deviced:remove_object"
	DEVICED_UNARY_CALL                                   = "deviced:unary_call"
	DEVICED_LIST_CONFIGS_BY_DEVICE                       = "deviced:list_configs_by_device"
	DEVICED_PUT_OBJECT                                   = "deviced:put_object"
	DEVICED_ADD_CONFIGS_TO_DEVICE                        = "deviced:add_configs_to_device"
	DEVICED_RENAME_OBJECT                                = "deviced:rename_object"
	DEVICED_REMOVE_FLOWS_FROM_FLOW_SET                   = "deviced:remove_flows_from_flow_set"
	DEVICED_LIST_OBJECTS                                 = "deviced:list_objects"
	DEVICED_DELETE_FIRMWARE_HUB                          = "deviced:delete_firmware_hub"
	DEVICED_CREATE_FIRMWARE_HUB                          = "deviced:create_firmware_hub"
	DEVICED_SET_DEVICE_FIRMWARE_DESCRIPTOR               = "deviced:set_device_firmware_descriptor"
	DEVICED_GET_FIRMWARE_HUB                             = "deviced:get_firmware_hub"
	DEVICED_GET_CONFIG                                   = "deviced:get_config"
	DEVICED_ADD_FIRMWARE_DESCRIPTOR_TO_FIRMWARE_HUB      = "deviced:add_firmware_descriptor_to_firmware_hub"
	DEVICED_HEARTBEAT                                    = "deviced:heartbeat"
	DEVICED_GET_OBJECT                                   = "deviced:get_object"
)

Variables

View Source 
var (
	ErrUnexpectedMessage = errors.New("unexpected message")
	ErrDuplicatedDevice  = errors.New("duplicated device")
	ErrUnconnectedDevice = errors.New("unconnected device")
	ErrFlowNotFound      = errors.New("flow not found")
	ErrDeviceOffline     = errors.New("device offline")

	ErrPutObjectStreamingTimeout = errors.New("put object streaming timeout")
	ErrInvalidProtoset           = errors.New("invaild protoset")
)

Functions

func NewMetathingsDevicedService 

func NewMetathingsDevicedService(
	opt *MetathingsDevicedServiceOption,
	logger log.FieldLogger,
	storage storage.Storage,
	session_storage session_storage.SessionStorage,
	simple_storage simple_storage.SimpleStorage,
	desc_storage descriptor_storage.DescriptorStorage,
	authorizer identityd_authorizer.Authorizer,
	validator identityd_validator.Validator,
	tkvdr token_helper.TokenValidator,
	cc connection.ConnectionCenter,
	tknr token_helper.Tokener,
	cli_fty *client_helper.ClientFactory,
	flw_fty flow.FlowFactory,
	flwst_fty flow.FlowSetFactory,
	data_launchers []evaluatord_sdk.DataLauncher,
) (pb.DevicedServiceServer, error)

Types

type MetathingsDevicedService 

type MetathingsDevicedService struct {
	pb.UnimplementedDevicedServiceServer

	grpc_auth.ServiceAuthFuncOverride
	*grpc_helper.ErrorParser
	// contains filtered or unexported fields
}

func (*MetathingsDevicedService) AddConfigsToDevice added in v1.1.27 

func (self *MetathingsDevicedService) AddConfigsToDevice(ctx context.Context, req *pb.AddConfigsToDeviceRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) AddDevicesToFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AddDevicesToFirmwareHub(ctx context.Context, req *pb.AddDevicesToFirmwareHubRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) AddFirmwareDescriptorToFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AddFirmwareDescriptorToFirmwareHub(ctx context.Context, req *pb.AddFirmwareDescriptorToFirmwareHubRequest) (*empty.Empty, error)

* Descriptor Format: * * device.sha256.next: * device.uri.next: * device.version.next: * modules.<name>.sha256.next: * modules.<name>.uri.next: * modules.<name>.version.next: * * Example: * * { * "device": { * "sha256": { "next": "8484848484848484848484848484848484848484848484848484848484848484" }, * "uri": { "next": "http://example.com/firmwares/device/device/v1_0_0/device_v1_0_0.bin" }, * "version": { "next": "v1.0.0" } * }, * "modules": { * "answer42": { * "sha256": { "next": "4242424242424242424242424242424242424242424242424242424242424242" }, * "uri": { "next": "http://example.com/firmwares/modules/answer42/v1_0_0/answeer_v1_0_0.bin" }, * "version": { "next": "v1.0.0" } * } * } * }

func (*MetathingsDevicedService) AddFlowsToFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) AddFlowsToFlowSet(ctx context.Context, req *pb.AddFlowsToFlowSetRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) AuthorizeAddConfigsToDevice added in v1.1.27 

func (self *MetathingsDevicedService) AuthorizeAddConfigsToDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeAddDevicesToFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeAddDevicesToFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeAddFirmwareDescriptorToFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeAddFirmwareDescriptorToFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeAddFlowsToFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) AuthorizeAddFlowsToFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeCreateFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeCreateFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeDeleteConfig added in v1.1.27 

func (self *MetathingsDevicedService) AuthorizeDeleteConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeDeleteDevice 

func (self *MetathingsDevicedService) AuthorizeDeleteDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeDeleteFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeDeleteFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeDeleteFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) AuthorizeDeleteFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetConfig added in v1.1.27 

func (self *MetathingsDevicedService) AuthorizeGetConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetDevice 

func (self *MetathingsDevicedService) AuthorizeGetDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetDeviceByModule added in v0.100.0 

func (self *MetathingsDevicedService) AuthorizeGetDeviceByModule(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeGetFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) AuthorizeGetFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetObject 

func (self *MetathingsDevicedService) AuthorizeGetObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeGetObjectContent 

func (self *MetathingsDevicedService) AuthorizeGetObjectContent(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeHeartbeat 

func (self *MetathingsDevicedService) AuthorizeHeartbeat(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeListConfigsByDevice added in v1.1.27 

func (self *MetathingsDevicedService) AuthorizeListConfigsByDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeListFirmwareHubs added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeListFirmwareHubs(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeListObjects 

func (self *MetathingsDevicedService) AuthorizeListObjects(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizePatchConfig added in v1.1.27 

func (self *MetathingsDevicedService) AuthorizePatchConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizePatchDevice 

func (self *MetathingsDevicedService) AuthorizePatchDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizePatchFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizePatchFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizePatchFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) AuthorizePatchFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizePushFrameToFlowOnce added in v1.2.2 

func (self *MetathingsDevicedService) AuthorizePushFrameToFlowOnce(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizePutObject 

func (self *MetathingsDevicedService) AuthorizePutObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeRemoveConfigsFromDevice added in v1.1.27 

func (self *MetathingsDevicedService) AuthorizeRemoveConfigsFromDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeRemoveDevicesFromFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeRemoveDevicesFromFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeRemoveFirmwareDescriptorFromFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeRemoveFirmwareDescriptorFromFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeRemoveFlowsFromFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) AuthorizeRemoveFlowsFromFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeRemoveObject 

func (self *MetathingsDevicedService) AuthorizeRemoveObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeRenameObject 

func (self *MetathingsDevicedService) AuthorizeRenameObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeSetDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeSetDeviceFirmwareDescriptor(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeSyncDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) AuthorizeSyncDeviceFirmwareDescriptor(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) AuthorizeUnaryCall 

func (self *MetathingsDevicedService) AuthorizeUnaryCall(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) Connect 

func (self *MetathingsDevicedService) Connect(stream pb.DevicedService_ConnectServer) error

func (*MetathingsDevicedService) CreateConfig added in v1.1.27 

func (self *MetathingsDevicedService) CreateConfig(ctx context.Context, req *pb.CreateConfigRequest) (*pb.CreateConfigResponse, error)

func (*MetathingsDevicedService) CreateDevice 

func (self *MetathingsDevicedService) CreateDevice(ctx context.Context, req *pb.CreateDeviceRequest) (*pb.CreateDeviceResponse, error)

func (*MetathingsDevicedService) CreateFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) CreateFirmwareHub(ctx context.Context, req *pb.CreateFirmwareHubRequest) (*pb.CreateFirmwareHubResponse, error)

func (*MetathingsDevicedService) CreateFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) CreateFlowSet(ctx context.Context, req *pb.CreateFlowSetRequest) (*pb.CreateFlowSetResponse, error)

func (*MetathingsDevicedService) DeleteConfig added in v1.1.27 

func (self *MetathingsDevicedService) DeleteConfig(ctx context.Context, req *pb.DeleteConfigRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) DeleteDevice 

func (self *MetathingsDevicedService) DeleteDevice(ctx context.Context, req *pb.DeleteDeviceRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) DeleteFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) DeleteFirmwareHub(ctx context.Context, req *pb.DeleteFirmwareHubRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) DeleteFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) DeleteFlowSet(ctx context.Context, req *pb.DeleteFlowSetRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) GetConfig added in v1.1.27 

func (self *MetathingsDevicedService) GetConfig(ctx context.Context, req *pb.GetConfigRequest) (*pb.GetConfigResponse, error)

func (*MetathingsDevicedService) GetDescriptor added in v1.1.27 

func (self *MetathingsDevicedService) GetDescriptor(ctx context.Context, req *pb.GetDescriptorRequest) (*pb.GetDescriptorResponse, error)

func (*MetathingsDevicedService) GetDevice 

func (self *MetathingsDevicedService) GetDevice(ctx context.Context, req *pb.GetDeviceRequest) (*pb.GetDeviceResponse, error)

func (*MetathingsDevicedService) GetDeviceByModule added in v0.100.0 

func (self *MetathingsDevicedService) GetDeviceByModule(ctx context.Context, req *pb.GetDeviceByModuleRequest) (*pb.GetDeviceByModuleResponse, error)

func (*MetathingsDevicedService) GetDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) GetDeviceFirmwareDescriptor(ctx context.Context, req *pb.GetDeviceFirmwareDescriptorRequest) (*pb.GetDeviceFirmwareDescriptorResponse, error)

func (*MetathingsDevicedService) GetFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) GetFirmwareHub(ctx context.Context, req *pb.GetFirmwareHubRequest) (*pb.GetFirmwareHubResponse, error)

func (*MetathingsDevicedService) GetFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) GetFlowSet(ctx context.Context, req *pb.GetFlowSetRequest) (*pb.GetFlowSetResponse, error)

func (*MetathingsDevicedService) GetObject 

func (self *MetathingsDevicedService) GetObject(ctx context.Context, req *pb.GetObjectRequest) (*pb.GetObjectResponse, error)

func (*MetathingsDevicedService) GetObjectContent 

func (self *MetathingsDevicedService) GetObjectContent(ctx context.Context, req *pb.GetObjectContentRequest) (*pb.GetObjectContentResponse, error)

func (*MetathingsDevicedService) GetObjectStreamingContent 

func (self *MetathingsDevicedService) GetObjectStreamingContent(*pb.GetObjectStreamingContentRequest, pb.DevicedService_GetObjectStreamingContentServer) error

func (*MetathingsDevicedService) Healthz 

func (self *MetathingsDevicedService) Healthz(ctx context.Context, req *emptypb.Empty) (*wrapperspb.StringValue, error)

func (*MetathingsDevicedService) Heartbeat 

func (self *MetathingsDevicedService) Heartbeat(ctx context.Context, req *pb.HeartbeatRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) IsIgnoreMethod 

func (self *MetathingsDevicedService) IsIgnoreMethod(md *grpc_helper.MethodDescription) bool

func (*MetathingsDevicedService) ListConfigs added in v1.1.27 

func (self *MetathingsDevicedService) ListConfigs(ctx context.Context, req *pb.ListConfigsRequest) (*pb.ListConfigsResponse, error)

func (*MetathingsDevicedService) ListConfigsByDevice added in v1.1.27 

func (self *MetathingsDevicedService) ListConfigsByDevice(ctx context.Context, req *pb.ListConfigsByDeviceRequest) (*pb.ListConfigsByDeviceResponse, error)

func (*MetathingsDevicedService) ListDevices 

func (self *MetathingsDevicedService) ListDevices(ctx context.Context, req *pb.ListDevicesRequest) (*pb.ListDevicesResponse, error)

func (*MetathingsDevicedService) ListFirmwareHubs added in v1.2.0 

func (self *MetathingsDevicedService) ListFirmwareHubs(ctx context.Context, req *pb.ListFirmwareHubsRequest) (*pb.ListFirmwareHubsResponse, error)

func (*MetathingsDevicedService) ListFlowSets added in v1.1.23 

func (self *MetathingsDevicedService) ListFlowSets(ctx context.Context, req *pb.ListFlowSetsRequest) (*pb.ListFlowSetsResponse, error)

func (*MetathingsDevicedService) ListObjects 

func (self *MetathingsDevicedService) ListObjects(ctx context.Context, req *pb.ListObjectsRequest) (*pb.ListObjectsResponse, error)

func (*MetathingsDevicedService) PatchConfig added in v1.1.27 

func (self *MetathingsDevicedService) PatchConfig(ctx context.Context, req *pb.PatchConfigRequest) (*pb.PatchConfigResponse, error)

func (*MetathingsDevicedService) PatchDevice 

func (self *MetathingsDevicedService) PatchDevice(ctx context.Context, req *pb.PatchDeviceRequest) (*pb.PatchDeviceResponse, error)

func (*MetathingsDevicedService) PatchFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) PatchFirmwareHub(ctx context.Context, req *pb.PatchFirmwareHubRequest) (*pb.PatchFirmwareHubResponse, error)

func (*MetathingsDevicedService) PatchFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) PatchFlowSet(ctx context.Context, req *pb.PatchFlowSetRequest) (*pb.PatchFlowSetResponse, error)

func (*MetathingsDevicedService) PullFrameFromFlow 

func (self *MetathingsDevicedService) PullFrameFromFlow(req *pb.PullFrameFromFlowRequest, stm pb.DevicedService_PullFrameFromFlowServer) error

func (*MetathingsDevicedService) PullFrameFromFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) PullFrameFromFlowSet(req *pb.PullFrameFromFlowSetRequest, stm pb.DevicedService_PullFrameFromFlowSetServer) error

func (*MetathingsDevicedService) PushFrameToFlow 

func (self *MetathingsDevicedService) PushFrameToFlow(stm pb.DevicedService_PushFrameToFlowServer) error

TODO(Peer): merge PushFrameToFlow and PushFrameToFlowOnce to one function

func (*MetathingsDevicedService) PushFrameToFlowOnce added in v1.2.2 

func (self *MetathingsDevicedService) PushFrameToFlowOnce(ctx context.Context, req *pb.PushFrameToFlowOnceRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) PutObject 

func (self *MetathingsDevicedService) PutObject(ctx context.Context, req *pb.PutObjectRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) PutObjectStreaming added in v1.1.16 

func (self *MetathingsDevicedService) PutObjectStreaming(stm pb.DevicedService_PutObjectStreamingServer) error

func (*MetathingsDevicedService) QueryFramesFromFlow 

func (self *MetathingsDevicedService) QueryFramesFromFlow(ctx context.Context, req *pb.QueryFramesFromFlowRequest) (*pb.QueryFramesFromFlowResponse, error)

func (*MetathingsDevicedService) RemoveConfigsFromDevice added in v1.1.27 

func (self *MetathingsDevicedService) RemoveConfigsFromDevice(ctx context.Context, req *pb.RemoveConfigsFromDeviceRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) RemoveDevicesFromFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) RemoveDevicesFromFirmwareHub(ctx context.Context, req *pb.RemoveDevicesFromFirmwareHubRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) RemoveFirmwareDescriptorFromFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) RemoveFirmwareDescriptorFromFirmwareHub(ctx context.Context, req *pb.RemoveFirmwareDescriptorFromFirmwareHubRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) RemoveFlowsFromFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) RemoveFlowsFromFlowSet(ctx context.Context, req *pb.RemoveFlowsFromFlowSetRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) RemoveObject 

func (self *MetathingsDevicedService) RemoveObject(ctx context.Context, req *pb.RemoveObjectRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) RenameObject 

func (self *MetathingsDevicedService) RenameObject(ctx context.Context, req *pb.RenameObjectRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) SetDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) SetDeviceFirmwareDescriptor(ctx context.Context, req *pb.SetDeviceFirmwareDescriptorRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) ShowDevice 

func (self *MetathingsDevicedService) ShowDevice(ctx context.Context, _ *empty.Empty) (*pb.ShowDeviceResponse, error)

func (*MetathingsDevicedService) ShowDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) ShowDeviceFirmwareDescriptor(ctx context.Context, _ *empty.Empty) (*pb.ShowDeviceFirmwareDescriptorResponse, error)

func (*MetathingsDevicedService) StreamCall 

func (self *MetathingsDevicedService) StreamCall(stm pb.DevicedService_StreamCallServer) error

func (*MetathingsDevicedService) SyncDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) SyncDeviceFirmwareDescriptor(ctx context.Context, req *pb.SyncDeviceFirmwareDescriptorRequest) (*empty.Empty, error)

func (*MetathingsDevicedService) UnaryCall 

func (self *MetathingsDevicedService) UnaryCall(ctx context.Context, req *pb.UnaryCallRequest) (*pb.UnaryCallResponse, error)

func (*MetathingsDevicedService) UploadDescriptor added in v1.1.27 

func (self *MetathingsDevicedService) UploadDescriptor(ctx context.Context, req *pb.UploadDescriptorRequest) (*pb.UploadDescriptorResponse, error)

func (*MetathingsDevicedService) ValidateAddDevicesToFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateAddDevicesToFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateAddFirmwareDescriptorToFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateAddFirmwareDescriptorToFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateCreateConfig added in v1.1.27 

func (self *MetathingsDevicedService) ValidateCreateConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateCreateDevice 

func (self *MetathingsDevicedService) ValidateCreateDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateCreateFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateCreateFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateCreateFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) ValidateCreateFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateDeleteConfig added in v1.1.27 

func (self *MetathingsDevicedService) ValidateDeleteConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateDeleteDevice 

func (self *MetathingsDevicedService) ValidateDeleteDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateDeleteFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateDeleteFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateDeleteFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) ValidateDeleteFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) ValidateFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetConfig added in v1.1.27 

func (self *MetathingsDevicedService) ValidateGetConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetDescriptor added in v1.1.27 

func (self *MetathingsDevicedService) ValidateGetDescriptor(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetDevice 

func (self *MetathingsDevicedService) ValidateGetDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetDeviceByModule added in v0.100.0 

func (self *MetathingsDevicedService) ValidateGetDeviceByModule(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateGetFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetObject 

func (self *MetathingsDevicedService) ValidateGetObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateGetObjectContent 

func (self *MetathingsDevicedService) ValidateGetObjectContent(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateHeartbeat 

func (self *MetathingsDevicedService) ValidateHeartbeat(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateListConfigsByDevice added in v1.1.27 

func (self *MetathingsDevicedService) ValidateListConfigsByDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateListObjects 

func (self *MetathingsDevicedService) ValidateListObjects(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidatePatchConfig added in v1.1.27 

func (self *MetathingsDevicedService) ValidatePatchConfig(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidatePatchDevice 

func (self *MetathingsDevicedService) ValidatePatchDevice(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidatePatchFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidatePatchFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidatePatchFlowSet added in v1.1.23 

func (self *MetathingsDevicedService) ValidatePatchFlowSet(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidatePushFrameToFlowOnce added in v1.2.2 

func (self *MetathingsDevicedService) ValidatePushFrameToFlowOnce(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidatePutObject 

func (self *MetathingsDevicedService) ValidatePutObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateRemoveDevicesFromFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateRemoveDevicesFromFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateRemoveFirmwareDescriptorFromFirmwareHub added in v1.2.0 

func (self *MetathingsDevicedService) ValidateRemoveFirmwareDescriptorFromFirmwareHub(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateRemoveObject 

func (self *MetathingsDevicedService) ValidateRemoveObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateRenameObject 

func (self *MetathingsDevicedService) ValidateRenameObject(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateSetDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) ValidateSetDeviceFirmwareDescriptor(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateSyncDeviceFirmwareDescriptor added in v1.2.0 

func (self *MetathingsDevicedService) ValidateSyncDeviceFirmwareDescriptor(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateUnaryCall 

func (self *MetathingsDevicedService) ValidateUnaryCall(ctx context.Context, in interface{}) error

func (*MetathingsDevicedService) ValidateUploadDescriptor added in v1.1.27 

func (self *MetathingsDevicedService) ValidateUploadDescriptor(ctx context.Context, in interface{}) error

type MetathingsDevicedServiceOption 

type MetathingsDevicedServiceOption struct {
	Methods struct {
		PutObjectStreaming struct {
			Timeout            int64
			ChunkSize          int64
			ChunkPerRequest    int
			PullRequestRetry   int
			PullRequestTimeout int64
		}
		PullFrameFromFlow struct {
			AliveInterval int64
		}
		PullFrameFromFlowSet struct {
			AliveInterval int64
		}
	}
	Domain string
}

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.