monitor

type Component ¶

type Component struct {
	State            *State
	HeartBeatChannel chan *heart.HeartBeat
	Name             string
}

Component is a basic statemachine Heartbeat timeout: OK(true)->OK(false) ; OK(false)->OK(false) Heartbeat received: OK(true)->OK(true) ; OK(false)->OK(true)

Once a HeartBeat is received, a component has HeartBeatWaitTimeout until the next heartbeat is received. When that heartbeat is received, it will be checked for recency. If it has not timed out (i.e. the HeartBeat is < 30 seconds old, its state will be the state of the component. If the HeartBeat is stale, it will be discarded and the component will be in a bad state.

func NewComponent(name string) *Component

func (c *Component) Send(hb *heart.HeartBeat)

type Monitor ¶

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

func NewMonitor(nsqdHost string) (*Monitor, error)

func (m *Monitor) SerializeState() ([]byte, error)

func (m *Monitor) Stop()

type State ¶

type State struct {
	OK        bool `json:"ok"`
	HeartBeat *heart.HeartBeat
}