nsqwatch

Documentation

Index

• func WatchAndPause(interval int64, consumers []*nsqpb.ProtoConsume, rc cred.CVRemoteConfig, ...)
• type NsqWatch
  • func (nq *NsqWatch) MaintainHealths()

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