Functions — github.com/alitto/pond

CodeHub MCPcopy Index your code

hub / github.com/alitto/pond / functions

Functions262 in github.com/alitto/pond

⨍ Functions 262◇ Types & classes 30

↓ 438 callersFunctionEqual

** * Asserts that the expected and actual values are equal. */

internal/assert/assert.go:8

↓ 117 callersMethodWait

Wait waits for the task to complete and returns any error that occurred.

↓ 79 callersMethodSubmit

Submits a task to the pool and returns a future that can be used to wait for the task to complete. The pool will not accept new tasks after it has bee

↓ 47 callersFunctionNewPool

NewPool creates a new pool with the given maximum concurrency and options. The new maximum concurrency must be greater than or equal to 0 (0 means no

↓ 39 callersMethodStopAndWait

Stops the pool and waits for all tasks to complete.

↓ 36 callersFunctionTrue

** * Asserts that the actual value is true. */

internal/assert/assert.go:18

↓ 34 callersMethodRunningWorkers

Returns the number of worker goroutines that are currently active (executing a task) in the pool.

↓ 30 callersMethodDone

Done returns a channel that is closed when the task is complete or has failed.

↓ 28 callersMethodCompletedTasks

Returns the total number of tasks that have completed (either successfully or with an error). Tasks accepted by the pool but canceled before execution

↓ 27 callersMethodSubmitErr

Submits a task to the pool and returns a future that can be used to wait for the task to complete. The task function must return an error. The pool wi

↓ 26 callersMethodSubmittedTasks

Returns the total number of tasks submitted to the pool since its creation.

↓ 21 callersMethodFailedTasks

Returns the number of tasks that have completed with an error.

↓ 21 callersMethodNewSubpool

Creates a new subpool with the specified maximum concurrency and options.

↓ 21 callersMethodSuccessfulTasks

Returns the number of tasks that have completed successfully.

↓ 19 callersMethodWaitingTasks

Returns the number of tasks that are currently waiting in the pool's queue.

↓ 15 callersMethodDroppedTasks

Returns the number of tasks that have been dropped because the queue was full.

↓ 15 callersMethodMaxConcurrency

Returns the maximum concurrency of the pool.

↓ 15 callersMethodNewGroup

Creates a new task group.

↓ 15 callersMethodStop

Stops the pool and returns a future that can be used to wait for all tasks pending to complete. The pool will not accept new tasks after it has been s

↓ 15 callersMethodWrite

Write writes a value to the buffer. If the buffer is full, it returns an EOF error.

internal/linkedbuffer/buffer.go:38

↓ 14 callersMethodRead

Read reads a value from the buffer. If the buffer is empty, it returns an EOF error. If the buffer has been read completely, it returns an EOF error.

internal/linkedbuffer/buffer.go:52

↓ 13 callersMethodError

internal/future/future.go:53

↓ 12 callersFunctionWithQueueSize

WithQueueSize sets the max number of elements that can be queued in the pool.

pooloptions.go:17

↓ 11 callersMethodLen

Len returns the number of elements in the buffer.

internal/linkedbuffer/buffer.go:32

↓ 10 callersMethodErr

internal/future/future.go:20

↓ 8 callersFunctionWithContext

WithContext sets the context for the pool.

pooloptions.go:10

↓ 7 callersMethodCanceledTasks

Returns the number of tasks accepted by the pool that were canceled before executing user code due to pool context cancellation.

↓ 7 callersFunctionPanicsWithError

** * Asserts that the function panics with the expected error. */

internal/assert/assert.go:42

↓ 6 callersMethodNewGroupContext

Creates a new task group with the specified context.

↓ 6 callersMethodReadCount

ReadCount returns the number of elements read from the buffer since it was created

internal/linkedbuffer/linkedbuffer.go:98

↓ 6 callersMethodResize

Resizes the pool by changing the maximum concurrency (number of workers) of the pool. The new max concurrency must be greater than 0. If the new max c

↓ 6 callersMethodTrySubmit

Attempts to submit a task to the pool and returns a future that can be used to wait for the task to complete and a boolean indicating whether the task

↓ 5 callersMethodContext

Returns the context associated with this pool.

↓ 5 callersMethodGo

Submits a task to the pool without waiting for it to complete. The pool will not accept new tasks after it has been stopped. If the pool has been stop

↓ 5 callersFunctionNewFuture

(ctx context.Context)

internal/future/future.go:37

↓ 5 callersMethodStopped

Returns true if the pool has been stopped or its context has been cancelled.

↓ 5 callersMethodTrySubmitErr

Attempts to submit a task to the pool and returns a future that can be used to wait for the task to complete and a boolean indicating whether the task

↓ 5 callersFunctionnewPool

(maxConcurrency int, parent *pool, options ...Option)

↓ 5 callersMethodupdateMetrics

↓ 4 callersMethodCap

Cap returns the capacity of the buffer.

internal/linkedbuffer/buffer.go:27

↓ 4 callersMethodTrySubmit

Attempts to submit a task to the pool and returns a future that can be used to wait for the task to complete and a boolean indicating whether the task

↓ 4 callersMethodTrySubmitErr

Attempts to submit a task to the pool and returns a future that can be used to wait for the task to complete and a boolean indicating whether the task

↓ 4 callersMethodWait

Waits for all tasks in the group to complete. If any of the tasks return an error, the group will return the first error encountered. If the context i

↓ 4 callersMethodnotifySubmitWaiter

↓ 4 callersMethodreadTask

↓ 4 callersMethodsubmit

(task any, nonBlocking bool)

↓ 4 callersMethodsubmit

(task any, nonBlocking bool)

↓ 4 callersMethodwrapAndSubmit

(task any, nonBlocking bool)

↓ 3 callersMethodDone

Returns a channel that is closed when all tasks in the group have completed, a task returns an error, or the group is stopped.

↓ 3 callersMethodQueueSize

Returns the size of the task queue.

↓ 3 callersFunctionSubmit

Submit submits a task to the default pool and returns a future that can be used to wait for the task to complete.

↓ 3 callersMethodSubmit

Submits a task to the pool and returns a future that can be used to wait for the task to complete and get the result. The pool will not accept new tas

↓ 3 callersMethodWait

Wait waits for the future to complete and returns any error that occurred.

internal/future/future.go:33

↓ 3 callersMethodWriteCount

WriteCount returns the number of elements written to the buffer since it was created

internal/linkedbuffer/linkedbuffer.go:93

↓ 3 callersMethodlaunchWorker

↓ 2 callersMethodCancel

internal/future/composite.go:77

↓ 2 callersMethodContext

Returns the context associated with this group. This context will be cancelled when either the parent context is cancelled or any task in the group re

↓ 2 callersMethodNonBlocking

Returns true if the pool is non-blocking, meaning that it will not block when the task queue is full. In a non-blocking pool, tasks that cannot be sub

↓ 2 callersMethodResult

internal/future/value.go:21

↓ 2 callersMethodStopped

↓ 2 callersMethodSubmit

Submits a task to the group.

↓ 2 callersMethodSubmitErr

Submits a task to the group that can return an error.

↓ 2 callersFunctionWithNonBlocking

WithNonBlocking sets the pool to be non-blocking when the queue is full. This option is only effective when the queue size is set.

pooloptions.go:25

↓ 2 callersMethodgetResult

internal/future/composite.go:143

↓ 2 callersFunctioninvokeTask

(task any, panicRecovery bool)

↓ 2 callersFunctionnewTaskGroup

(pool *pool, ctx context.Context)

↓ 2 callersMethodnotifyListeners

internal/future/composite.go:174

↓ 2 callersMethodsubmit

↓ 2 callersMethodtrySubmit

↓ 2 callersFunctionwrapTask

(task any, callback C, ctx context.Context, panicRecovery bool)

↓ 1 callersMethodContext

↓ 1 callersMethodDone

internal/future/future.go:16

↓ 1 callersFunctionNewGroup

NewGroup creates a new task group with the default pool.

↓ 1 callersFunctionNewSubpool

NewSubpool creates a new subpool with the default pool.

↓ 1 callersFunctionPanicsWith

** * Asserts that the function panics with the expected object. */

internal/assert/assert.go:28

↓ 1 callersMethodStop

↓ 1 callersFunctionSubmitErr

SubmitErr submits a task to the default pool and returns a future that can be used to wait for the task to complete.

↓ 1 callersFunctionWithoutPanicRecovery

WithoutPanicRecovery disables panic interception inside worker goroutines. When this option is enabled, panics inside tasks will propagate just like r

pooloptions.go:33

↓ 1 callersMethodblockingTrySubmit

↓ 1 callersFunctionfetchURL

(ctx context.Context, url string)

examples/task_group/main.go:12

↓ 1 callersFunctiongenerateTasks

(count int, duration time.Duration)

examples/task_group_context/main.go:36

↓ 1 callersFunctionsubmitTasks

(pool pond.Pool)

examples/prometheus/main.go:82

↓ 1 callersMethodsubpoolWorker

↓ 1 callersMethodworker

↓ 1 callersMethodwrapTask

MethodCanceledTasks

MethodCompletedTasks

internal/future/composite.go:73

Returns a channel that is closed when all tasks in the group have completed, a task returns an error, or the group is stopped.

Done returns a channel that is closed when the task is complete or has failed.

Done returns a channel that is closed when the task is complete or has failed.

internal/future/value.go:17

internal/future/composite.go:50

MethodDroppedTasks

internal/future/value.go:57

internal/future/composite.go:21

MethodFailedTasks

next →1–100 of 262, ranked by callers