analyzer

type AnalyzerStatus struct {
	Clients  map[string]shttp.WSConnStatus
	Peers    map[string]shttp.WSConnStatus
	Alerts   ElectionStatus
	Captures ElectionStatus
}

type ElectionStatus struct {
	IsMaster bool
}

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

type FlowClientConn interface {
	Connect() error
	Close() error
	Send(data []byte) error
}

type FlowClientPool struct {
	sync.RWMutex
	shttp.DefaultWSSpeakerEventHandler
	// contains filtered or unexported fields
}

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

type FlowClientWebSocketConn struct {
	shttp.DefaultWSSpeakerEventHandler
	// contains filtered or unexported fields
}

type FlowServer struct {
	Storage          storage.Storage
	EnhancerPipeline *flow.EnhancerPipeline

	Server *shttp.Server
	// contains filtered or unexported fields
}

type FlowServerConn interface {
	Serve(ch chan *flow.Flow, quit chan struct{}, wg *sync.WaitGroup)
}

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

type FlowServerWebSocketConn struct {
	shttp.DefaultWSSpeakerEventHandler
	// contains filtered or unexported fields
}

type Server struct {
	HTTPServer      *shttp.Server
	WSServer        *shttp.WSJSONServer
	TopologyServer  *TopologyServer
	AlertServer     *alert.AlertServer
	OnDemandClient  *ondemand.OnDemandProbeClient
	MetadataManager *metadata.UserMetadataManager
	FlowServer      *FlowServer
	ProbeBundle     *probe.ProbeBundle
	Storage         storage.Storage
	EmbeddedEtcd    *etcd.EmbeddedEtcd
	EtcdClient      *etcd.EtcdClient
	// contains filtered or unexported fields
}

type TopologyReplicatorPeer struct {
	shttp.DefaultWSSpeakerEventHandler
	Addr        string
	Port        int
	Graph       *graph.Graph
	AuthOptions *shttp.AuthenticationOpts
	// contains filtered or unexported fields
}

type TopologyServer struct {
	sync.RWMutex
	shttp.DefaultWSSpeakerEventHandler

	Graph *graph.Graph
	// contains filtered or unexported fields
}