analyzer

Documentation

Index

• func ClusterAuthenticationOpts() *shttp.AuthenticationOpts
• func NewESConfig(name ...string) es.Config
• func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.Bundle, error)
• type Server
  • func NewServerFromConfig() (*Server, error)
  • func (s *Server) GetStatus() interface{}
  • func (s *Server) Start() error
  • func (s *Server) Stop()
• type Status
  • func (v Status) MarshalEasyJSON(w *jwriter.Writer)
  • func (v Status) MarshalJSON() ([]byte, error)
  • func (v *Status) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (v *Status) UnmarshalJSON(data []byte) error

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 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      hub.ElectionStatus
	Captures    hub.ElectionStatus
	Probes      map[string]interface{}
}

Status analyzer object

Status describes the status of an analyzer

swagger:model AnalyzerStatus easyjson:json

func (Status) MarshalEasyJSON

func (v Status) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (Status) MarshalJSON

func (v Status) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*Status) UnmarshalEasyJSON

func (v *Status) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Status) UnmarshalJSON

func (v *Status) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface