actualstatelisteners

Documentation

Index

• Constants
• func NewHeartbeatListener(logger lager.Logger, config *config.Config, syncer Syncer) *heartbeatListener
• func NewHttpListener(logger lager.Logger, config *config.Config, syncer Syncer) (http.Handler, error)
• type NatsListener
  • func NewNatsListener(logger lager.Logger, config *config.Config, messageBus yagnats.NATSConn, ...) *NatsListener
  • func (listener *NatsListener) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type Syncer
  • func NewSyncer(logger lager.Logger, config *config.Config, store store.Store, ...) Syncer

Constants

const HeartbeatSyncTimer = "HeartbeatSyncTimer"

Functions

func NewHeartbeatListener

func NewHeartbeatListener(logger lager.Logger,
	config *config.Config,
	syncer Syncer) *heartbeatListener

func NewHttpListener

func NewHttpListener(logger lager.Logger, config *config.Config, syncer Syncer) (http.Handler, error)

Types

type NatsListener

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

func NewNatsListener

func NewNatsListener(logger lager.Logger,
	config *config.Config,
	messageBus yagnats.NATSConn,
	syncer Syncer) *NatsListener

func (*NatsListener) Run

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

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