from __future__ import annotations
import omni.ujitso._ujitso
import typing
import numpy
_Shape = typing.Tuple[int, ...]

__all__ = [
    "Agent",
    "AgentConfigFlags",
    "BuildContext",
    "BuildHandle",
    "BuildJob",
    "DataGrid",
    "DataStoreUtils",
    "Default",
    "DependencyContext",
    "DependencyHandle",
    "DependencyJob",
    "DynamicRequest",
    "ExternalStorage",
    "ForceRemoteTasks",
    "IAgent",
    "IDataGrid",
    "IDataStore",
    "IFactory",
    "IHTTPFactory",
    "IInProcessFactory",
    "ILocalDataStore",
    "INucleusDataStore",
    "IRegistry",
    "IService",
    "ITCPFactory",
    "ITaskAgent",
    "ITaskService",
    "KeyToken",
    "KeyTokenEx",
    "MatchContext",
    "MatchResult",
    "None",
    "OperationResult",
    "Processor",
    "ProcessorInformation",
    "Request",
    "RequestCallbackData",
    "RequestFilter",
    "RequestHandle",
    "RequestTokenType",
    "RequestType",
    "ResultHandle",
    "TCPAgentConfigFlags",
    "TIME_OUT_INFINITE",
    "UjitsoUtils",
    "UseRoundRobinServerScheduling",
    "ValidationType",
    "WaitForConnectionsBeforeLaunch",
    "acquire_agent_interface",
    "acquire_data_grid_interface",
    "acquire_factory_interface",
    "acquire_http_factory_interface",
    "acquire_in_progress_factory_interface",
    "acquire_local_data_store_interface",
    "acquire_nucleus_data_store_interface",
    "acquire_registry_interface",
    "acquire_service_interface",
    "acquire_tcp_factory_interface",
    "release_agent_interface",
    "release_data_grid_interface",
    "release_factory_interface",
    "release_http_factory_interface",
    "release_in_progress_factory_interface",
    "release_local_data_store_interface",
    "release_nucleus_data_store_interface",
    "release_registry_interface",
    "release_service_interface",
    "release_tcp_factory_interface"
]


class Agent():
    @property
    def agent(self) -> carb::ujitso::IAgent:
        """
        :type: carb::ujitso::IAgent
        """
    @property
    def factory(self) -> carb::ujitso::IFactory:
        """
        :type: carb::ujitso::IFactory
        """
    @property
    def registry(self) -> IRegistry:
        """
        :type: IRegistry
        """
    @property
    def service(self) -> carb::ujitso::IService:
        """
        :type: carb::ujitso::IService
        """
    @property
    def store(self) -> IDataStore:
        """
        :type: IDataStore
        """
    @property
    def taskAgent(self) -> ITaskAgent:
        """
        :type: ITaskAgent
        """
    @property
    def taskService(self) -> ITaskService:
        """
        :type: ITaskService
        """
    pass
class AgentConfigFlags():
    """
    Members:

      None

      ForceRemoteTasks

      Default
    """
    def __eq__(self, other: object) -> bool: ...
    def __getstate__(self) -> int: ...
    def __hash__(self) -> int: ...
    def __index__(self) -> int: ...
    def __init__(self, value: int) -> None: ...
    def __int__(self) -> int: ...
    def __ne__(self, other: object) -> bool: ...
    def __repr__(self) -> str: ...
    def __setstate__(self, state: int) -> None: ...
    @property
    def name(self) -> str:
        """
        :type: str
        """
    @property
    def value(self) -> int:
        """
        :type: int
        """
    Default: omni.ujitso._ujitso.AgentConfigFlags # value = <AgentConfigFlags.None: 1>
    ForceRemoteTasks: omni.ujitso._ujitso.AgentConfigFlags # value = <AgentConfigFlags.ForceRemoteTasks: 2>
    None: omni.ujitso._ujitso.AgentConfigFlags # value = <AgentConfigFlags.None: 1>
    __members__: dict # value = {'None': <AgentConfigFlags.None: 1>, 'ForceRemoteTasks': <AgentConfigFlags.ForceRemoteTasks: 2>, 'Default': <AgentConfigFlags.None: 1>}
    pass
class BuildContext():
    @property
    def agent(self) -> Agent:
        """
        :type: Agent
        """
    @property
    def processor(self) -> carb::ujitso::Processor:
        """
        :type: carb::ujitso::Processor
        """
    pass
class BuildHandle():
    def __init__(self, value: int = 0) -> None: ...
    @property
    def value(self) -> int:
        """
        :type: int
        """
    @value.setter
    def value(self, arg0: int) -> None:
        pass
    pass
class BuildJob():
    @staticmethod
    def __init__(*args, **kwargs) -> typing.Any: ...
    @property
    def request(self) -> Request:
        """
        :type: Request
        """
    @request.setter
    def request(self, arg0: Request) -> None:
        pass
    pass
class DataGrid():
    @property
    def iface(self) -> carb::dad::IDataGrid:
        """
        :type: carb::dad::IDataGrid
        """
    pass
class DataStoreUtils():
    @staticmethod
    def copy_data_block(*args, **kwargs) -> typing.Any: ...
    pass
class DependencyContext():
    @property
    def agent(self) -> Agent:
        """
        :type: Agent
        """
    @property
    def processor(self) -> carb::ujitso::Processor:
        """
        :type: carb::ujitso::Processor
        """
    pass
class DependencyHandle():
    def __init__(self, value: int = 0) -> None: ...
    @property
    def value(self) -> int:
        """
        :type: int
        """
    @value.setter
    def value(self, arg0: int) -> None:
        pass
    pass
class DependencyJob():
    @staticmethod
    def __init__(*args, **kwargs) -> typing.Any: ...
    @property
    def request(self) -> Request:
        """
        :type: Request
        """
    @request.setter
    def request(self, arg0: Request) -> None:
        pass
    pass
class DynamicRequest():
    @typing.overload
    def __init__(self) -> None: ...
    @typing.overload
    def __init__(self, arg0: Request) -> None: ...
    def add(self, arg0: KeyTokenEx) -> int: ...
    def add_buffer(self, arg0: KeyTokenEx, arg1: RequestTokenType, arg2: numpy.ndarray[numpy.uint8]) -> int: ...
    def add_double(self, arg0: KeyTokenEx, arg1: float) -> int: ...
    def add_float(self, arg0: KeyTokenEx, arg1: float) -> int: ...
    def add_int(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def add_int16(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def add_int64(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def add_key_token(self, arg0: KeyTokenEx, arg1: KeyToken) -> int: ...
    def add_string(self, arg0: KeyTokenEx, arg1: str) -> int: ...
    def add_uint(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def add_uint16(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def add_uint64(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def add_uint8(self, arg0: KeyTokenEx, arg1: int) -> int: ...
    def copy(self, arg0: KeyTokenEx, arg1: DynamicRequest) -> bool: ...
    def find_key(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_double(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_float(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_int16(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_int32(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_int64(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_key_token(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_string(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_uint16(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_uint32(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_uint64(self, arg0: KeyTokenEx) -> tuple: ...
    def get_as_uint8(self, arg0: KeyTokenEx) -> tuple: ...
    def get_key(self, arg0: int) -> KeyToken: ...
    def get_request(self) -> Request: ...
    def get_type(self, arg0: int) -> RequestTokenType: ...
    def remove_key(self, arg0: KeyTokenEx) -> bool: ...
    def replace_key(self, arg0: KeyTokenEx, arg1: KeyTokenEx) -> bool: ...
    def replace_value_double(self, arg0: KeyTokenEx, arg1: float) -> bool: ...
    def replace_value_float(self, arg0: KeyTokenEx, arg1: float) -> bool: ...
    def replace_value_int(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def replace_value_int16(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def replace_value_int64(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def replace_value_key_token(self, arg0: KeyTokenEx, arg1: KeyToken) -> bool: ...
    def replace_value_string(self, arg0: KeyTokenEx, arg1: str) -> bool: ...
    def replace_value_uint(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def replace_value_uint16(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def replace_value_uint64(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def replace_value_uint8(self, arg0: KeyTokenEx, arg1: int) -> bool: ...
    def reserve(self, arg0: int) -> None: ...
    def size(self) -> int: ...
    pass
class ExternalStorage():
    def __init__(self, arg0: numpy.ndarray[numpy.uint64]) -> None: ...
    @property
    def values(self) -> numpy.ndarray[numpy.uint64]:
        """
        :type: numpy.ndarray[numpy.uint64]
        """
    @values.setter
    def values(self, arg1: numpy.ndarray[numpy.uint64]) -> None:
        pass
    pass
class IAgent():
    def destroy_request(self, arg0: RequestHandle) -> OperationResult: ...
    def get_request_external_data(self, arg0: ResultHandle) -> tuple: ...
    def get_request_meta_data(self, arg0: ResultHandle) -> tuple: ...
    def get_request_result(self, arg0: RequestHandle) -> tuple: ...
    def get_request_storage_context(self, arg0: RequestHandle) -> tuple: ...
    def request_build(self, arg0: Agent, arg1: Request, arg2: RequestCallbackData) -> tuple: ...
    def validate_request_external_data(self, arg0: RequestHandle, arg1: ResultHandle, arg2: numpy.ndarray[bool], arg3: bool) -> OperationResult: ...
    def wait_all(self, arg0: Agent, arg1: int) -> OperationResult: ...
    def wait_request(self, arg0: RequestHandle, arg1: int) -> OperationResult: ...
    pass
class IDataGrid():
    def create_data_grid(self) -> DataGrid: ...
    def destroy_data_grid(self, arg0: DataGrid) -> None: ...
    pass
class IDataStore():
    class RetrieveFlags():
        """
        Members:

          EN_RETRIEVEFLAG_NONE

          EN_RETRIEVEFLAG_SYNC

          EN_RETRIEVEFLAG_SIZE_ONLY

          EN_RETRIEVEFLAG_EXISTENCE_ONLY

          EN_RETRIEVEFLAG_LOCAL

          EN_RETRIEVEFLAG_CLUSTER
        """
        def __eq__(self, other: object) -> bool: ...
        def __getstate__(self) -> int: ...
        def __hash__(self) -> int: ...
        def __index__(self) -> int: ...
        def __init__(self, value: int) -> None: ...
        def __int__(self) -> int: ...
        def __ne__(self, other: object) -> bool: ...
        def __repr__(self) -> str: ...
        def __setstate__(self, state: int) -> None: ...
        @property
        def name(self) -> str:
            """
            :type: str
            """
        @property
        def value(self) -> int:
            """
            :type: int
            """
        EN_RETRIEVEFLAG_CLUSTER: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_CLUSTER: 16>
        EN_RETRIEVEFLAG_EXISTENCE_ONLY: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_EXISTENCE_ONLY: 4>
        EN_RETRIEVEFLAG_LOCAL: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_LOCAL: 8>
        EN_RETRIEVEFLAG_NONE: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_NONE: 0>
        EN_RETRIEVEFLAG_SIZE_ONLY: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_SIZE_ONLY: 2>
        EN_RETRIEVEFLAG_SYNC: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_SYNC: 1>
        __members__: dict # value = {'EN_RETRIEVEFLAG_NONE': <RetrieveFlags.EN_RETRIEVEFLAG_NONE: 0>, 'EN_RETRIEVEFLAG_SYNC': <RetrieveFlags.EN_RETRIEVEFLAG_SYNC: 1>, 'EN_RETRIEVEFLAG_SIZE_ONLY': <RetrieveFlags.EN_RETRIEVEFLAG_SIZE_ONLY: 2>, 'EN_RETRIEVEFLAG_EXISTENCE_ONLY': <RetrieveFlags.EN_RETRIEVEFLAG_EXISTENCE_ONLY: 4>, 'EN_RETRIEVEFLAG_LOCAL': <RetrieveFlags.EN_RETRIEVEFLAG_LOCAL: 8>, 'EN_RETRIEVEFLAG_CLUSTER': <RetrieveFlags.EN_RETRIEVEFLAG_CLUSTER: 16>}
        pass
    class StoreFlags():
        """
        Members:

          EN_STOREFLAG_DEFAULT

          EN_STOREFLAG_NO_LOCAL

          EN_STOREFLAG_LOCAL_INCONSISTENT

          EN_STOREFLAG_NO_CLUSTER

          EN_STOREFLAG_CLUSTER_INCONSISTENT

          EN_STOREFLAG_NO_REMOTE

          EN_STOREFLAG_REMOTE_INCONSISTENT

          EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW

          EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM

          EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH
        """
        def __eq__(self, other: object) -> bool: ...
        def __getstate__(self) -> int: ...
        def __hash__(self) -> int: ...
        def __index__(self) -> int: ...
        def __init__(self, value: int) -> None: ...
        def __int__(self) -> int: ...
        def __ne__(self, other: object) -> bool: ...
        def __repr__(self) -> str: ...
        def __setstate__(self, state: int) -> None: ...
        @property
        def name(self) -> str:
            """
            :type: str
            """
        @property
        def value(self) -> int:
            """
            :type: int
            """
        EN_STOREFLAG_CLUSTER_INCONSISTENT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_CLUSTER_INCONSISTENT: 8>
        EN_STOREFLAG_DEFAULT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_DEFAULT: 0>
        EN_STOREFLAG_LOCAL_INCONSISTENT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_LOCAL_INCONSISTENT: 2>
        EN_STOREFLAG_NO_CLUSTER: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_NO_CLUSTER: 4>
        EN_STOREFLAG_NO_LOCAL: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_NO_LOCAL: 1>
        EN_STOREFLAG_NO_REMOTE: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_NO_REMOTE: 16>
        EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH: 192>
        EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW: 64>
        EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM: 128>
        EN_STOREFLAG_REMOTE_INCONSISTENT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_REMOTE_INCONSISTENT: 32>
        __members__: dict # value = {'EN_STOREFLAG_DEFAULT': <StoreFlags.EN_STOREFLAG_DEFAULT: 0>, 'EN_STOREFLAG_NO_LOCAL': <StoreFlags.EN_STOREFLAG_NO_LOCAL: 1>, 'EN_STOREFLAG_LOCAL_INCONSISTENT': <StoreFlags.EN_STOREFLAG_LOCAL_INCONSISTENT: 2>, 'EN_STOREFLAG_NO_CLUSTER': <StoreFlags.EN_STOREFLAG_NO_CLUSTER: 4>, 'EN_STOREFLAG_CLUSTER_INCONSISTENT': <StoreFlags.EN_STOREFLAG_CLUSTER_INCONSISTENT: 8>, 'EN_STOREFLAG_NO_REMOTE': <StoreFlags.EN_STOREFLAG_NO_REMOTE: 16>, 'EN_STOREFLAG_REMOTE_INCONSISTENT': <StoreFlags.EN_STOREFLAG_REMOTE_INCONSISTENT: 32>, 'EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW': <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW: 64>, 'EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM': <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM: 128>, 'EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH': <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH: 192>}
        pass
    EN_RETRIEVEFLAG_CLUSTER: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_CLUSTER: 16>
    EN_RETRIEVEFLAG_EXISTENCE_ONLY: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_EXISTENCE_ONLY: 4>
    EN_RETRIEVEFLAG_LOCAL: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_LOCAL: 8>
    EN_RETRIEVEFLAG_NONE: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_NONE: 0>
    EN_RETRIEVEFLAG_SIZE_ONLY: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_SIZE_ONLY: 2>
    EN_RETRIEVEFLAG_SYNC: omni.ujitso._ujitso.IDataStore.RetrieveFlags # value = <RetrieveFlags.EN_RETRIEVEFLAG_SYNC: 1>
    EN_STOREFLAG_CLUSTER_INCONSISTENT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_CLUSTER_INCONSISTENT: 8>
    EN_STOREFLAG_DEFAULT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_DEFAULT: 0>
    EN_STOREFLAG_LOCAL_INCONSISTENT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_LOCAL_INCONSISTENT: 2>
    EN_STOREFLAG_NO_CLUSTER: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_NO_CLUSTER: 4>
    EN_STOREFLAG_NO_LOCAL: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_NO_LOCAL: 1>
    EN_STOREFLAG_NO_REMOTE: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_NO_REMOTE: 16>
    EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_HIGH: 192>
    EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_LOW: 64>
    EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_PERSISTENCE_PRIORITY_MEDIUM: 128>
    EN_STOREFLAG_REMOTE_INCONSISTENT: omni.ujitso._ujitso.IDataStore.StoreFlags # value = <StoreFlags.EN_STOREFLAG_REMOTE_INCONSISTENT: 32>
    pass
class IFactory():
    def create_agent(self, arg0: DataGrid, arg1: IDataStore, arg2: ITaskAgent, arg3: ITaskService, arg4: AgentConfigFlags) -> Agent: ...
    def destroy_agent(self, arg0: Agent) -> None: ...
    pass
class IHTTPFactory():
    def create_agent(self, arg0: str) -> ITaskAgent: ...
    def create_service(self) -> ITaskService: ...
    def run_http_jobs(self, arg0: ITaskService, arg1: str, arg2: str) -> str: ...
    pass
class IInProcessFactory():
    def create_agent(self) -> ITaskAgent: ...
    def get_service(self, arg0: ITaskAgent) -> ITaskService: ...
    pass
class ILocalDataStore():
    def create(self, arg0: str, arg1: int) -> IDataStore: ...
    def destroy(self, arg0: IDataStore) -> None: ...
    pass
class INucleusDataStore():
    def create(self, remote_cache_path: str, remote_cache_discovery_path: str, use_cache_discovery_for_writes: bool = True) -> IDataStore: ...
    def destroy(self, arg0: IDataStore) -> None: ...
    pass
class IRegistry():
    class GlobalKeyToken():
        """
        Members:

          PATH

          VERSION

          TIME

          FLAGS

          PARAM0

          PARAM1

          PARAM2

          PARAM3

          CUSTOM_START
        """
        def __eq__(self, other: object) -> bool: ...
        def __getstate__(self) -> int: ...
        def __hash__(self) -> int: ...
        def __index__(self) -> int: ...
        def __init__(self, value: int) -> None: ...
        def __int__(self) -> int: ...
        def __ne__(self, other: object) -> bool: ...
        def __repr__(self) -> str: ...
        def __setstate__(self, state: int) -> None: ...
        @property
        def name(self) -> str:
            """
            :type: str
            """
        @property
        def value(self) -> int:
            """
            :type: int
            """
        CUSTOM_START: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.CUSTOM_START: 65536>
        FLAGS: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.FLAGS: 3>
        PARAM0: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM0: 4>
        PARAM1: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM1: 5>
        PARAM2: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM2: 6>
        PARAM3: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM3: 7>
        PATH: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PATH: 0>
        TIME: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.TIME: 2>
        VERSION: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.VERSION: 1>
        __members__: dict # value = {'PATH': <GlobalKeyToken.PATH: 0>, 'VERSION': <GlobalKeyToken.VERSION: 1>, 'TIME': <GlobalKeyToken.TIME: 2>, 'FLAGS': <GlobalKeyToken.FLAGS: 3>, 'PARAM0': <GlobalKeyToken.PARAM0: 4>, 'PARAM1': <GlobalKeyToken.PARAM1: 5>, 'PARAM2': <GlobalKeyToken.PARAM2: 6>, 'PARAM3': <GlobalKeyToken.PARAM3: 7>, 'CUSTOM_START': <GlobalKeyToken.CUSTOM_START: 65536>}
        pass
    @staticmethod
    def register_processor(*args, **kwargs) -> None: ...
    @staticmethod
    def unregister_processor(*args, **kwargs) -> None: ...
    CUSTOM_START: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.CUSTOM_START: 65536>
    FLAGS: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.FLAGS: 3>
    PARAM0: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM0: 4>
    PARAM1: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM1: 5>
    PARAM2: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM2: 6>
    PARAM3: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PARAM3: 7>
    PATH: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.PATH: 0>
    TIME: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.TIME: 2>
    VERSION: omni.ujitso._ujitso.IRegistry.GlobalKeyToken # value = <GlobalKeyToken.VERSION: 1>
    pass
class IService():
    def add_dependency(self, arg0: Agent, arg1: DependencyHandle, arg2: Request) -> tuple: ...
    def add_request_tuple_input(self, arg0: Agent, arg1: DependencyHandle, arg2: Request, arg3: bool, arg4: bool) -> OperationResult: ...
    def allocate_meta_data_storage(self, arg0: Agent, arg1: BuildHandle, arg2: int) -> tuple: ...
    def get_dependencies(self, arg0: Agent, arg1: BuildHandle) -> tuple: ...
    def get_external_data(self, arg0: Agent, arg1: BuildHandle) -> tuple: ...
    def get_meta_data(self, arg0: Agent, arg1: BuildHandle) -> tuple: ...
    def set_storage_context(self, arg0: Agent, arg1: DependencyHandle, arg2: str) -> OperationResult: ...
    def store_external_data(self, arg0: Agent, arg1: BuildHandle, arg2: typing.List[numpy.ndarray[numpy.uint8]], arg3: typing.List[ValidationType]) -> OperationResult: ...
    pass
class ITCPFactory():
    def create_agent(self, addressesAndPorts: typing.List[typing.Tuple[str, int]] = [], flags: TCPAgentConfigFlags = TCPAgentConfigFlags.UseRoundRobinServerScheduling) -> ITaskAgent: ...
    def create_service(self, port: int = 0) -> ITaskService: ...
    def get_service_ip(self, arg0: ITaskService) -> str: ...
    pass
class ITaskAgent():
    def destroy(self) -> None: ...
    pass
class ITaskService():
    def destroy(self) -> None: ...
    pass
class KeyToken():
    def __eq__(self, arg0: KeyToken) -> bool: ...
    def __init__(self, value: int = 0) -> None: ...
    @property
    def value(self) -> int:
        """
        :type: int
        """
    @value.setter
    def value(self, arg0: int) -> None:
        pass
    STATIC_STRING_HASH_MARKER = 2147483648
    __hash__ = None
    pass
class KeyTokenEx():
    @typing.overload
    def __eq__(self, arg0: KeyTokenEx) -> bool: ...
    @typing.overload
    def __eq__(self, arg0: KeyToken) -> bool: ...
    @typing.overload
    def __init__(self, arg0: IRegistry.GlobalKeyToken) -> None: ...
    @typing.overload
    def __init__(self, arg0: str) -> None: ...
    @typing.overload
    def __init__(self, arg0: KeyToken) -> None: ...
    @property
    def value(self) -> int:
        """
        :type: int
        """
    @value.setter
    def value(self, arg0: int) -> None:
        pass
    __hash__ = None
    pass
class MatchContext():
    @property
    def agent(self) -> Agent:
        """
        :type: Agent
        """
    @property
    def processor(self) -> carb::ujitso::Processor:
        """
        :type: carb::ujitso::Processor
        """
    pass
class MatchResult():
    """
    Members:

      FAILURE

      LOWEST_PRIORITY

      NORMAL_PRIORITY

      HIGHEST_PRIORITY
    """
    def __eq__(self, other: object) -> bool: ...
    def __getstate__(self) -> int: ...
    def __hash__(self) -> int: ...
    def __index__(self) -> int: ...
    def __init__(self, value: int) -> None: ...
    def __int__(self) -> int: ...
    def __ne__(self, other: object) -> bool: ...
    def __repr__(self) -> str: ...
    def __setstate__(self, state: int) -> None: ...
    @property
    def name(self) -> str:
        """
        :type: str
        """
    @property
    def value(self) -> int:
        """
        :type: int
        """
    FAILURE: omni.ujitso._ujitso.MatchResult # value = <MatchResult.FAILURE: 0>
    HIGHEST_PRIORITY: omni.ujitso._ujitso.MatchResult # value = <MatchResult.HIGHEST_PRIORITY: 2000>
    LOWEST_PRIORITY: omni.ujitso._ujitso.MatchResult # value = <MatchResult.LOWEST_PRIORITY: 1>
    NORMAL_PRIORITY: omni.ujitso._ujitso.MatchResult # value = <MatchResult.NORMAL_PRIORITY: 1000>
    __members__: dict # value = {'FAILURE': <MatchResult.FAILURE: 0>, 'LOWEST_PRIORITY': <MatchResult.LOWEST_PRIORITY: 1>, 'NORMAL_PRIORITY': <MatchResult.NORMAL_PRIORITY: 1000>, 'HIGHEST_PRIORITY': <MatchResult.HIGHEST_PRIORITY: 2000>}
    pass
class OperationResult():
    """
    Members:

      SUCCESS

      FAILURE

      OVERFLOW_ERROR

      INVALIDHANDLE_ERROR

      NOPROCESSOR_ERROR

      NOTFOUND_ERROR

      NOTBUILT_ERROR

      INVALIDMETADATA_ERROR

      OUTOFMEMORY_ERROR

      DATAVALIDATION_ERROR

      INTERNAL
    """
    def __eq__(self, other: object) -> bool: ...
    def __getstate__(self) -> int: ...
    def __hash__(self) -> int: ...
    def __index__(self) -> int: ...
    def __init__(self, value: int) -> None: ...
    def __int__(self) -> int: ...
    def __ne__(self, other: object) -> bool: ...
    def __repr__(self) -> str: ...
    def __setstate__(self, state: int) -> None: ...
    @property
    def name(self) -> str:
        """
        :type: str
        """
    @property
    def value(self) -> int:
        """
        :type: int
        """
    DATAVALIDATION_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.DATAVALIDATION_ERROR: 10>
    FAILURE: omni.ujitso._ujitso.OperationResult # value = <OperationResult.FAILURE: 1>
    INTERNAL: omni.ujitso._ujitso.OperationResult # value = <OperationResult.INTERNAL: 65535>
    INVALIDHANDLE_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.INVALIDHANDLE_ERROR: 3>
    INVALIDMETADATA_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.INVALIDMETADATA_ERROR: 7>
    NOPROCESSOR_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.NOPROCESSOR_ERROR: 4>
    NOTBUILT_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.NOTBUILT_ERROR: 6>
    NOTFOUND_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.NOTFOUND_ERROR: 5>
    OUTOFMEMORY_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.OUTOFMEMORY_ERROR: 8>
    OVERFLOW_ERROR: omni.ujitso._ujitso.OperationResult # value = <OperationResult.OVERFLOW_ERROR: 2>
    SUCCESS: omni.ujitso._ujitso.OperationResult # value = <OperationResult.SUCCESS: 0>
    __members__: dict # value = {'SUCCESS': <OperationResult.SUCCESS: 0>, 'FAILURE': <OperationResult.FAILURE: 1>, 'OVERFLOW_ERROR': <OperationResult.OVERFLOW_ERROR: 2>, 'INVALIDHANDLE_ERROR': <OperationResult.INVALIDHANDLE_ERROR: 3>, 'NOPROCESSOR_ERROR': <OperationResult.NOPROCESSOR_ERROR: 4>, 'NOTFOUND_ERROR': <OperationResult.NOTFOUND_ERROR: 5>, 'NOTBUILT_ERROR': <OperationResult.NOTBUILT_ERROR: 6>, 'INVALIDMETADATA_ERROR': <OperationResult.INVALIDMETADATA_ERROR: 7>, 'OUTOFMEMORY_ERROR': <OperationResult.OUTOFMEMORY_ERROR: 8>, 'DATAVALIDATION_ERROR': <OperationResult.DATAVALIDATION_ERROR: 10>, 'INTERNAL': <OperationResult.INTERNAL: 65535>}
    pass
class Processor():
    @staticmethod
    def __init__(*args, **kwargs) -> typing.Any: ...
    pass
class ProcessorInformation():
    def __init__(self, arg0: str, arg1: int, arg2: int) -> None: ...
    @property
    def name(self) -> str:
        """
        :type: str
        """
    @name.setter
    def name(self, arg1: str) -> None:
        pass
    @property
    def remoteExecutionBatchHint(self) -> int:
        """
        :type: int
        """
    @remoteExecutionBatchHint.setter
    def remoteExecutionBatchHint(self, arg0: int) -> None:
        pass
    @property
    def version(self) -> int:
        """
        :type: int
        """
    @version.setter
    def version(self, arg0: int) -> None:
        pass
    pass
class Request():
    def __init__(self, type: RequestType = ..., token_values: bytes = b'') -> None: ...
    @property
    def tokenValues(self) -> bytes:
        """
        :type: bytes
        """
    @property
    def type(self) -> RequestType:
        """
        :type: RequestType
        """
    pass
class RequestCallbackData():
    def __init__(self, callback: typing.Callable[[object, object, RequestHandle, ResultHandle, OperationResult], None] = None, callback_context_0: object = None, callback_context_1: object = None) -> None: ...
    @property
    def callbackContext0(self) -> object:
        """
        :type: object
        """
    @property
    def callbackContext1(self) -> object:
        """
        :type: object
        """
    pass
class RequestFilter():
    def __init__(self, keys: numpy.ndarray[KeyToken] = array([], dtype=[('value', '<u4')])) -> None: ...
    @property
    def count(self) -> int:
        """
        :type: int
        """
    @property
    def keys(self) -> numpy.ndarray[KeyToken]:
        """
        :type: numpy.ndarray[KeyToken]
        """
    pass
class RequestHandle():
    def __init__(self, value: int = 0) -> None: ...
    @property
    def value(self) -> int:
        """
        :type: int
        """
    @value.setter
    def value(self, arg0: int) -> None:
        pass
    pass
class RequestTokenType():
    def __eq__(self, arg0: RequestTokenType) -> bool: ...
    def __init__(self, size: int = 0, type_name_hash: int = 0) -> None: ...
    @property
    def size(self) -> int:
        """
        :type: int
        """
    @size.setter
    def size(self, arg0: int) -> None:
        pass
    @property
    def typeNameHash(self) -> int:
        """
        :type: int
        """
    @typeNameHash.setter
    def typeNameHash(self, arg0: int) -> None:
        pass
    __hash__ = None
    pass
class RequestType():
    def __init__(self, keys: numpy.ndarray[KeyToken] = array([], dtype=[('value', '<u4')]), types: numpy.ndarray[RequestTokenType] = array([], dtype=[('size', '<u4'), ('typeNameHash', '<u4')])) -> None: ...
    @property
    def count(self) -> int:
        """
        :type: int
        """
    @property
    def keys(self) -> numpy.ndarray[KeyToken]:
        """
        :type: numpy.ndarray[KeyToken]
        """
    @property
    def types(self) -> numpy.ndarray[RequestTokenType]:
        """
        :type: numpy.ndarray[RequestTokenType]
        """
    pass
class ResultHandle():
    def __init__(self, value: int = 0) -> None: ...
    @property
    def value(self) -> int:
        """
        :type: int
        """
    @value.setter
    def value(self, arg0: int) -> None:
        pass
    pass
class TCPAgentConfigFlags():
    """
    Members:

      None

      WaitForConnectionsBeforeLaunch

      UseRoundRobinServerScheduling

      Default
    """
    def __eq__(self, other: object) -> bool: ...
    def __getstate__(self) -> int: ...
    def __hash__(self) -> int: ...
    def __index__(self) -> int: ...
    def __init__(self, value: int) -> None: ...
    def __int__(self) -> int: ...
    def __ne__(self, other: object) -> bool: ...
    def __repr__(self) -> str: ...
    def __setstate__(self, state: int) -> None: ...
    @property
    def name(self) -> str:
        """
        :type: str
        """
    @property
    def value(self) -> int:
        """
        :type: int
        """
    Default: omni.ujitso._ujitso.TCPAgentConfigFlags # value = <TCPAgentConfigFlags.UseRoundRobinServerScheduling: 2>
    None: omni.ujitso._ujitso.TCPAgentConfigFlags # value = <TCPAgentConfigFlags.None: 1>
    UseRoundRobinServerScheduling: omni.ujitso._ujitso.TCPAgentConfigFlags # value = <TCPAgentConfigFlags.UseRoundRobinServerScheduling: 2>
    WaitForConnectionsBeforeLaunch: omni.ujitso._ujitso.TCPAgentConfigFlags # value = <TCPAgentConfigFlags.WaitForConnectionsBeforeLaunch: 4>
    __members__: dict # value = {'None': <TCPAgentConfigFlags.None: 1>, 'WaitForConnectionsBeforeLaunch': <TCPAgentConfigFlags.WaitForConnectionsBeforeLaunch: 4>, 'UseRoundRobinServerScheduling': <TCPAgentConfigFlags.UseRoundRobinServerScheduling: 2>, 'Default': <TCPAgentConfigFlags.UseRoundRobinServerScheduling: 2>}
    pass
class UjitsoUtils():
    @staticmethod
    def get_request_value_double(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: float) -> float: ...
    @staticmethod
    def get_request_value_float(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: float) -> float: ...
    @staticmethod
    def get_request_value_int(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def get_request_value_int16(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def get_request_value_int64(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def get_request_value_key_token(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: KeyToken) -> KeyToken: ...
    @staticmethod
    def get_request_value_string(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: str) -> str: ...
    @staticmethod
    def get_request_value_uint(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def get_request_value_uint16(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def get_request_value_uint64(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def get_request_value_uint8(arg0: Agent, arg1: Request, arg2: KeyTokenEx, arg3: int) -> int: ...
    @staticmethod
    def make_double_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_float_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_int16_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_int32_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_int64_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_key_token_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_uint16_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_uint32_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_uint64_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_uint8_request_token_type() -> RequestTokenType: ...
    @staticmethod
    def make_void_request_token_type() -> RequestTokenType: ...
    pass
class ValidationType():
    """
    Members:

      MANDATORY

      DEFERRED

      NONE
    """
    def __eq__(self, other: object) -> bool: ...
    def __getstate__(self) -> int: ...
    def __hash__(self) -> int: ...
    def __index__(self) -> int: ...
    def __init__(self, value: int) -> None: ...
    def __int__(self) -> int: ...
    def __ne__(self, other: object) -> bool: ...
    def __repr__(self) -> str: ...
    def __setstate__(self, state: int) -> None: ...
    @property
    def name(self) -> str:
        """
        :type: str
        """
    @property
    def value(self) -> int:
        """
        :type: int
        """
    DEFERRED: omni.ujitso._ujitso.ValidationType # value = <ValidationType.DEFERRED: 1>
    MANDATORY: omni.ujitso._ujitso.ValidationType # value = <ValidationType.MANDATORY: 0>
    NONE: omni.ujitso._ujitso.ValidationType # value = <ValidationType.NONE: 2>
    __members__: dict # value = {'MANDATORY': <ValidationType.MANDATORY: 0>, 'DEFERRED': <ValidationType.DEFERRED: 1>, 'NONE': <ValidationType.NONE: 2>}
    pass
def acquire_agent_interface(plugin_name: str = None, library_path: str = None) -> IAgent:
    pass
def acquire_data_grid_interface(plugin_name: str = None, library_path: str = None) -> IDataGrid:
    pass
def acquire_factory_interface(plugin_name: str = None, library_path: str = None) -> IFactory:
    pass
def acquire_http_factory_interface(plugin_name: str = None, library_path: str = None) -> IHTTPFactory:
    pass
def acquire_in_progress_factory_interface(plugin_name: str = None, library_path: str = None) -> IInProcessFactory:
    pass
def acquire_local_data_store_interface(plugin_name: str = None, library_path: str = None) -> ILocalDataStore:
    pass
def acquire_nucleus_data_store_interface(plugin_name: str = None, library_path: str = None) -> INucleusDataStore:
    pass
def acquire_registry_interface(plugin_name: str = None, library_path: str = None) -> IRegistry:
    pass
def acquire_service_interface(plugin_name: str = None, library_path: str = None) -> IService:
    pass
def acquire_tcp_factory_interface(plugin_name: str = None, library_path: str = None) -> ITCPFactory:
    pass
def release_agent_interface(arg0: IAgent) -> None:
    pass
def release_data_grid_interface(arg0: IDataGrid) -> None:
    pass
def release_factory_interface(arg0: IFactory) -> None:
    pass
def release_http_factory_interface(arg0: IHTTPFactory) -> None:
    pass
def release_in_progress_factory_interface(arg0: IInProcessFactory) -> None:
    pass
def release_local_data_store_interface(arg0: ILocalDataStore) -> None:
    pass
def release_nucleus_data_store_interface(arg0: INucleusDataStore) -> None:
    pass
def release_registry_interface(arg0: IRegistry) -> None:
    pass
def release_service_interface(arg0: IService) -> None:
    pass
def release_tcp_factory_interface(arg0: ITCPFactory) -> None:
    pass
Default: omni.ujitso._ujitso.AgentConfigFlags # value = <AgentConfigFlags.None: 1>
ForceRemoteTasks: omni.ujitso._ujitso.AgentConfigFlags # value = <AgentConfigFlags.ForceRemoteTasks: 2>
None: omni.ujitso._ujitso.AgentConfigFlags # value = <AgentConfigFlags.None: 1>
TIME_OUT_INFINITE = 4294967295
UseRoundRobinServerScheduling: omni.ujitso._ujitso.TCPAgentConfigFlags # value = <TCPAgentConfigFlags.UseRoundRobinServerScheduling: 2>
WaitForConnectionsBeforeLaunch: omni.ujitso._ujitso.TCPAgentConfigFlags # value = <TCPAgentConfigFlags.WaitForConnectionsBeforeLaunch: 4>
