concurrency

package

v0.1.3 Latest Latest Go to latest Published: Aug 2, 2026 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func Pipe(ctx context.Context, in <-chan Chunk, out chan<- Chunk)

func RunGroup(ctx context.Context, timeout time.Duration, fns ...func(ctx context.Context) error) error

type Chunk struct {
	Data string
	Err  error
	Done bool
}

type Pool struct {
	// contains filtered or unexported fields
}

func NewPool(ctx context.Context, maxConcurrent int) *Pool

func (p *Pool) Stop()

func (p *Pool) Submit(fn func(ctx context.Context) error) error

func (p *Pool) Wait()

type Supervisor struct {
	// contains filtered or unexported fields
}

func NewSupervisor() *Supervisor

func (s *Supervisor) ActiveCount() map[string]int

func (s *Supervisor) Go(ctx context.Context, name string, fn func())