nsqwatch

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 26, 2018 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WatchAndPause

func WatchAndPause(interval int64, consumers []*nsqpb.ProtoConsume, rc cred.CVRemoteConfig, store storage.OcelotStorage, duHealthChecker *du.HealthChecker)

Types

type NsqWatch

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

NsqWatch is for keeping an eye on Ocelot's dependencies and pausing the reception of messages

from NSQ if any other dependency goes down. the `paused` bool will be switched to true if the queue is shut down temporarily.

func (*NsqWatch) MaintainHealths

func (nq *NsqWatch) MaintainHealths()

MaintainHealths checks to make sure that disk, remoteConfig, and storage connections are all healthy. If they are not,

then nsq consumers will be paused, effectively blocking all builds. The consumers will be unpaused when all checks return
to healthy state

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL