ExStorageServiceSdk.Transfer.Coordinator (ex_storage_service_sdk v0.7.1)

Copy Markdown View Source

Invocation-wide request-count and byte reservations with owned cancellation.

Summary

Functions

acquire(coordinator, bytes, opts \\ [])
cancel(coordinator, signal \\ :sigint)
check(coordinator)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

release(lease)
start_link(opts \\ [])
stats(coordinator)
stream(items, task_supervisor, function, opts \\ [])

Lazy, supervised object work; result queues remain bounded by active tasks.

track(lease, controller)

Functions

acquire(coordinator, bytes, opts \\ [])

cancel(coordinator, signal \\ :sigint)

check(coordinator)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

release(lease)

start_link(opts \\ [])

stats(coordinator)

stream(items, task_supervisor, function, opts \\ [])

Lazy, supervised object work; result queues remain bounded by active tasks.

track(lease, controller)