Skip to main content

compute

Used to configure datasinks for sensor streams.

This service is used to configure datasink endpoints for frames and telemetry post-processing. It maintains an internal consumer list of datasinks that the kernel broadcasts frames and telemetry to. RPC methods within this service allow for manipulation of this list.

attr STUB​

Type: ComputeStub

Stub that is automatically set at runtime so that actions for this service can connect to grpc.

class AddDatasinks​

Inherits from: Action

Add datasinks to consumer list.

Takes a list of datasinks and adds them to the current consumer list.

Attributes​

attr  datasinks  (List[DatasinkInfo]) — name of target datasinks

method execute​

Call Type: async

Execute the AddDatasinks action.

Returns​

Response — response generated by the RPC call.

View Source
@register_action
class AddDatasinks(Action):
    """Add datasinks to consumer list.

    Takes a list of datasinks and adds them to the current consumer list.

    Attributes:
        datasinks (List[params.DatasinkInfo]): name of target datasinks
    """
    datasinks: List[params.DatasinkInfo]

    async def execute(self) -> Response:
        """Execute the AddDatasinks action.

        Returns:
            Response: response generated by the RPC call.
        """
        req = compute_service_pb2.AddDatasinksRequest()
        ParseDict(payload_from_action(self), req)
        return await run_unary(STUB.AddDatasinks, req)

class SetDatasinks​

Inherits from: Action

Set the datasink consumer list.

Takes a list of datasinks and replaces the current consumer list with them.

Attributes​

attr  datasinks  (List[DatasinkInfo]) — name of target datasinks

method execute​

Call Type: async

Execute the SetDatasinks action.

Returns​

Response — response generated by the RPC call.

View Source
@register_action
class SetDatasinks(Action):
    """Set the datasink consumer list.

    Takes a list of datasinks and replaces the current consumer list with them.

    Attributes:
        datasinks (List[params.DatasinkInfo]): name of target datasinks
    """
    datasinks: List[params.DatasinkInfo]

    async def execute(self) -> Response:
        """Execute the SetDatasinks action.

        Returns:
            Response: response generated by the RPC call.
        """
        req = compute_service_pb2.SetDatasinksRequest()
        ParseDict(payload_from_action(self), req)
        return await run_unary(STUB.SetDatasinks, req)

class RemoveDatasinks​

Inherits from: Action

Remove datasinks from consumer list.

Takes a list of datasinks and removes them from the current consumer list.

Attributes​

attr  datasinks  (List[DatasinkInfo]) — name of target datasinks

method execute​

Call Type: async

Execute the RemoveDatasinks action.

Returns​

Response — response generated by the RPC call.

View Source
@register_action
class RemoveDatasinks(Action):
    """Remove datasinks from consumer list.

    Takes a list of datasinks and removes them from the current consumer list.

    Attributes:
        datasinks (List[params.DatasinkInfo]): name of target datasinks
    """
    datasinks: List[params.DatasinkInfo]

    async def execute(self) -> Response:
        """Execute the RemoveDatasinks action.

        Returns:
            Response: response generated by the RPC call.
        """
        req = compute_service_pb2.RemoveDatasinksRequest()
        ParseDict(payload_from_action(self), req)
        return await run_unary(STUB.RemoveDatasinks, req)