索引

_

__call__() （nameko.cli.actions.FlagAction 方法） __call__() （nameko.rpc.MethodProxy 方法） __call__() （nameko.web.server.WsgiApp 方法） __enter__() （nameko.standalone.rpc.StandaloneProxyBase 方法） __eq__() （nameko.testing.utils.AnyInstanceOf 方法） __exit__() （nameko.standalone.rpc.StandaloneProxyBase 方法） __getattr__() （nameko.rpc.ServiceProxy 方法） __getattr__() （nameko.standalone.rpc.ClusterProxy 方法） __getattr__() （nameko.utils.concurrency.SpawningProxy 方法） __getitem__() （nameko.standalone.rpc.ClusterProxy 方法） __ne__() （nameko.testing.utils.AnyInstanceOf 方法） __params（nameko.extensions.Extension 属性） __repr__() （nameko.containers.ServiceContainer 方法） __repr__() （nameko.containers.WorkerContext 方法） __repr__() （nameko.extensions.DependencyProvider 方法） __repr__() （nameko.extensions.Entrypoint 方法） __repr__() （nameko.extensions.Extension 方法） __repr__() （nameko.rpc.MethodProxy 方法） __repr__() （nameko.testing.utils.AnyInstanceOf 方法） __str__() （nameko.exceptions.UnknownService 方法） __str__() （nameko.exceptions.UnserializableValueError 方法） _base_url（nameko.testing.rabbit.Client 属性） _being_killed（nameko.containers.ServiceContainer 属性） _build_url() （nameko.testing.rabbit.Client 方法） _call() （nameko.rpc.MethodProxy 方法） _call_id_stack（nameko.containers.WorkerContext 属性） _call_id（nameko.containers.WorkerContext 属性） _cancel_consumers_if_requested() （nameko.messaging.QueueConsumer 方法） _consumers_ready（nameko.messaging.QueueConsumer 属性） _consumers（nameko.messaging.QueueConsumer 属性） _create() （nameko.testing.utils.ResourcePipeline 方法） _delete() （nameko.testing.rabbit.Client 方法） _destroy() （nameko.testing.utils.ResourcePipeline 方法） _died（nameko.containers.ServiceContainer 属性） _get() （nameko.testing.rabbit.Client 方法） _get_connection() （nameko.web.websocket.WebSocketHub 方法） _get_header_name() （nameko.messaging.HeaderEncoder 方法） _gt（nameko.messaging.QueueConsumer 属性） _gt（nameko.web.server.WebServer 属性） _handle_managed_thread_exited() （nameko.containers.ServiceContainer 方法） _handle_thread_exited() （nameko.containers.ServiceContainer 方法） _handle_thread_exited() （nameko.messaging.QueueConsumer 方法） _handle_worker_thread_exited() （nameko.containers.ServiceContainer 方法） _inject_dependencies() （nameko.containers.ServiceContainer 方法） _is_accepting（nameko.web.server.WebServer 属性） _items（nameko.utils.concurrency.SpawningProxy 属性） _kill_managed_threads() （nameko.containers.ServiceContainer 方法） _kill_worker_threads() （nameko.containers.ServiceContainer 方法） _last_provider_unregistered（nameko.extensions.ProviderCollector 属性） _log()（在 nameko.containers 模块中）

_log()（在 nameko.events 模块中） _log()（在 nameko.extensions 模块中） _log()（在 nameko.messaging 模块中） _log()（在 nameko.rpc 模块中） _log()（在 nameko.runners 模块中） _log()（在 nameko.timer 模块中） _log()（在 nameko.web.handlers 模块中） _log()（在 nameko.web.websocket 模块中） _log_time()（在 nameko.containers 模块中） _logger()（在 nameko.standalone.rpc 模块中） _managed_threads（nameko.containers.ServiceContainer 属性） _parent_call_id_stack（nameko.containers.WorkerContext 属性） _pending_remove_providers（nameko.messaging.QueueConsumer 属性） _post() （nameko.testing.rabbit.Client 方法） _providers_registered（nameko.extensions.ProviderCollector 属性） _providers（nameko.extensions.ProviderCollector 属性） _proxies（nameko.standalone.rpc.ClusterProxy 属性） _proxy（nameko.standalone.rpc.ClusterRpcProxy 属性） _proxy（nameko.standalone.rpc.ServiceRpcProxy 属性） _proxy（nameko.standalone.rpc.StandaloneProxyBase 属性） _put() （nameko.testing.rabbit.Client 方法） _replace_dependencies()（在 nameko.testing.services 模块中） _replace_env_var()（在 nameko.cli.main 模块中） _reply_events（nameko.rpc.ReplyListener 属性） _reply_events（nameko.standalone.rpc.SingleThreadedReplyListener 属性） _reply_listener（nameko.standalone.rpc.ClusterProxy 属性） _reply_listener（nameko.standalone.rpc.StandaloneProxyBase 属性） _request() （nameko.testing.rabbit.Client 方法） _run() （nameko.timer.Timer 方法） _run_worker() （nameko.containers.ServiceContainer 方法） _server（nameko.web.websocket.WebSocketHub 属性） _service_name（nameko.exceptions.UnknownService 属性） _serv（nameko.web.server.WebServer 属性） _session（nameko.testing.rabbit.Client 属性） _setup_consumer() （nameko.standalone.rpc.PollingQueueConsumer 方法） _shutdown() （nameko.testing.utils.ResourcePipeline 方法） _sock（nameko.web.server.WebServer 属性） _start() （nameko.testing.utils.ResourcePipeline 方法） _starting（nameko.messaging.QueueConsumer 属性） _starting（nameko.web.server.WebServer 属性） _strip_header_name() （nameko.messaging.HeaderDecoder 方法） _unregistered_from_queue_consumer（nameko.rpc.RpcConsumer 属性） _unregistering_providers（nameko.rpc.RpcConsumer 属性） _verify_api_connection() （nameko.testing.rabbit.Client 方法） _worker_ctx（nameko.standalone.rpc.ClusterProxy 属性） _worker_ctx（nameko.standalone.rpc.StandaloneProxyBase 属性） _worker_pool（nameko.containers.ServiceContainer 属性） _worker_result() （nameko.containers.ServiceContainer 方法） _worker_setup() （nameko.containers.ServiceContainer 方法） _worker_teardown() （nameko.containers.ServiceContainer 方法） _worker_threads（nameko.containers.ServiceContainer 属性）

A

abort_on_error（nameko.utils.concurrency.SpawningProxy 属性） ACCEPT_CONFIG_KEY()（在 nameko.constants 模块中） accept（nameko.messaging.QueueConsumer 属性） ack_message() （nameko.messaging.QueueConsumer 方法） ack_message() （nameko.standalone.rpc.PollingQueueConsumer 方法） add_service() （nameko.runners.ServiceRunner 方法） add_websocket() （nameko.web.websocket.WebSocketServer 方法） all（nameko.utils.concurrency.SpawningSet 属性） AMQP_SSL_CONFIG_KEY()（在 nameko.constants 模块中） amqp_uri()（在 nameko.testing.pytest 模块中） AMQP_URI_CONFIG_KEY()（在 nameko.constants 模块中） amqp_uri（nameko.amqp.publish.Publisher 属性） amqp_uri（nameko.messaging.Publisher 属性）

amqp_uri（nameko.messaging.QueueConsumer 属性） amqp_uri（nameko.rpc.MethodProxy 属性） amqp_uri（nameko.rpc.Responder 属性） ANY_PARTIAL()（在 nameko.testing.utils 模块中） AnyInstanceOf（nameko.testing.utils 中的类） args（nameko.containers.WorkerContext 属性） args（nameko.testing.services.Once 属性） assert_stops_raising()（在 nameko.testing.utils 模块中） attr_name（nameko.extensions.DependencyProvider 属性） attr_name（nameko.testing.services.MockDependencyProvider 属性） AUTH_TOKEN_CONTEXT_KEY()（在 nameko.constants 模块中） AuthToken（nameko.contextdata 中的类） auth（nameko.testing.rabbit.Client 属性）

B

Backdoor（nameko.cli.commands 中的类） backoff（nameko.utils.retry.RetryDelay 属性） BadRequest banner（nameko.cli.shell.ShellRunner 属性） bind() （nameko.extensions.DependencyProvider 方法） bind() （nameko.extensions.Entrypoint 方法） bind() （nameko.extensions.Extension 方法）

bind() （nameko.extensions.SharedExtension 方法） bind_addr（nameko.web.server.WebServer 属性） BindAddress()（在 nameko.web.server 模块中） bpython() （nameko.cli.shell.ShellRunner 方法） broadcast() （nameko.web.websocket.WebSocketHub 方法） BROADCAST()（在 nameko.events 模块中） broadcast_identifier（nameko.events.EventHandler 属性）

C

call_async() （nameko.rpc.MethodProxy 方法） CALL_ID_STACK_CONTEXT_KEY()（在 nameko.constants 模块中） call_id_stack（nameko.containers.WorkerContext 属性） call_id（nameko.containers.WorkerContext 属性） check_signature() （nameko.extensions.Entrypoint 方法） cleanup_websocket() （nameko.web.websocket.WebSocketHubProvider 方法） Client（nameko.testing.rabbit 中的类） cls（nameko.testing.utils.AnyInstanceOf 属性） ClusterProxy（nameko.standalone.rpc 中的类） ClusterRpcProxy（nameko.standalone.rpc 中的类） CommandError commands()（在 nameko.cli.commands 模块中） Command（nameko.cli.commands 中的类） compat_attrs（nameko.messaging.Publisher 属性） compat_attrs（nameko.rpc.MethodProxy 属性） compression（nameko.amqp.publish.Publisher 属性） ConfigurationError config（nameko.containers.ServiceContainer 属性） config（nameko.containers.WorkerContext 属性） Config（nameko.dependency_providers 中的类） config（nameko.runners.ServiceRunner 属性） config（nameko.standalone.rpc.StandaloneProxyBase.ServiceContainer 属性） ConnectionNotFound connections（nameko.web.websocket.WebSocketHub 属性） connection（nameko.messaging.QueueConsumer 属性） Connection（nameko.web.websocket 中的类）

consume()（在 nameko.messaging 模块中） ConsumeEvent（nameko.standalone.rpc 中的类） Consumer（nameko.messaging 中的类） consumer（nameko.standalone.rpc.PollingQueueConsumer 属性） container_cls（nameko.runners.ServiceRunner 属性） container_factory()（在 nameko.testing.pytest 模块中） ContainerBeingKilled containers（nameko.runners.ServiceRunner 属性） ContainerT()（在 nameko.utils.concurrency 模块中） container（nameko.containers.WorkerContext 属性） container（nameko.extensions.Extension 属性） container（nameko.rpc.MethodProxy 属性） container（nameko.standalone.rpc.StandaloneProxyBase 属性） context_data_from_headers() （nameko.web.server.WebServer 方法） context_data（nameko.containers.WorkerContext 属性） context_data（nameko.web.websocket.Connection 属性） context_key（nameko.contextdata.AuthToken 属性） context_key（nameko.contextdata.ContextDataProvider 属性） context_key（nameko.contextdata.Language 属性） context_key（nameko.contextdata.UserAgent 属性） context_key（nameko.contextdata.UserId 属性） ContextDataProvider（nameko.contextdata 中的类） correlation_id（nameko.standalone.rpc.ConsumeEvent 属性） create_queue() （nameko.testing.rabbit.Client 方法） create_queue_binding() （nameko.testing.rabbit.Client 方法） create_vhost() （nameko.testing.rabbit.Client 方法） create（nameko.testing.utils.ResourcePipeline 属性）

D

data（nameko.containers.WorkerContext 属性） declare（nameko.amqp.publish.Publisher 属性） declare（nameko.messaging.Publisher 属性） decorator()（nameko.extensions.Entrypoint 类方法） DEFAULT_HEARTBEAT()（在 nameko.constants 模块中） DEFAULT_MAX_WORKERS()（在 nameko.constants 模块中） DEFAULT_PARENT_CALLS_TRACKED()（在 nameko.constants 模块中） DEFAULT_RETRY_POLICY()（在 nameko.constants 模块中） DEFAULT_SERIALIZER()（在 nameko.constants 模块中） DEFAULT_TRANSPORT_OPTIONS()（在 nameko.constants 模块中） delay（nameko.utils.retry.RetryDelay 属性） delete_connection() （nameko.testing.rabbit.Client 方法）

delete_vhost() （nameko.testing.rabbit.Client 方法） delivery_mode（nameko.amqp.publish.Publisher 属性） dependencies（nameko.containers.ServiceContainer 属性） dependency_attrs（nameko.containers.ServiceContainer 属性） DependencyProvider（nameko.extensions 中的类） dependency（nameko.testing.services.MockDependencyProvider 属性） deserialize()（在 nameko.exceptions 模块中） deserialize_to_instance()（在 nameko.exceptions 模块中） deserialize_ws_frame() （nameko.web.websocket.WebSocketServer 方法） destroy（nameko.testing.utils.ResourcePipeline 属性） dummy()（在 nameko.testing.services 模块中） DummyProvider（nameko.testing.utils 中的类）

E

eager（nameko.timer.Timer 属性） empty_config()（在 nameko.testing.pytest 模块中） ENTRYPOINT_EXTENSIONS_ATTR()（在 nameko.extensions 模块中） entrypoint_hook()（在 nameko.testing.services 模块中） entrypoint_waiter()（在 nameko.testing.services 模块中） entrypoints_methods（nameko.containers.ServiceContainer 属性） entrypoints（nameko.containers.ServiceContainer 属性） EntrypointWaiterTimeout entrypoint（nameko.containers.WorkerContext 属性） Entrypoint（nameko.extensions 中的类） env_var_constructor()（在 nameko.cli.main 模块中） event_dispatcher()（在 nameko.standalone.events 模块中） event_handler()（在 nameko.events 模块中） event_type（nameko.events.EventHandler 属性）

EventDispatcher（nameko.events 中的类） EventHandlerConfigurationError EventHandler（nameko.events 中的类） exc_info（nameko.testing.waiting.WaitResult 属性） exc_type（nameko.exceptions.RemoteError 属性） exception（nameko.standalone.rpc.ConsumeEvent 属性） exchange（nameko.messaging.Publisher 属性） exchange（nameko.rpc.Responder 属性） expected_exceptions（nameko.extensions.Entrypoint 属性） expected_exceptions（nameko.testing.services.Once 属性） expiration（nameko.amqp.publish.Publisher 属性） ExtensionNotFound extensions（nameko.containers.ServiceContainer 属性） Extension（nameko.extensions 中的类）

F

fail_fast_imap()（在 nameko.utils.concurrency 模块中） fast_teardown()（在 nameko.testing.pytest 模块中）

find_free_port()（在 nameko.testing.utils 模块中） finish() （nameko.web.server.HttpOnlyProtocol 方法） FlagAction（nameko.cli.actions 中的类）

G

get() （nameko.testing.utils.ResourcePipeline 方法） get() （nameko.testing.waiting.WaitResult 方法） get_all_vhosts() （nameko.testing.rabbit.Client 方法） get_connection()（在 nameko.amqp 模块中） get_connection()（在 nameko.amqp.publish 模块中） get_connections() （nameko.testing.rabbit.Client 方法） get_consumers() （nameko.messaging.QueueConsumer 方法） get_container()（在 nameko.testing.utils 模块中） get_container_cls()（在 nameko.containers 模块中） get_dependency() （nameko.contextdata.ContextDataProvider 方法） get_dependency() （nameko.dependency_providers.Config 方法） get_dependency() （nameko.events.EventDispatcher 方法） get_dependency() （nameko.extensions.DependencyProvider 方法） get_dependency() （nameko.messaging.Publisher 方法） get_dependency() （nameko.rpc.RpcProxy 方法） get_dependency() （nameko.testing.services.MockDependencyProvider 方法） get_dependency() （nameko.web.websocket.WebSocketHubProvider 方法） get_entrypoint_parameters() （nameko.web.handlers.HttpRequestHandler 方法） get_event_exchange()（在 nameko.standalone.events 模块中） get_exchanges() （nameko.testing.rabbit.Client 方法） get_extension()（在 nameko.testing.utils 模块中） get_message() （nameko.standalone.rpc.PollingQueueConsumer 方法）

