Loading...
Searching...
No Matches
constructors.h
1
5#pragma once
6
7#include <memory>
8
9#include <Python.h>
10
11#include <ucxx/buffer.h>
12
13namespace ucxx {
14
15class Context;
16class Future;
17class Notifier;
18class Worker;
19
20namespace python {
21
22[[nodiscard]] std::shared_ptr<::ucxx::Future> createFuture(
23 std::shared_ptr<::ucxx::Notifier> notifier);
24
25[[nodiscard]] std::shared_ptr<::ucxx::Future> createFutureWithEventLoop(
26 PyObject* asyncioEventLoop, std::shared_ptr<::ucxx::Notifier> notifier);
27
28[[nodiscard]] std::shared_ptr<::ucxx::Notifier> createNotifier();
29
30[[nodiscard]] std::shared_ptr<::ucxx::Worker> createWorker(std::shared_ptr<ucxx::Context> context,
31 const bool enableDelayedSubmission,
32 const bool enableFuture);
33
34} // namespace python
35
36} // namespace ucxx
Component encapsulating the UCP context.
Definition context.h:35
Represent a future that may be notified by a specialized notifier.
Definition future.h:21
Notifier for status of futures.
Definition notifier.h:38
Component encapsulating a UCP worker.
Definition worker.h:62
Definition address.h:16