analyzer

Documentation

Index

• func ClusterAuthenticationOpts() *shttp.AuthenticationOpts
• func NewESConfig(name ...string) es.Config
• func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.Bundle, error)
• type ElectionStatus
• type Server
  • func NewServerFromConfig() (*Server, error)
  • func (s *Server) GetStatus() interface{}
  • func (s *Server) Start() error
  • func (s *Server) Stop()
• type Status

Functions

func ClusterAuthenticationOpts

func ClusterAuthenticationOpts() *shttp.AuthenticationOpts

ClusterAuthenticationOpts returns auth info to connect to an analyzer from the configuration

func NewESConfig

func NewESConfig(name ...string) es.Config

NewESConfig returns a new elasticsearch configuration for the given backend name

func NewTopologyProbeBundleFromConfig

func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.Bundle, error)

NewTopologyProbeBundleFromConfig creates a new topology server probes from configuration

Types

type ElectionStatus

type ElectionStatus struct {
	IsMaster bool
}

ElectionStatus describes the status of an election

type Server

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

Server describes an Analyzer servers mechanism like http, websocket, topology, ondemand probes, ...

func NewServerFromConfig

func NewServerFromConfig() (*Server, error)

NewServerFromConfig creates a new empty server

func (*Server) GetStatus

func (s *Server) GetStatus() interface{}

GetStatus returns the status of an analyzer

func (*Server) Start

func (s *Server) Start() error

Start the analyzer server

func (*Server) Stop

func (s *Server) Stop()

Stop the analyzer server

type Status

type Status struct {
	Agents      map[string]ws.ConnStatus
	Peers       hub.PeersStatus
	Publishers  map[string]ws.ConnStatus
	Subscribers map[string]ws.ConnStatus
	Alerts      ElectionStatus
	Captures    ElectionStatus
	Probes      []string
}

Status describes the status of an analyzer