syncer

Documentation

Index

• type NatsSyncer
  • func NewSyncer(clock clock.Clock, syncInterval time.Duration, logger lager.Logger) *NatsSyncer
  • func (s *NatsSyncer) Run(signals <-chan os.Signal, ready chan<- struct{}) error
  • func (s *NatsSyncer) SyncCh() chan struct{}

Types

type NatsSyncer

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

func NewSyncer

func NewSyncer(
	clock clock.Clock,
	syncInterval time.Duration,
	logger lager.Logger,
) *NatsSyncer

func (*NatsSyncer) Run

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

func (*NatsSyncer) SyncCh

func (s *NatsSyncer) SyncCh() chan struct{}