metathings_deviced_service

package
v1.1.31-alpha5 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2020 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"
)

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

Types

type MetathingsDevicedService

type MetathingsDevicedService struct {
	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) 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 (*MetathingsDevicedService) CreateConfig added in v1.1.27

func (*MetathingsDevicedService) CreateDevice

func (*MetathingsDevicedService) CreateFirmwareHub added in v1.2.0

func (*MetathingsDevicedService) CreateFlowSet added in v1.1.23

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 (*MetathingsDevicedService) GetDescriptor added in v1.1.27

func (*MetathingsDevicedService) GetDevice

func (*MetathingsDevicedService) GetDeviceByModule added in v0.100.0

func (*MetathingsDevicedService) GetDeviceFirmwareDescriptor added in v1.2.0

func (*MetathingsDevicedService) GetFirmwareHub added in v1.2.0

func (*MetathingsDevicedService) GetFlowSet added in v1.1.23

func (*MetathingsDevicedService) GetObject

func (*MetathingsDevicedService) GetObjectContent

func (*MetathingsDevicedService) Heartbeat

func (*MetathingsDevicedService) IsIgnoreMethod

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

func (*MetathingsDevicedService) ListConfigs added in v1.1.27

func (*MetathingsDevicedService) ListConfigsByDevice added in v1.1.27

func (*MetathingsDevicedService) ListDevices

func (*MetathingsDevicedService) ListFirmwareHubs added in v1.2.0

func (*MetathingsDevicedService) ListFlowSets added in v1.1.23

func (*MetathingsDevicedService) ListObjects

func (*MetathingsDevicedService) PatchConfig added in v1.1.27

func (*MetathingsDevicedService) PatchDevice

func (*MetathingsDevicedService) PatchFirmwareHub added in v1.2.0

func (*MetathingsDevicedService) PatchFlowSet added in v1.1.23

func (*MetathingsDevicedService) PullFrameFromFlow

func (*MetathingsDevicedService) PullFrameFromFlowSet added in v1.1.23

func (*MetathingsDevicedService) PushFrameToFlow

func (*MetathingsDevicedService) PutObject

func (*MetathingsDevicedService) PutObjectStreaming added in v1.1.16

func (*MetathingsDevicedService) QueryFramesFromFlow

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 (*MetathingsDevicedService) ShowDeviceFirmwareDescriptor added in v1.2.0

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

func (*MetathingsDevicedService) StreamCall

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 (*MetathingsDevicedService) UploadDescriptor added in v1.1.27

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) 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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL