Consumer Module

Base Class

class arrowhead_client.consumer.BaseConsumer(keyfile, certfile, cafile)

Abstract base class for consumers.

Parameters

• keyfile – Certificate keyfile.

• certfile – Certificate certfile.

• cafile – Certificate authority file.

async connect(rule, **kwargs)

Connect to a service with a persistent connection, for example with WebSockets, according to the orchestration rule.

Parameters

rule (OrchestrationRule) – Orchestration rule.

Return type

ConnectionResponse

Returns

A connection object, currently implementation specific.

abstract consume_service(rule, data_model=None, **kwargs)

Consumes service according to the orchestrationrule.

Parameters

• rule (OrchestrationRule) – Orchestration rule.

• data_model (type[M] | None) –

Returns

A Response object.

Return type

Response[M] | Coroutine[Any, Any, Response[M]]

Implementations

class arrowhead_client.consumer.RequestsConsumer(keyfile, certfile, cafile)

Consumer based on requests.

Parameters

• keyfile (str) –

• certfile (str) –

• cafile (str) –

class arrowhead_client.consumer.AiohttpConsumer(keyfile, certfile, cafile)

Asynchronous consumer based on AioHttp.

Parameters

• keyfile (str) –

• certfile (str) –

• cafile (str) –