get_message_from_queue()（在 nameko.testing.pytest 模块中） get_message_headers() （nameko.messaging.HeaderEncoder 方法） get_messages() （nameko.testing.rabbit.Client 方法） get_module_path()（在 nameko.exceptions 模块中） get_producer()（在 nameko.amqp 模块中） get_producer()（在 nameko.amqp.publish 模块中） get_provider_for_method() （nameko.rpc.RpcConsumer 方法） get_provider_for_method() （nameko.web.websocket.WebSocketServer 方法） get_queue() （nameko.testing.rabbit.Client 方法） get_queue_bindings() （nameko.testing.rabbit.Client 方法） get_queues() （nameko.testing.rabbit.Client 方法） get_rabbit_connections()（在 nameko.testing.utils 模块中） get_redacted_args()（在 nameko.utils 模块中） get_reply_event() （nameko.rpc.ReplyListener 方法） get_reply_event() （nameko.standalone.rpc.SingleThreadedReplyListener 方法） get_rpc_exchange()（在 nameko.rpc 模块中） get_service_name()（在 nameko.containers 模块中） get_subscriptions() （nameko.web.websocket.WebSocketHub 方法） get_url_rule() （nameko.web.handlers.HttpRequestHandler 方法） get_url_rule() （nameko.web.websocket.WebSocketServer 方法） get_wsgi_app() （nameko.web.server.WebServer 方法） get_wsgi_server() （nameko.web.server.WebServer 方法） gt（nameko.timer.Timer 属性）

H

handle_message() （nameko.messaging.Consumer 方法） handle_message() （nameko.messaging.QueueConsumer 方法） handle_message() （nameko.rpc.ReplyListener 方法） handle_message() （nameko.rpc.Rpc 方法） handle_message() （nameko.rpc.RpcConsumer 方法） handle_message() （nameko.web.websocket.WebSocketRpc 方法） handle_message_processed() （nameko.messaging.Consumer 方法） handle_request() （nameko.web.handlers.HttpRequestHandler 方法） handle_request() （nameko.web.websocket.WebSocketServer 方法） handle_result() （nameko.messaging.Consumer 方法） handle_result() （nameko.rpc.Rpc 方法） handle_result() （nameko.rpc.RpcConsumer 方法） handle_result() （nameko.timer.Timer 方法） handle_result() （nameko.web.handlers.HttpRequestHandler 方法） handle_result() （nameko.web.websocket.WebSocketRpc 方法）

handle_timer_tick() （nameko.timer.Timer 方法） handle_websocket_request() （nameko.web.websocket.WebSocketServer 方法） handler_type（nameko.events.EventHandler 属性） has_regex_module()（在 nameko.cli.main 模块中） has_result（nameko.testing.waiting.WaitResult 属性） HEADER_PREFIX()（在 nameko.constants 模块中） header_prefix（nameko.messaging.HeaderDecoder 属性） header_prefix（nameko.messaging.HeaderEncoder 属性） HeaderDecoder（nameko.messaging 中的类） HeaderEncoder（nameko.messaging 中的类） HEARTBEAT_CONFIG_KEY()（在 nameko.constants 模块中） http()（在 nameko.web.handlers 模块中） HttpOnlyProtocol（nameko.web.server 中的类） HttpRequestHandler（nameko.web.handlers 中的类） hub（nameko.web.websocket.WebSocketHubProvider 属性）

I

IDENTIFY_WEBSOCKET_RULES()（在 nameko.web.websocket 模块中） immediate_parent_call_id（nameko.containers.WorkerContext 属性） IMPLICIT_ENV_VAR_MATCHER()（在 nameko.cli.main 模块中） import_from_path()（在 nameko.utils 模块中） import_service()（在 nameko.cli.run 模块中） IncorrectSignature init_parser()（nameko.cli.commands.Backdoor 静态方法） init_parser()（nameko.cli.commands.Command 静态方法） init_parser()（nameko.cli.commands.Run 静态方法） init_parser()（nameko.cli.commands.Shell 类方法） init_parser()（nameko.cli.commands.ShowConfig 静态方法） init_parser()（nameko.cli.commands.Test 静态方法）

interact()（在 nameko.cli.code 模块中） interface（nameko.containers.ServiceContainer 属性） interval（nameko.timer.Timer 属性） ipython() （nameko.cli.shell.ShellRunner 方法） is_bound() （nameko.extensions.Extension 方法） is_dependency()（在 nameko.extensions 模块中） is_entrypoint()（在 nameko.cli.run 模块中） is_entrypoint()（在 nameko.extensions 模块中） is_extension()（在 nameko.extensions 模块中） is_method()（在 nameko.containers 模块中） is_type()（在 nameko.cli.run 模块中） iter_extensions()（在 nameko.extensions 模块中）

K

