Versions in this module Expand all Collapse all v0 v0.0.1 Feb 22, 2017 Changes in this version + const REGIntrannetIP + var ErrEmptyCircle = errors.New("empty circle") + func IntranetIP(ipStr string) string + func Start() + type Consistent struct + NumberOfReplicas int + func NewConsistent() *Consistent + func (c *Consistent) Add(elt string) + func (c *Consistent) Get(name string) (string, error) + func (c *Consistent) GetN(name string, n int) ([]string, error) + func (c *Consistent) GetTwo(name string) (string, string, error) + func (c *Consistent) Members() []string + func (c *Consistent) Remove(elt string) + func (c *Consistent) Set(elts []string) + type Kapacitor struct + Addrs []string + AlarmAddr string + Clients map[string]*client.Client + Hash *Consistent + func NewKapacitor(addrs []string, alarmAddr string) *Kapacitor + func (k *Kapacitor) CreateTask(alarm models.Alarm) error + func (k *Kapacitor) RemoveTask(task client.Task) error + func (k *Kapacitor) SetAddr(addrs []string) + func (k *Kapacitor) Tasks() map[string]client.Task + func (k *Kapacitor) Work(tasks map[string]client.Task, alarms map[string]models.Alarm) + type Machine struct + IP string + type Registry struct + Addr string + AlarmNS string + Interval int + func NewRegistry(addr string, alarmNS string) *Registry + func (r *Registry) AlarmServers() ([]string, error) + func (r *Registry) Alarms() (map[string]models.Alarm, error) + type RespAlarm struct + Data []models.Alarm + Status int + type RespMachine struct + Data []Machine + Status int
Go to main page