metathings_deviced_service

package
v1.1.25-alpha Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2020 License: MIT Imports: 37 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")
)

Functions

func NewMetathingsDevicedService 

func NewMetathingsDevicedService(
	opt *MetathingsDevicedServiceOption,
	logger log.FieldLogger,
	storage storage.Storage,
	session_storage session_storage.SessionStorage,
	simple_storage simple_storage.SimpleStorage,
	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_launcher evaluatord_sdk.DataLauncher,
) (pb.DevicedServiceServer, error)

Types

type MetathingsDevicedService 

type MetathingsDevicedService struct {
	grpc_auth.ServiceAuthFuncOverride
	// contains filtered or unexported fields
}

func (*MetathingsDevicedService) AddFlowsToFlowSet added in v1.1.23 

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

func (*MetathingsDevicedService) AuthorizeAddFlowsToFlowSet added in v1.1.23 

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

func (*MetathingsDevicedService) AuthorizeDeleteDevice 

func (self *MetathingsDevicedService) AuthorizeDeleteDevice(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) 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) 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) AuthorizeListObjects 

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

func (*MetathingsDevicedService) AuthorizePatchDevice 

func (self *MetathingsDevicedService) AuthorizePatchDevice(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) 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) 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) CreateDevice 

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

func (*MetathingsDevicedService) CreateFlowSet added in v1.1.23 

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

func (*MetathingsDevicedService) DeleteDevice 

func (self *MetathingsDevicedService) DeleteDevice(ctx context.Context, req *pb.DeleteDeviceRequest) (*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) 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) 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) 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) ListDevices 

func (self *MetathingsDevicedService) ListDevices(ctx context.Context, req *pb.ListDevicesRequest) (*pb.ListDevicesResponse, 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) PatchDevice 

func (self *MetathingsDevicedService) PatchDevice(ctx context.Context, req *pb.PatchDeviceRequest) (*pb.PatchDeviceResponse, 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

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

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

func (*MetathingsDevicedService) StreamCall 

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

func (*MetathingsDevicedService) UnaryCall 

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

func (*MetathingsDevicedService) ValidateCreateDevice 

func (self *MetathingsDevicedService) ValidateCreateDevice(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) ValidateDeleteDevice 

func (self *MetathingsDevicedService) ValidateDeleteDevice(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) 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) 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) ValidateListObjects 

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

func (*MetathingsDevicedService) ValidatePatchDevice 

func (self *MetathingsDevicedService) ValidatePatchDevice(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) 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) ValidateUnaryCall 

func (self *MetathingsDevicedService) ValidateUnaryCall(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
		}
	}
}

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.