taskconsumerinterface

Documentation

Index

• Variables
• type Consumer

Variables

var RateLimiterError = errors.New("task consuming failed due to error occurred while limiting rate")

Types

type Consumer

type Consumer interface {
	Consume(ctx context.Context, urlsCh <-chan *url.URL)
}