workers

Documentation

Index

• Variables
• type Balancer
• type BalancerService
  • func NewBalancerService(ctx context.Context, cfg *config.Config, logger logservice.Logger, ...) *BalancerService
  • func (s *BalancerService) CurrentAction() (action enum.Action, sleep time.Duration)
• type Manager
• type ManagerService
  • func NewManagerService(ctx context.Context, sender *sender.Http, logger logservice.Logger, ...) *ManagerService
  • func (m *ManagerService) CloseAll(cancel context.CancelFunc, wg *sync.WaitGroup)
  • func (m *ManagerService) CloseOne()
  • func (m *ManagerService) SpawnOne(ctx context.Context, wg *sync.WaitGroup, sendTicker *time.Ticker)

Variables

var (
	UndefinedVoteStrategyWasGivenError = errors.New("undefined vote strategy was given, check your input")
	UndefinedSpawnVoterWasGivenError   = errors.New("undefined spawn voter was given, check your input")
	UndefinedCloseVoterWasGivenError   = errors.New("undefined close voter was given, check your input")
)

Types

type Balancer

type Balancer interface {
	CurrentAction() (action enum.Action, sleep time.Duration)
}

type BalancerService

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

func NewBalancerService

func NewBalancerService(
	ctx context.Context,
	cfg *config.Config,
	logger logservice.Logger,
	collector statservice.Collector,
) *BalancerService

func (*BalancerService) CurrentAction

func (s *BalancerService) CurrentAction() (action enum.Action, sleep time.Duration)

type Manager

type Manager interface {
	SpawnOne(ctx context.Context, wg *sync.WaitGroup, sendTicker *time.Ticker)
	CloseOne()
	CloseAll(cancel context.CancelFunc, wg *sync.WaitGroup)
}

type ManagerService

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

func NewManagerService

func NewManagerService(
	ctx context.Context,
	sender *sender.Http,
	logger logservice.Logger,
	collector statservice.Collector,
) *ManagerService

func (*ManagerService) CloseAll

func (m *ManagerService) CloseAll(cancel context.CancelFunc, wg *sync.WaitGroup)

func (*ManagerService) CloseOne

func (m *ManagerService) CloseOne()

func (*ManagerService) SpawnOne

func (m *ManagerService) SpawnOne(ctx context.Context, wg *sync.WaitGroup, sendTicker *time.Ticker)