MCPcopy Index your code

hub / github.com/alitto/pond / types & classes

Types & classes30 in github.com/alitto/pond

InterfaceBasePool
BasePool defines methods common to all pool types.
pool.go:38
StructCompositeFuture
internal/future/composite.go:30
FuncTypeCompositeFutureResolver
func(index int, value V, err error)
internal/future/composite.go:9
StructFuture
A Future represents a value that will be available in the Future. It is always associated with a context that can be used to wait for the value to be
internal/future/future.go:12
FuncTypeFutureResolver
func(err error)
internal/future/future.go:7
StructLinkedBuffer
LinkedBuffer implements an unbounded generic buffer that can be written to and read from concurrently. It is implemented using a linked list of buffer
internal/linkedbuffer/linkedbuffer.go:10
FuncTypeOption
func(*pool)
pooloptions.go:7
StructPayload
internal/linkedbuffer/buffer_test.go:47
InterfacePool
Represents a pool of goroutines that can execute tasks concurrently.
pool.go:96
InterfaceResult
Result is deprecated. Use ResultTask instead. This interface is maintained for backward compatibility. Deprecated: Use ResultTask instead.
future.go:27
InterfaceResultPool
ResultPool is a pool that can be used to submit tasks that return a result.
result.go:10
InterfaceResultTask
ResultTask represents a task that yields a result. If the task fails, the error can be retrieved.
future.go:14
InterfaceResultTaskGroup
ResultTaskGroup represents a group of tasks that can be executed concurrently. As opposed to TaskGroup, the tasks in a ResultTaskGroup yield a result.
group.go:48
InterfaceTask
Task represents a task that can be waited on. If the task fails, the error can be retrieved.
future.go:4
InterfaceTaskGroup
TaskGroup represents a group of tasks that can be executed concurrently. The group can be waited on to block until all tasks have completed. If any of
group.go:17
StructValueFuture
A Future represents a value that will be available in the Future. It is always associated with a context that can be used to wait for the value to be
internal/future/value.go:13
FuncTypeValueFutureResolver
func(value V, err error)
internal/future/value.go:8
StructabstractTaskGroup
group.go:75
Structbuffer
buffer implements a generic buffer that can store any type of data. It is not thread-safe and should be used with a mutex. It is used by LinkedBuffer
internal/linkedbuffer/buffer.go:12
StructcompositeErrorResolution
internal/future/composite.go:16
StructcompositeResolution
internal/future/composite.go:11
StructfutureResolution
internal/future/future.go:49
Structpool
pool.go:138
Structresult
group.go:70
StructresultPool
result.go:47
StructresultTaskGroup
group.go:173
StructtaskGroup
group.go:151
StructvalueFutureResolution
internal/future/value.go:52
StructwaitListener
internal/future/composite.go:25
StructwrappedTask
task.go:14