wigo

Jun 28, 2020

Changes in this version

+ func NewConcurrentMapProbes() *concurrentMapProbes

+ func NewConcurrentMapWigos() *concurrentMapWigos

Jun 28, 2020

Changes in this version

type GeneralConfig

+ Trace bool

type UpdateRequest

+ WigoHostname string

+ WigoJson string

Feb 19, 2016

Changes in this version

+ const ADDDIRECTORY

+ const CRITICAL

+ const DEBUG

+ const DELETEPROBERESULT

+ const EMERGENCY

+ const ERROR

+ const INFO

+ const NEWCONNECTION

+ const NEWPROBERESULT

+ const NEWREMOTERESULT

+ const NOTICE

+ const REMOVEDIRECTORY

+ const SENDNOTIFICATION

+ const SENDRESULTS

+ const WARNING

+ var Version = "##VERSION##"

+ func CallbackHttp(json string) (e error)

+ func Dump(data interface{})

+ func HttpAuthorityAllowHandler(params martini.Params) (int, string)

+ func HttpAuthorityListHandler(params martini.Params) (int, string)

+ func HttpAuthorityRevokeHandler(params martini.Params) (int, string)

+ func HttpGroupsHandler(params martini.Params) (int, string)

+ func HttpLogsHandler(params martini.Params, r *http.Request) (int, string)

+ func HttpLogsIndexesHandler(params martini.Params) (int, string)

+ func HttpRemotesHandler(params martini.Params) (int, string)

+ func HttpRemotesProbesHandler(params martini.Params) (int, string)

+ func HttpRemotesProbesStatusHandler(params martini.Params) (int, string)

+ func HttpRemotesStatusHandler(params martini.Params) (int, string)

+ func InitChannels()

+ func InitWigo() (err error)

+ func IsStringInArray(str string, l []string) bool

+ func ListProbesDirectories() ([]string, error)

+ func ListProbesInDirectory(directory string) (probesList *list.List, error error)

+ func SendMail(summary string, message string)

+ func SendNotification(notification INotification)

+ func StatusToString(status int) string

+ func ToJson(data interface{}) string

+ type AdvancedRemoteWigoConfig struct

+ CheckInterval int

+ CheckRemotesDepth int

+ Hostname string

+ Login string

+ Password string

+ Port int

+ SslEnabled bool

+ type Authority struct

+ Allowed map[string]string

+ Tokens map[string]string

+ Waiting map[string]string

+ func NewAuthority(config *PushServerConfig) (this *Authority)

+ func (this *Authority) AddClientToWaitingList(uuid string, hostname string) (err error)

+ func (this *Authority) AllowClient(uuid string) (err error)

+ func (this *Authority) GetServerCertificate() []byte

+ func (this *Authority) GetToken(clientUuid string) (token string, err error)

+ func (this *Authority) GetUuidSignature(uuid string, hostname string) (uuidSignature []byte, err error)

+ func (this *Authority) IsAllowed(uuid string) bool

+ func (this *Authority) IsWaiting(uuid string) bool

+ func (this *Authority) LoadAllowedList() (err error)

+ func (this *Authority) RevokeClient(uuid string) (err error)

+ func (this *Authority) RevokeToken(uuid string, token string) (err error)

+ func (this *Authority) SaveAllowedList() (err error)

+ func (this *Authority) VerifyToken(uuid string, token string) (err error)

+ func (this *Authority) VerifyUuidSignature(uuid string, uuidSignature []byte) (err error)

+ type Chans struct

+ ChanCallbacks chan INotification

+ ChanChecks chan Event

+ ChanSignals chan os.Signal

+ ChanWatch chan Event

+ var Channels *Chans

+ type Config struct

+ AdvancedList []AdvancedRemoteWigoConfig

+ Global *GeneralConfig

+ Http *HttpConfig

+ Notifications *NotificationConfig

+ OpenTSDB *OpenTSDBConfig

+ PushClient *PushClientConfig

+ PushServer *PushServerConfig

+ RemoteWigos *RemoteWigoConfig

+ func NewConfig(configFile string) (this *Config)

+ type Event struct

+ Type int

+ Value interface{}

+ type GeneralConfig struct

+ AliveTimeout int

+ ConfigFile string

+ Database string

+ Debug bool

+ Group string

+ Hostname string

+ ListenAddress string

+ ListenPort int

+ LogFile string

