dispatcher

Documentation

Index

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

Functions

func Handle

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

Handle is a synchronous form of HandleAsync.

func Handler

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

Types

type Callback

type Callback func(ctx context.Context, key string) 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 int, f Callback) 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.