converger_process

Documentation

Index

• type ConvergerProcess
  • func New(bbsServiceClient bbs.ServiceClient, bbsClient bbs.InternalClient, ...) *ConvergerProcess
  • func (c *ConvergerProcess) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Types

type ConvergerProcess

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

func New

func New(
	bbsServiceClient bbs.ServiceClient,
	bbsClient bbs.InternalClient,
	logger lager.Logger,
	clock clock.Clock,
	convergeRepeatInterval,
	kickTaskDuration,
	expirePendingTaskDuration,
	expireCompletedTaskDuration time.Duration,
) *ConvergerProcess

func (*ConvergerProcess) Run

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