Views

Views of the dasf-broker-django app to be imported via the url config (see dasf_broker.urls).

Classes:

BrokerTopicPingView(**kwargs)	View to ping a broker topic.
BrokerTopicStatusView(**kwargs)	Get a hint on the status of a broker topic.
HttpResponseServiceUnavailable([content])

class dasf_broker.views.BrokerTopicPingView(**kwargs)

Bases: PermissionRequiredMixin, SingleObjectMixin, View

View to ping a broker topic.

Attributes:

accept_global_perms
permission_required

Methods:

check_permissions(request)	Check if the user has the required permissions.
get(request, *args, **kwargs)
post(request, *args, **kwargs)

Models:

model

alias of BrokerTopic

accept_global_perms: bool = True

check_permissions(request)

Check if the user has the required permissions.

Checks if request.user has all permissions returned by the get_required_permissions() method.

Parameters:

request (HttpRequest) – The original request.

get(request, *args, **kwargs)

model

alias of BrokerTopic

permission_required: str | list[str] | None = 'dasf_broker.can_produce'

post(request, *args, **kwargs)

class dasf_broker.views.BrokerTopicStatusView(**kwargs)

Bases: PermissionRequiredMixin, BaseDetailView

Get a hint on the status of a broker topic.

Attributes:

accept_global_perms
any_perm
permission_required

Methods:

check_permissions(request)	Check if the user has the required permissions.
render_to_response(context)

Models:

model

alias of BrokerTopic

accept_global_perms: bool = True

any_perm: bool = True

check_permissions(request)

Check if the user has the required permissions.

Checks if request.user has all permissions returned by the get_required_permissions() method.

Parameters:

request (HttpRequest) – The original request.

model

alias of BrokerTopic

permission_required: str | list[str] | None = ['dasf_broker.can_view_status', 'dasf_broker.can_produce', 'dasf_broker.can_consume']

render_to_response(context)

class dasf_broker.views.HttpResponseServiceUnavailable(content=b'', *args, **kwargs)

Bases: HttpResponse

Attributes:

status_code

status_code = 503