kill() （nameko.containers.ServiceContainer 方法） kill() （nameko.extensions.Extension 方法） kill() （nameko.messaging.QueueConsumer 方法）

kill() （nameko.runners.ServiceRunner 方法） kill() （nameko.timer.Timer 方法） kwargs（nameko.containers.WorkerContext 属性） kwargs（nameko.testing.services.Once 属性）

L

LANGUAGE_CONTEXT_KEY()（在 nameko.constants 模块中） Language（nameko.contextdata 中的类） local（nameko.cli.shell.ShellRunner 属性） logger()（在 nameko.cli.run 模块中）

LOGIN_METHOD_CONFIG_KEY()（在 nameko.constants 模块中） login_method（nameko.amqp.publish.Publisher 属性） login_method（nameko.rpc.MethodProxy 属性） login_method（nameko.rpc.Responder 属性）

M

main()（nameko.cli.commands.Backdoor 静态方法） main()（nameko.cli.commands.Command 静态方法） main()（nameko.cli.commands.Run 静态方法） main()（nameko.cli.commands.Shell 静态方法） main()（nameko.cli.commands.ShowConfig 静态方法） main()（nameko.cli.commands.Test 静态方法） main()（在 nameko.cli.backdoor 模块中） main()（在 nameko.cli.main 模块中） main()（在 nameko.cli.run 模块中） main()（在 nameko.cli.shell 模块中） main()（在 nameko.cli.show_config 模块中） make_nameko_helper()（在 nameko.cli.shell 模块中） make_timing_logger()（在 nameko.log_helpers 模块中） make_url_map() （nameko.web.server.WebServer 方法） make_virtual_socket()（在 nameko.testing.websocket 模块中） MalformedRequest mandatory（nameko.amqp.publish.Publisher 属性） max_delay（nameko.utils.retry.RetryDelay 属性） MAX_WORKERS_CONFIG_KEY()（在 nameko.constants 模块中） max_workers（nameko.containers.ServiceContainer 属性） message（nameko.exceptions.RemoteError 属性） message（nameko.rpc.Responder 属性） method_name（nameko.extensions.Entrypoint 属性） method_name（nameko.rpc.MethodProxy 属性） method_name（nameko.standalone.rpc.StandaloneProxyBase.Dummy 属性） method_name（nameko.testing.utils.DummyProvider 属性） MethodNotFound MethodProxy（nameko.rpc 中的类） method（nameko.web.handlers.HttpRequestHandler 属性） MISSING_MODULE_TEMPLATE()（在 nameko.cli.run 模块中） mock_container()（在 nameko.testing.pytest 模块中） MockCallArgs()（在 nameko.testing.utils 模块中） MockDependencyProvider（nameko.testing.services 中的类） module nameko nameko.__main__ nameko.amqp nameko.amqp.publish nameko.cli nameko.cli.actions nameko.cli.backdoor nameko.cli.code nameko.cli.commands nameko.cli.main nameko.cli.run nameko.cli.shell nameko.cli.show_config nameko.constants nameko.containers nameko.contextdata nameko.dependency_providers nameko.events nameko.exceptions nameko.extensions nameko.log_helpers nameko.messaging nameko.rpc nameko.runners nameko.serialization nameko.standalone nameko.standalone.events nameko.standalone.rpc nameko.testing nameko.testing.pytest nameko.testing.rabbit nameko.testing.services nameko.testing.utils nameko.testing.waiting nameko.testing.websocket nameko.timer nameko.utils nameko.utils.concurrency nameko.utils.retry nameko.web nameko.web.handlers nameko.web.server nameko.web.websocket

N

nameko module nameko.__main__ module nameko.amqp module nameko.amqp.publish module nameko.cli module nameko.cli.actions module nameko.cli.backdoor module nameko.cli.code module nameko.cli.commands module nameko.cli.main module nameko.cli.run module nameko.cli.shell module nameko.cli.show_config module nameko.constants module nameko.containers module nameko.contextdata module nameko.dependency_providers module nameko.events module nameko.exceptions module nameko.extensions module nameko.log_helpers module nameko.messaging module nameko.rpc module nameko.runners module

nameko.serialization module nameko.standalone module nameko.standalone.events module nameko.standalone.rpc module nameko.testing module nameko.testing.pytest module nameko.testing.rabbit module nameko.testing.services module nameko.testing.utils module nameko.testing.waiting module nameko.testing.websocket module nameko.timer module nameko.utils module nameko.utils.concurrency module nameko.utils.retry module nameko.web module nameko.web.handlers module nameko.web.server module nameko.web.websocket module name（nameko.cli.commands.Backdoor 属性） name（nameko.cli.commands.Command 属性） name（nameko.cli.commands.Run 属性） name（nameko.cli.commands.Shell 属性） name（nameko.cli.commands.ShowConfig 属性） name（nameko.cli.commands.Test 属性） negative_strings（nameko.cli.actions.FlagAction 属性） new_call_id()（在 nameko.containers 模块中） next() （nameko.utils.retry.RetryDelay 方法） NON_PERSISTENT()（在 nameko.constants 模块中）

O

on_connection_error() （nameko.messaging.QueueConsumer 方法） on_consume_ready() （nameko.messaging.QueueConsumer 方法） on_iteration() （nameko.messaging.QueueConsumer 方法） on_message() （nameko.standalone.rpc.PollingQueueConsumer 方法） once()（在 nameko.testing.services 模块中）

