Documentation
¶
Index ¶
- Variables
- func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.ProbeBundle, error)
- type AgentAnalyzerClientConn
- type AgentAnalyzerConnectionType
- type AgentAnalyzerServerConn
- func (a *AgentAnalyzerServerConn) Accept() (*AgentAnalyzerServerConn, error)
- func (a *AgentAnalyzerServerConn) Cleanup()
- func (a *AgentAnalyzerServerConn) Close()
- func (a *AgentAnalyzerServerConn) Mode() AgentAnalyzerConnectionType
- func (a *AgentAnalyzerServerConn) Read(data []byte) (int, error)
- func (a *AgentAnalyzerServerConn) SetDeadline(t time.Time)
- func (a *AgentAnalyzerServerConn) Timeout(err error) bool
- type Client
- type Server
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrAgentAnalyzerUDPAcceptNotSupported = errors.New("UDP connection is datagram based (not connected), accept() not supported")
Functions ¶
func NewTopologyProbeBundleFromConfig ¶ added in v0.8.0
func NewTopologyProbeBundleFromConfig(g *graph.Graph) (*probe.ProbeBundle, error)
Types ¶
type AgentAnalyzerClientConn ¶ added in v0.8.0
type AgentAnalyzerClientConn struct {
// contains filtered or unexported fields
}
func NewAgentAnalyzerClientConn ¶ added in v0.8.0
func NewAgentAnalyzerClientConn(addr *net.UDPAddr) (a *AgentAnalyzerClientConn, err error)
func (*AgentAnalyzerClientConn) Close ¶ added in v0.8.0
func (a *AgentAnalyzerClientConn) Close()
type AgentAnalyzerConnectionType ¶ added in v0.8.0
type AgentAnalyzerConnectionType int
const ( UDP AgentAnalyzerConnectionType = 1 + iota TLS )
type AgentAnalyzerServerConn ¶ added in v0.8.0
type AgentAnalyzerServerConn struct {
// contains filtered or unexported fields
}
func NewAgentAnalyzerServerConn ¶ added in v0.8.0
func NewAgentAnalyzerServerConn(addr *net.UDPAddr) (a *AgentAnalyzerServerConn, err error)
func (*AgentAnalyzerServerConn) Accept ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) Accept() (*AgentAnalyzerServerConn, error)
func (*AgentAnalyzerServerConn) Cleanup ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) Cleanup()
func (*AgentAnalyzerServerConn) Close ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) Close()
func (*AgentAnalyzerServerConn) Mode ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) Mode() AgentAnalyzerConnectionType
func (*AgentAnalyzerServerConn) Read ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) Read(data []byte) (int, error)
func (*AgentAnalyzerServerConn) SetDeadline ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) SetDeadline(t time.Time)
func (*AgentAnalyzerServerConn) Timeout ¶ added in v0.8.0
func (a *AgentAnalyzerServerConn) Timeout(err error) bool
type Server ¶
type Server struct {
HTTPServer *shttp.Server
WSServer *shttp.WSServer
GraphServer *graph.GraphServer
AlertServer *alert.AlertServer
OnDemandClient *ondemand.OnDemandProbeClient
FlowMappingPipeline *mappings.FlowMappingPipeline
ProbeBundle *probe.ProbeBundle
Storage storage.Storage
FlowTable *flow.Table
TableClient *flow.TableClient
EmbeddedEtcd *etcd.EmbeddedEtcd
EtcdClient *etcd.EtcdClient
// contains filtered or unexported fields
}
func NewServerFromConfig ¶
func (*Server) AnalyzeFlows ¶
func (*Server) ListenAndServe ¶
func (s *Server) ListenAndServe()
func (*Server) SetStorage ¶
Click to show internal directories.
Click to hide internal directories.