pooling

Documentation

Overview

Package pooling implements the wayback workers pool.

Index

• Variables
• type Bucket
• type Pool
  • func New(ctx context.Context, capacity int) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) Put(b Bucket)
  • func (p *Pool) Roll()

Variables

var (
	ErrPoolNotExist = errors.New("pool not exist")  // ErrPoolNotExist pool not exist
	ErrTimeout      = errors.New("process timeout") // ErrTimeout process timeout

)

Types

type Bucket

type Bucket struct {
	// Request is the main func for handling wayback requests.
	Request func(context.Context) error

	// Fallback defines an optional func to return a failure response for the Request func.
	Fallback func(context.Context) error
	// contains filtered or unexported fields
}

A Bucket represents a wayback request is sent by a service.

type Pool

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

Pool represents a pool of services.

func New

func New(ctx context.Context, capacity int) *Pool

New a resource pool of the specified capacity Resources are created concurrently to save resource initialization time

func (*Pool) Close

func (p *Pool) Close()

Close closes the worker pool, and it is blocked until all workers are idle.

func (*Pool) Put

func (p *Pool) Put(b Bucket)

Pub puts wayback requests to the resource pool

func (*Pool) Roll

func (p *Pool) Roll()

Roll process wayback requests from the resource pool for execution.

// Stream generates values with DoSomething and sends them to out
// until DoSomething returns an error or ctx.Done is closed.
func Stream(ctx context.Context, out chan<- Value) error {
	for {
		v, err := DoSomething(ctx)
		if err != nil {
			return err
		}
		select {
		case <-ctx.Done():
			return ctx.Err()
		case out <- v:
		}
	}
}