crossbar.worker.transport¶

Classes¶

`RouterTransport`	A (listening) transport running on a router worker.
`RouterWebTransport`	Web transport or Universal transport with Web sub-service.
`TransportController`	Services shared between RouterController and ProxyController

Functions¶

create_router_transport(worker, transport_id, config)

Factory for creating router (listening) transports.

Module Contents¶

class RouterTransport(worker, transport_id, config)[source]¶

Bases: object

A (listening) transport running on a router worker.

STATES[source]¶

STATE_CREATED = 1[source]¶

STATE_FAILED = 4[source]¶

STATE_STARTED = 3[source]¶

STATE_STARTING = 2[source]¶

STATE_STOPPED = 6[source]¶

STATE_STOPPING = 5[source]¶

_cbdir[source]¶

_config[source]¶

_create_factory(create_paths=False, ignore=[])[source]¶

abstractmethod _create_web_factory(create_paths=False, ignore=[])[source]¶

_created_at[source]¶

_listening_since = None[source]¶

_port = None[source]¶

_root_webservice = None[source]¶

_state = 1[source]¶

_templates[source]¶

_transport_factory = None[source]¶

_transport_id[source]¶

_type[source]¶

_worker[source]¶

property cbdir[source]¶

Node directory.

Type:: return

property config[source]¶

The original configuration as supplied to this router transport.

Type:: return

property created[source]¶

When this transport was created (the run-time, in-memory object instantiated).

Type:: return

property id[source]¶

The transport ID.

Type:: return

log[source]¶

marshal()[source]¶

property port[source]¶

The network listening transport of this router transport.

Type:: return

property root[source]¶

The root (on path “/”) Web service.

Type:: return

start(start_children=False, ignore=[])[source]¶

Start this transport (starts listening on the respective network listening port).

Parameters:: start_children
Returns:

property state[source]¶

The state of this transport.

Type:: return

stop()[source]¶

Stops this transport (stops listening on the respective network port or interface).

Returns:

property templates[source]¶

Templates directory.

Type:: return

property type[source]¶

The transport type.

Type:: return

property worker[source]¶

The worker (controller session) this transport was created from.

Type:: return

class RouterWebTransport(worker, transport_id, config)[source]¶

Bases: RouterTransport

Web transport or Universal transport with Web sub-service.

_create_web_factory(create_paths=False, ignore=[])[source]¶

log[source]¶

class TransportController(config=None, reactor=None, personality=None)[source]¶

Bases: crossbar.worker.controller.WorkerController

Services shared between RouterController and ProxyController

get_web_transport_service(transport_id, path, details=None)[source]¶

get_web_transport_services(transport_id, details=None)[source]¶

start_web_transport_service(transport_id, path, config, details=None)[source]¶

Start a service on a Web transport.

Parameters:

transport_id (str) – The ID of the transport to start the Web transport service on.
path (str) – The path (absolute URL, eg “/myservice1”) on which to start the service.
config (dict) – The Web service configuration.
details (autobahn.wamp.types.CallDetails) – Call details.

stop_web_transport_service(transport_id, path, details=None)[source]¶

Stop a service on a Web transport.

Parameters:

transport_id (str) – The ID of the transport to stop the Web transport service on.
path (str) – The path (absolute URL, eg “/myservice1”) of the service to stop.
details (autobahn.wamp.types.CallDetails) – Call details.

transports[source]¶

create_router_transport(worker, transport_id, config)[source]¶

Factory for creating router (listening) transports.

Parameters:

worker
transport_id
config

Returns: