limitparallelrequests

package

v3.1.0 Latest Latest Go to latest Published: Jan 25, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

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

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

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

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

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