handlers

type CheckedHandler ¶ added in v1.5.1

type CheckedHandler struct {
	LinkChecker models.LinkChecker
	LinkHandler models.LinkHandler
}

CheckedHandler ...

func (handler CheckedHandler) HandleLink(
	ctx context.Context,
	link models.SourcedLink,
)

type ConcurrentHandler ¶ added in v1.7.1

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

ConcurrentHandler ...

func NewConcurrentHandler(
	bufferSize int,
	linkHandler models.LinkHandler,
) ConcurrentHandler

func (handler ConcurrentHandler) HandleLink(
	ctx context.Context,
	link models.SourcedLink,
)

func (handler ConcurrentHandler) Start(ctx context.Context)

func (handler ConcurrentHandler) StartConcurrently(
	ctx context.Context,
	concurrencyFactor int,
)

func (handler ConcurrentHandler) Stop()

type HandlerGroup ¶ added in v1.10.1

type HandlerGroup []models.LinkHandler

HandlerGroup ...

func (handlers HandlerGroup) HandleLink(
	ctx context.Context,
	link models.SourcedLink,
)

type LinkChecker ¶ added in v1.5.1

type LinkChecker interface {
	models.LinkChecker
}

LinkChecker ...

It's used only for mock generating.

type LinkHandler ¶

type LinkHandler interface {
	models.LinkHandler
}

LinkHandler ...

It's used only for mock generating.