+ ProbesConfigDirectory string

+ ProbesDirectory string

+ UuidFile string

+ type HelloRequest struct

+ Hostname string

+ Uuid string

+ UuidSignature []byte

+ func NewHelloRequest(uuidSignature []byte) (this *HelloRequest)

+ type Host struct

+ Group string

+ Name string

+ Probes map[string]*ProbeResult

+ Status int

+ func NewHost() (this *Host)

+ func (this *Host) AddOrUpdateProbe(probe *ProbeResult)

+ func (this *Host) DeleteProbeByName(probeName string)

+ func (this *Host) GetErrorsProbesList() (list []string)

+ func (this *Host) GetParentWigo() *Wigo

+ func (this *Host) GetSummary() (hs *HostSummary)

+ func (this *Host) RecomputeStatus()

+ func (this *Host) SetParentWigo(w *Wigo)

+ type HostSummary struct

+ IsAlive bool

+ Message string

+ Name string

+ Probes []map[string]interface{}

+ Status int

+ type HttpConfig struct

+ Address string

+ Enabled bool

+ Gzip bool

+ Login string

+ Password string

+ Port int

+ SslCert string

+ SslEnabled bool

+ SslKey string

+ type INotification interface

+ GetMessage func() string

+ GetSummary func() string

+ ToJson func() ([]byte, error)

+ type Log struct

+ Date string

+ Group string

+ Host string

+ Level uint8

+ Message string

+ Probe string

+ Timestamp int64

+ func NewLog(level uint8, message string) (this *Log)

+ func (this *Log) Persist()

+ func (this *Log) SetGroup(group string)

+ func (this *Log) SetHost(hostname string)

+ func (this *Log) SetProbe(probename string)

+ type Notification struct

+ Date string

+ Hostname string

+ Message string

+ Summary string

+ Type string

+ func NewNotification() (this *Notification)

+ func NewNotificationFromMessage(message string) (this *Notification)

+ func (this *Notification) GetMessage() string

+ func (this *Notification) GetSummary() (s string)

+ func (this *Notification) ToJson() (ba []byte, e error)

+ type NotificationConfig struct

+ EmailEnabled int

+ EmailFromAddress string

+ EmailFromName string

+ EmailRecipients []string

+ EmailSmtpServer string

+ HttpEnabled int

+ HttpUrl string

+ MinLevelToSend int

+ OnHostChange bool

+ OnProbeChange bool

+ type NotificationProbe struct

+ HostProbesInError []string

+ NewProbe *ProbeResult

+ OldProbe *ProbeResult

+ func NewNotificationProbe(oldProbe *ProbeResult, newProbe *ProbeResult) (this *NotificationProbe)

+ func (this *NotificationProbe) GetSummary() (s string)

+ func (this *NotificationProbe) ToJson() (ba []byte, e error)

+ type NotificationWigo struct

+ NewWigo *Wigo

+ OldWigo *Wigo

+ func (this *NotificationWigo) GetSummary() (s string)

+ func (this *NotificationWigo) ToJson() (ba []byte, e error)

+ type OpenTSDBConfig struct

+ Address []string

+ BufferSize int

+ Deduplication int

+ Enabled bool

+ MetricPrefix string

+ SslEnabled bool

+ Tags map[string]string

+ type ProbeResult struct

+ Detail interface{}

+ ExitCode int

+ Message string

+ Metrics interface{}

+ Name string

+ ProbeDate string

+ Status int

+ Timestamp int64

+ Value interface{}

+ Version string

+ func NewProbeResult(name string, status int, exitCode int, message string, detail string) (this *ProbeResult)

+ func NewProbeResultFromJson(name string, ba []byte) (this *ProbeResult)

+ func (this *ProbeResult) GetHost() *Host

+ func (this *ProbeResult) GraphMetrics()

+ func (this *ProbeResult) SetHost(h *Host)

+ func (this *ProbeResult) Summary() string

+ type PushClient struct

+ func NewPushClient(config *PushClientConfig) (this *PushClient, err error)

+ func (this *PushClient) CallWithTimeout(serviceMethod string, args interface{}, reply interface{}, ...) error

+ func (this *PushClient) Close() (err error)

+ func (this *PushClient) GetServerCertificate() (err error)

+ func (this *PushClient) Goodbye() (err error)

+ func (this *PushClient) Hello() (err error)

+ func (this *PushClient) SignUuid() (err error)

+ func (this *PushClient) Update() (err error)

+ type PushClientConfig struct

+ Address string

+ Enabled bool

+ Port int

+ PushInterval int

+ SslCert string

+ SslEnabled bool

+ UuidSig string

+ type PushServer struct

+ func NewPushServer(config *PushServerConfig) (this *PushServer)

+ func (this *PushServer) GetServerCertificate(req HelloRequest, cert *[]byte) (err error)

+ func (this *PushServer) GetUuidSignature(req HelloRequest, sig *[]byte) (err error)

+ func (this *PushServer) Goodbye(req Request, reply *bool) (err error)

+ func (this *PushServer) Hello(req HelloRequest, token *string) (err error)

+ func (this *PushServer) Register(req HelloRequest, reply *bool) (err error)

+ func (this *PushServer) Update(req UpdateRequest, reply *bool) (err error)

+ type PushServerConfig struct

+ Address string

+ AllowedClientsFile string

+ AutoAcceptClients bool

+ Enabled bool

+ MaxWaitingClients int

+ Port int

+ SslCert string

+ SslEnabled bool

+ SslKey string

+ type Put struct

+ Tags map[string]string

+ Value float64

+ type RemoteWigoConfig struct

+ AdvancedList []AdvancedRemoteWigoConfig

+ CheckInterval int

+ List []string

+ Login string

+ Password string

+ SslEnabled bool

+ type Request struct

+ Token string

+ Uuid string

+ func NewRequest(uuid string, token string) (this *Request)

+ type UpdateRequest struct

+ Wigo Wigo

+ func NewUpdateRequest(wigo *Wigo, token string) (this *UpdateRequest)

+ type Wigo struct

+ GlobalMessage string

+ GlobalStatus int

+ Hostname string

+ IsAlive bool

+ LastUpdate int64

+ LocalHost *Host

+ RemoteWigos map[string]*Wigo

+ Uuid string

+ Version string

+ var LocalWigo *Wigo

+ func GetLocalWigo() *Wigo

+ func NewWigo(config *Config) (this *Wigo, err error)

+ func NewWigoFromJson(ba []byte, checkRemotesDepth int) (this *Wigo, e error)

+ func (this *Wigo) AddLog(ressource interface{}, level uint8, message string) (err error)

+ func (this *Wigo) AddOrUpdateRemoteWigo(remoteWigo *Wigo)

+ func (this *Wigo) CompareTwoWigosAndRaiseNotifications(oldWigo *Wigo, newWigo *Wigo)

+ func (this *Wigo) Deduplicate(remoteWigo *Wigo) (err error)

+ func (this *Wigo) DisableProbe(probeName string)

+ func (this *Wigo) Down()

+ func (this *Wigo) EraseRemoteWigos(depth int) *Wigo

+ func (this *Wigo) FindRemoteWigoByHostname(hostname string) *Wigo

+ func (this *Wigo) FindRemoteWigoByUuid(uuid string) (*Wigo, bool)

+ func (this *Wigo) GenerateRemoteWigosSummary(level int, showOnlyErrors bool, version string) (summary string)

+ func (this *Wigo) GenerateSummary(showOnlyErrors bool) (summary string)

+ func (this *Wigo) GetConfig() *Config

+ func (this *Wigo) GetDisabledProbes() *list.List

+ func (this *Wigo) GetHostname() string

+ func (this *Wigo) GetLocalHost() *Host

+ func (this *Wigo) GetOpenTsdb() *gopentsdb.OpenTsdb

+ func (this *Wigo) GroupSummary(groupName string) (hs []*HostSummary, status int)

+ func (this *Wigo) InitOrReloadLogger() (err error)

+ func (this *Wigo) IsProbeDisabled(probeName string) bool

+ func (this *Wigo) ListGroupsNames() []string

+ func (this *Wigo) ListProbes() []string

+ func (this *Wigo) ListRemoteWigosNames() []string

+ func (this *Wigo) Lock()

+ func (this *Wigo) RecomputeGlobalStatus()

+ func (this *Wigo) SearchLogs(probe string, hostname string, group string, limit uint64, offset uint64) []*Log

+ func (this *Wigo) SetParentHostsInProbes()

+ func (this *Wigo) ToJsonString() (string, error)

+ func (this *Wigo) Unlock()

+ func (this *Wigo) Up()