channels

Documentation

Index

• Variables
• func InitUrlExecutorThreadPool(threadCount int)
• type ExecFunc
• type UrlExecutor
  • func NewTestUrlExecutor() UrlExecutor
  • func NewUrlExecutor() UrlExecutor
• type UrlExecutorProvider
  • func NewUrlExecutorProvider(e UrlExecutor) UrlExecutorProvider

Variables

var ChanSvrStart = make(chan bool, 1)

Functions

func InitUrlExecutorThreadPool

func InitUrlExecutorThreadPool(threadCount int)

InitUrlExecutorThreadPool function is responsible to create goroutines for the provided thread count.

Types

type ExecFunc

type ExecFunc func(string, int, int64)

type UrlExecutor

type UrlExecutor interface {

	// Create function is responsible to create an object
	// of UrlExecutor
	Create() UrlExecutor

	// Build function is responsible to build an already
	// initialized UrlExecutor object.
	Build(url string, wg *sync.WaitGroup, fn ExecFunc) UrlExecutor

	// PushChannel function is responsible to push the built
	// UrlExecutor object to the channel.
	PushChannel()
}

UrlExecutor interface contains the functions to be implemented to execute a URL in a multi-threaded approach.

func NewTestUrlExecutor

func NewTestUrlExecutor() UrlExecutor

func NewUrlExecutor

func NewUrlExecutor() UrlExecutor

type UrlExecutorProvider

type UrlExecutorProvider interface {

	// Provide function is responsible to provide
	// UrlExecutor objects
	Provide() UrlExecutor
}

UrlExecutorProvider interface contains the functions to be implemented to create the provider the builds UrlExecutor objects

func NewUrlExecutorProvider

func NewUrlExecutorProvider(e UrlExecutor) UrlExecutorProvider

NewUrlExecutorProvider function is responsible to create urlExecutorProvider objects