limitparallelrequests

package
v3.3.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL