dispatcher

package

v0.9.5 Latest Latest Go to latest Published: Nov 24, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

Index ¶

func Handle(ctx context.Context, wq workqueue.Interface, concurrency, batchSize int, ...) error
func Handler(wq workqueue.Interface, concurrency, batchSize int, f Callback, maxRetry int) http.Handler
type Callback
- func ServiceCallback(client workqueue.WorkqueueServiceClient) Callback
type Future
- func HandleAsync(ctx context.Context, wq workqueue.Interface, concurrency, batchSize int, ...) Future

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Handle ¶

func Handle(ctx context.Context, wq workqueue.Interface, concurrency, batchSize int, f Callback) error

Handle is a synchronous form of HandleAsync.

func Handler ¶

func Handler(wq workqueue.Interface, concurrency, batchSize int, f Callback, maxRetry int) http.Handler

Types ¶

type Callback ¶

type Callback func(ctx context.Context, key string, opts workqueue.Options) error

Callback is the function that Handle calls to process a particular key.

func ServiceCallback ¶

func ServiceCallback(client workqueue.WorkqueueServiceClient) Callback

ServiceCallback returns a Callback that invokes the given service.

type Future ¶

type Future func() error

Future is a function that can be used to block on the result of a round of dispatching work.

func HandleAsync ¶

func HandleAsync(ctx context.Context, wq workqueue.Interface, concurrency, batchSize int, f Callback, maxRetry int) Future

HandleAsync initiates a single iteration of the dispatcher, possibly invoking the callback for several different keys. It returns a future that can be used to block on the result.

Source Files ¶

View all Source files

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