Once（nameko.testing.services 中的类） options（nameko.messaging.Publisher 属性） options（nameko.rpc.RpcProxy 属性） options（nameko.rpc.ServiceProxy 属性） origin_call_id（nameko.containers.WorkerContext 属性）

P

PARENT_CALLS_CONFIG_KEY()（在 nameko.constants 模块中） parse_address()（在 nameko.web.server 模块中） parse_config_option()（在 nameko.testing.pytest 模块中） PERSISTENT()（在 nameko.constants 模块中） plain() （nameko.cli.shell.ShellRunner 方法） PollingQueueConsumer（nameko.standalone.rpc 中的类） positive_strings（nameko.cli.actions.FlagAction 属性） predictable_call_ids()（在 nameko.testing.pytest 模块中） prefetch_count（nameko.messaging.QueueConsumer 属性） priority（nameko.amqp.publish.Publisher 属性） process_request() （nameko.web.server.WebServer 方法） ProviderCollector（nameko.extensions 中的类）

publish() （nameko.amqp.publish.Publisher 方法） publish() （nameko.testing.rabbit.Client 方法） publish_kwargs（nameko.amqp.publish.Publisher 属性） publisher_cls（nameko.messaging.Publisher 属性） publisher_cls（nameko.rpc.MethodProxy 属性） publisher_cls（nameko.rpc.Responder 属性） Publisher（nameko.amqp.publish 中的类） Publisher（nameko.messaging 中的类） publisher（nameko.rpc.MethodProxy 属性） pytest_addoption()（在 nameko.testing.pytest 模块中） pytest_configure()（在 nameko.testing.pytest 模块中） pytest_sessionstart()（在 nameko.testing.pytest 模块中）

Q

queue_consumer（nameko.messaging.Consumer 属性） queue_consumer（nameko.rpc.ReplyListener 属性） queue_consumer（nameko.rpc.RpcConsumer 属性） queue_consumer（nameko.standalone.rpc.ConsumeEvent 属性）

queue_consumer（nameko.standalone.rpc.SingleThreadedReplyListener 属性） QueueConsumerStopped QueueConsumer（nameko.messaging 中的类） queue（nameko.messaging.Consumer 属性） queue（nameko.rpc.RpcConsumer 属性）

R

rabbit_config()（在 nameko.testing.pytest 模块中） rabbit_manager()（在 nameko.testing.pytest 模块中） rabbit_ssl_config()（在 nameko.testing.pytest 模块中） raise_expections（nameko.cli.code.RaisingInteractiveConsole 属性） RaisingInteractiveConsole（nameko.cli.code 中的类） ready（nameko.testing.utils.ResourcePipeline 属性） RECURSIVE_ENV_VAR_MATCHER()（在 nameko.cli.main 模块中） REDACTED()（在 nameko.utils 模块中） register_entrypoint()（在 nameko.extensions 模块中） register_provider() （nameko.extensions.ProviderCollector 方法） register_provider() （nameko.standalone.rpc.PollingQueueConsumer 方法） registry()（在 nameko.exceptions 模块中） reliable_delivery（nameko.events.EventHandler 属性） RemoteError remove_socket() （nameko.web.websocket.WebSocketServer 方法） replace_dependencies()（在 nameko.testing.services 模块中） replies（nameko.standalone.rpc.PollingQueueConsumer 属性） reply_event（nameko.rpc.RpcReply 属性） reply_listener（nameko.rpc.MethodProxy 属性） reply_listener（nameko.rpc.ServiceProxy 属性） ReplyListener（nameko.rpc 中的类） ReplyQueueExpiredWithPendingReplies requeue_message() （nameko.messaging.QueueConsumer 方法） requeue_message() （nameko.rpc.RpcConsumer 方法） requeue_on_error（nameko.messaging.Consumer 属性） reset_rabbit_connections()（在 nameko.testing.utils 模块中） ResourcePipeline（nameko.testing.utils 中的类） resp_body（nameko.rpc.RpcReply 属性） Responder（nameko.rpc 中的类）

response_from_exception() （nameko.web.handlers.HttpRequestHandler 方法） response_from_result() （nameko.web.handlers.HttpRequestHandler 方法） restrict_entrypoints()（在 nameko.testing.services 模块中） result() （nameko.rpc.RpcReply 方法） res（nameko.testing.waiting.WaitResult 属性） retry()（在 nameko.utils.retry 模块中） retry_policy（nameko.amqp.publish.Publisher 属性） RetryDelay（nameko.utils.retry 中的类） retry（nameko.amqp.publish.Publisher 属性） rpc()（在 nameko.rpc 模块中） rpc()（在 nameko.web.websocket 模块中） rpc_consumer（nameko.rpc.Rpc 属性） RPC_EXCHANGE_CONFIG_KEY()（在 nameko.constants 模块中） RPC_QUEUE_TEMPLATE()（在 nameko.rpc 模块中） rpc_reply_listener（nameko.rpc.RpcProxy 属性） RPC_REPLY_QUEUE_TEMPLATE()（在 nameko.rpc 模块中） RPC_REPLY_QUEUE_TTL()（在 nameko.rpc 模块中） RpcConsumer（nameko.rpc 中的类） RpcProxy（nameko.rpc 中的类） RpcReply（nameko.rpc 中的类） RpcTimeout Rpc（nameko.rpc 中的类） run() （nameko.testing.utils.ResourcePipeline 方法） run() （nameko.web.server.WebServer 方法） run()（在 nameko.cli.run 模块中） run_services()（在 nameko.runners 模块中） runcode() （nameko.cli.code.RaisingInteractiveConsole 方法） runner_factory()（在 nameko.testing.pytest 模块中） Run（nameko.cli.commands 中的类）

