Documentation ¶
Index ¶
Constants ¶
View Source
const HeartbeatSyncTimer = "HeartbeatSyncTimer"
Variables ¶
This section is empty.
Functions ¶
func NewHeartbeatListener ¶
Types ¶
type NatsListener ¶
type NatsListener struct {
// contains filtered or unexported fields
}
func NewNatsListener ¶
type Syncer ¶
type Syncer interface { Run(signals <-chan os.Signal, ready chan<- struct{}) error Heartbeat(heartbeat *models.Heartbeat) }
func NewSyncer ¶
func NewSyncer(logger lager.Logger, config *config.Config, store store.Store, storeUsageTracker metricsaccountant.UsageTracker, metricsAccountant metricsaccountant.MetricsAccountant, clock clock.Clock, sender sender.Sender) Syncer
Click to show internal directories.
Click to hide internal directories.