scheduler

Documentation

Index

• type RouteBroadcastScheduler
  • func NewRouteBroadcastScheduler(clock clock.Clock, natsClient diegonats.NATSClient, logger lager.Logger, ...) *RouteBroadcastScheduler
  • func (s *RouteBroadcastScheduler) EmitCh() chan struct{}
  • func (s *RouteBroadcastScheduler) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Types

type RouteBroadcastScheduler

type RouteBroadcastScheduler struct {
	MaxGreetAttempts int
	// contains filtered or unexported fields
}

func NewRouteBroadcastScheduler

func NewRouteBroadcastScheduler(
	clock clock.Clock,
	natsClient diegonats.NATSClient,
	logger lager.Logger,
	externalServiceName string,
	cfg *config.RouteEmitterConfig,
	emitCh chan struct{},
) *RouteBroadcastScheduler

func (*RouteBroadcastScheduler) EmitCh

func (s *RouteBroadcastScheduler) EmitCh() chan struct{}

func (*RouteBroadcastScheduler) Run

func (s *RouteBroadcastScheduler) Run(signals <-chan os.Signal, ready chan<- struct{}) error