S

safe_for_serialization()（在 nameko.exceptions 模块中） sanitize_url()（在 nameko.utils 模块中） send() （nameko.standalone.rpc.ConsumeEvent 方法） send() （nameko.testing.waiting.WaitResult 方法） send_exception() （nameko.standalone.rpc.ConsumeEvent 方法） send_response() （nameko.rpc.Responder 方法） sensitive_arguments（nameko.extensions.Entrypoint 属性） sensitive_arguments（nameko.testing.services.Once 属性） sensitive_variables（nameko.extensions.Entrypoint 属性） sensitive_variables（nameko.testing.services.Once 属性） sentinel（nameko.testing.waiting.WaitResult 属性） serialize()（在 nameko.exceptions 模块中） serialize_event() （nameko.web.websocket.WebSocketServer 方法） serialize_for_ws() （nameko.web.websocket.WebSocketServer 方法） SERIALIZER_CONFIG_KEY()（在 nameko.constants 模块中） SERIALIZERS_CONFIG_KEY()（在 nameko.constants 模块中） serializer（nameko.amqp.publish.Publisher 属性） serializer（nameko.messaging.Publisher 属性） serializer（nameko.rpc.MethodProxy 属性） serializer（nameko.rpc.Responder 属性） server（nameko.web.handlers.HttpRequestHandler 属性） server（nameko.web.server.WsgiApp 属性） server（nameko.web.websocket.WebSocketHubProvider 属性） server（nameko.web.websocket.WebSocketRpc 属性） service_cls（nameko.containers.ServiceContainer 属性） service_map（nameko.runners.ServiceRunner 属性） service_names（nameko.runners.ServiceRunner 属性） service_name（nameko.containers.ServiceContainer 属性） service_name（nameko.containers.WorkerContext 属性） service_name（nameko.rpc.MethodProxy 属性） service_name（nameko.rpc.ServiceProxy 属性） service_name（nameko.standalone.rpc.StandaloneProxyBase.ServiceContainer 属性） SERVICE_POOL()（在 nameko.events 模块中） ServiceContainer（nameko.containers 中的类） ServiceProxy（nameko.rpc 中的类） ServiceRpcProxy（nameko.standalone.rpc 中的类） ServiceRunner（nameko.runners 中的类） service（nameko.containers.WorkerContext 属性） set_vhost_permissions() （nameko.testing.rabbit.Client 方法） setup() （nameko.events.EventDispatcher 方法） setup() （nameko.events.EventHandler 方法） setup() （nameko.extensions.Extension 方法） setup() （nameko.messaging.Consumer 方法） setup() （nameko.messaging.Publisher 方法） setup() （nameko.rpc.ReplyListener 方法） setup() （nameko.rpc.Rpc 方法） setup() （nameko.rpc.RpcConsumer 方法） setup() （nameko.web.handlers.HttpRequestHandler 方法） setup() （nameko.web.websocket.WebSocketHubProvider 方法） setup() （nameko.web.websocket.WebSocketRpc 方法） setup() （nameko.web.websocket.WebSocketServer 方法） setup()（在 nameko.serialization 模块中） setup_backdoor()（在 nameko.cli.run 模块中） setup_parser()（在 nameko.cli.main 模块中） setup_yaml_parser()（在 nameko.cli.main 模块中） shared_extensions（nameko.containers.ServiceContainer 属性） shared_extensions（nameko.standalone.rpc.StandaloneProxyBase.ServiceContainer 属性）

