limitparallelrequests

Documentation

Index

• type DoFunc
• type DoObserveFunc
• type LimitParallelRequests
  • func New(limit, endpointLimit int64, do DoFunc, doObserve DoObserveFunc) *LimitParallelRequests
  • func (c *LimitParallelRequests) Do(req *pool.Message) (*pool.Message, error)
  • func (c *LimitParallelRequests) DoObserve(req *pool.Message, observeFunc func(req *pool.Message)) (Observation, error)
• type Observation

Types

type DoFunc

type DoFunc = func(req *pool.Message) (*pool.Message, error)

type DoObserveFunc

type DoObserveFunc = func(req *pool.Message, observeFunc func(req *pool.Message)) (Observation, error)

type LimitParallelRequests

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

func New

func New(limit, endpointLimit int64, do DoFunc, doObserve DoObserveFunc) *LimitParallelRequests

New creates new LimitParallelRequests. When limit, endpointLimit == 0, then limit is not used.

func (*LimitParallelRequests) Do

func (c *LimitParallelRequests) Do(req *pool.Message) (*pool.Message, error)

func (*LimitParallelRequests) DoObserve

func (c *LimitParallelRequests) DoObserve(req *pool.Message, observeFunc func(req *pool.Message)) (Observation, error)

type Observation

type Observation = interface {
	Cancel(ctx context.Context, opts ...message.Option) error
	Canceled() bool
}