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 ¶
Functions ¶
Types ¶
type AgentAnalyzerClientConn ¶ added in v0.9.0
type AgentAnalyzerClientConn struct {
// contains filtered or unexported fields
}
func NewAgentAnalyzerClientConn ¶ added in v0.9.0
func NewAgentAnalyzerClientConn(addr *net.UDPAddr) (a *AgentAnalyzerClientConn, err error)
func (*AgentAnalyzerClientConn) Close ¶ added in v0.9.0
func (a *AgentAnalyzerClientConn) Close()
func (*AgentAnalyzerClientConn) Write ¶ added in v0.9.0
func (a *AgentAnalyzerClientConn) Write(b []byte) (int, error)
type AgentAnalyzerConnectionType ¶ added in v0.9.0
type AgentAnalyzerConnectionType int
const ( UDP AgentAnalyzerConnectionType = 1 + iota TLS )
type AgentAnalyzerServerConn ¶ added in v0.9.0
type AgentAnalyzerServerConn struct {
// contains filtered or unexported fields
}
func NewAgentAnalyzerServerConn ¶ added in v0.9.0
func NewAgentAnalyzerServerConn(addr *net.UDPAddr) (a *AgentAnalyzerServerConn, err error)
func (*AgentAnalyzerServerConn) Accept ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) Accept() (*AgentAnalyzerServerConn, error)
func (*AgentAnalyzerServerConn) Cleanup ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) Cleanup()
func (*AgentAnalyzerServerConn) Close ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) Close()
func (*AgentAnalyzerServerConn) Mode ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) Mode() AgentAnalyzerConnectionType
func (*AgentAnalyzerServerConn) Read ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) Read(data []byte) (int, error)
func (*AgentAnalyzerServerConn) SetDeadline ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) SetDeadline(t time.Time)
func (*AgentAnalyzerServerConn) Timeout ¶ added in v0.9.0
func (a *AgentAnalyzerServerConn) Timeout(err error) bool
type Client ¶
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
}
Source Files
¶
- client.go
- connection.go
- probes.go
- server.go
Click to show internal directories.
Click to hide internal directories.