looper

type Func func(IMetrics)

type ILooper interface {
	// Start starts the loop.
	Start()

	// StartAsync starts the loop asynchronously.
	StartAsync()

	// Stop stops the loop.
	Stop()
}

type IMetrics interface {
	// GetLogger returns the logger of the looper.
	GetLogger() sypl.ISypl

	// IncrementFailedCounter increments the failed counter.
	IncrementFailedCounter()

	// IncrementSuccessCounter increments the success counter.
	IncrementSuccessCounter()

	// IncrementTotalCounter increments the total counter.
	IncrementTotalCounter()
}

type Looper struct {
	// Func is the function to be executed.
	Func Func `json:"-" validate:"required"`

	// Interval is the time between each loop.
	Interval time.Duration `json:"interval"`

	// Logger is the logger.
	Logger sypl.ISypl `json:"-" validate:"required"`

	// Name of the looper.
	Name string `json:"name" validate:"required,lowercase,gte=1"`

	*Metrics
	// contains filtered or unexported fields
}

type Metrics struct {
	// Failed will be incremented every time a it fails execution.
	FailedCounter *expvar.Int `json:"-" validate:"omitempty,gte=0"`

	// Succeeded will be incremented every time a it succeeds execution.
	SuccessCounter *expvar.Int `json:"-" validate:"omitempty,gte=0"`

	// Total will be incremented every time a it is executed.
	TotalCounter *expvar.Int `json:"-" validate:"omitempty,gte=0"`
}

type Requester struct {
	ILooper
}