SharedExtension（nameko.extensions 中的类） sharing_key（nameko.extensions.SharedExtension 属性） ShellRunner（nameko.cli.shell 中的类） SHELLS（nameko.cli.commands.Shell 属性） Shell（nameko.cli.commands 中的类） should_stop（nameko.timer.Timer 属性） ShowConfig（nameko.cli.commands 中的类） SingleThreadedReplyListener（nameko.standalone.rpc 中的类） SINGLETON()（在 nameko.events 模块中） size（nameko.testing.utils.ResourcePipeline 属性） socket_id（nameko.web.websocket.Connection 属性） SocketInfo()（在 nameko.web.websocket 模块中） sockets（nameko.web.websocket.WebSocketServer 属性） source_service（nameko.events.EventHandler 属性） spawn_managed_thread() （nameko.containers.ServiceContainer 方法） spawn_worker() （nameko.containers.ServiceContainer 方法） SpawningProxy（nameko.utils.concurrency 中的类） SpawningSet（nameko.utils.concurrency 中的类） ssl（nameko.amqp.publish.Publisher 属性） ssl（nameko.rpc.MethodProxy 属性） ssl（nameko.rpc.Responder 属性） StandaloneProxyBase.Dummy（nameko.standalone.rpc 中的类） StandaloneProxyBase.ServiceContainer（nameko.standalone.rpc 中的类） StandaloneProxyBase（nameko.standalone.rpc 中的类） start() （nameko.containers.ServiceContainer 方法） start() （nameko.extensions.Extension 方法） start() （nameko.messaging.QueueConsumer 方法） start() （nameko.runners.ServiceRunner 方法） start() （nameko.standalone.rpc.StandaloneProxyBase 方法） start() （nameko.testing.services.Once 方法） start() （nameko.timer.Timer 方法） start() （nameko.web.server.WebServer 方法） start_shell() （nameko.cli.shell.ShellRunner 方法） started（nameko.containers.ServiceContainer 属性） STATE_IDLE()（在 nameko.web.server 模块中） stop() （nameko.containers.ServiceContainer 方法） stop() （nameko.extensions.Extension 方法） stop() （nameko.extensions.ProviderCollector 方法） stop() （nameko.messaging.Consumer 方法） stop() （nameko.messaging.QueueConsumer 方法） stop() （nameko.rpc.ReplyListener 方法） stop() （nameko.rpc.Rpc 方法） stop() （nameko.rpc.RpcConsumer 方法） stop() （nameko.runners.ServiceRunner 方法） stop() （nameko.standalone.rpc.StandaloneProxyBase 方法） stop() （nameko.timer.Timer 方法） stop() （nameko.web.handlers.HttpRequestHandler 方法） stop() （nameko.web.server.WebServer 方法） stop() （nameko.web.websocket.WebSocketHubProvider 方法） stop() （nameko.web.websocket.WebSocketRpc 方法） stop() （nameko.web.websocket.WebSocketServer 方法） stopped（nameko.standalone.rpc.PollingQueueConsumer 属性） STOP（nameko.testing.utils.ResourcePipeline 属性） strings（nameko.cli.actions.FlagAction 属性） subextensions（nameko.containers.ServiceContainer 属性） subscribe() （nameko.web.websocket.WebSocketHub 方法） subscriptions（nameko.web.websocket.Connection 属性） subscriptions（nameko.web.websocket.WebSocketHub 属性）

T

target_service（nameko.rpc.RpcProxy 属性） Test（nameko.cli.commands 中的类） timeout（nameko.standalone.rpc.PollingQueueConsumer 属性） timer()（在 nameko.timer 模块中）

Timer（nameko.timer 中的类） TRANSPORT_OPTIONS_CONFIG_KEY()（在 nameko.constants 模块中） transport_options（nameko.amqp.publish.Publisher 属性） trash（nameko.testing.utils.ResourcePipeline 属性）

U

UndeliverableMessage, [1] unicast() （nameko.web.websocket.WebSocketHub 方法） UnknownService unpack_message_headers() （nameko.messaging.HeaderDecoder 方法） unpack_mock_call()（在 nameko.testing.utils 模块中） unregister_provider() （nameko.extensions.ProviderCollector 方法） unregister_provider() （nameko.messaging.QueueConsumer 方法） unregister_provider() （nameko.rpc.RpcConsumer 方法） unregister_provider() （nameko.standalone.rpc.PollingQueueConsumer 方法）

UnserializableValueError unsubscribe() （nameko.web.websocket.WebSocketHub 方法） uri（nameko.testing.rabbit.Client 属性） url_map（nameko.web.server.WsgiApp 属性） url（nameko.web.handlers.HttpRequestHandler 属性） use_confirms（nameko.amqp.publish.Publisher 属性） USER_AGENT_CONTEXT_KEY()（在 nameko.constants 模块中） USER_ID_CONTEXT_KEY()（在 nameko.constants 模块中） UserAgent（nameko.contextdata 中的类） UserId（nameko.contextdata 中的类）

V

value（nameko.exceptions.RemoteError 属性）

vhost_pipeline()（在 nameko.testing.pytest 模块中）

W

wait() （nameko.containers.ServiceContainer 方法） wait() （nameko.runners.ServiceRunner 方法） wait() （nameko.standalone.rpc.ConsumeEvent 方法） wait_for_call()（在 nameko.testing.utils 模块中） wait_for_call()（在 nameko.testing.waiting 模块中） wait_for_providers() （nameko.extensions.ProviderCollector 方法） wait_for_worker_idle()（在 nameko.testing.utils 模块中） WaitResult.NotReady WaitResult（nameko.testing.waiting 中的类） web_config()（在 nameko.testing.pytest 模块中） web_config_port()（在 nameko.testing.pytest 模块中） WEB_SERVER_CONFIG_KEY()（在 nameko.constants 模块中） web_session()（在 nameko.testing.pytest 模块中） WebServer（nameko.web.server 中的类） websocket()（在 nameko.testing.pytest 模块中）

websocket_mainloop() （nameko.web.websocket.WebSocketServer 方法） WebSocketHubProvider（nameko.web.websocket 中的类） WebSocketHub（nameko.web.websocket 中的类） WebSocketRpc（nameko.web.websocket 中的类） WebSocketServer（nameko.web.websocket 中的类） worker_complete（nameko.timer.Timer 属性） worker_ctx（nameko.rpc.MethodProxy 属性） worker_ctx（nameko.rpc.ServiceProxy 属性） worker_factory()（在 nameko.testing.services 模块中） worker_result() （nameko.extensions.DependencyProvider 方法） worker_setup() （nameko.extensions.DependencyProvider 方法） worker_teardown() （nameko.extensions.DependencyProvider 方法） WorkerContext（nameko.containers 中的类） wsgi_server（nameko.web.websocket.WebSocketServer 属性） WsgiApp（nameko.web.server 中的类）

调

调用ID（nameko.containers.WorkerContext 属性）