runnerpooltest

Documentation

Overview

Package runnerpooltest provides an implementation of runnerpool.Pool to be used from tests of third party libraries where we just need to provide a dependency that will execute the code synchronously. For fine-grained control of the Pool, use the package runnerpoolmock

Index

• type SyncWorkersPool
  • func (s SyncWorkersPool) Stats() runnerpool.Stats
  • func (s SyncWorkersPool) Worker(ctx context.Context) (runnerpool.Worker, error)

Types

type SyncWorkersPool

type SyncWorkersPool struct{}

SyncWorkerPool provides workers that run the provided function synchronously. This is used to test third party libraries depending on runnerpool.Pool

func (SyncWorkersPool) Stats

func (s SyncWorkersPool) Stats() runnerpool.Stats

Stats does not provide correct stats for this test implementation

func (SyncWorkersPool) Worker

func (s SyncWorkersPool) Worker(ctx context.Context) (runnerpool.Worker, error)

Worker always provides a worker with no calls limit