helper

Sep 14, 2018

Changes in this version

+ func Connect(endpoint string, timeout int, onReady func(*websocket.Conn)) (*websocket.Conn, error)

+ func DecodeStructMessageJSON(b []byte) *ws.StructMessage

Aug 8, 2018

Changes in this version

+ var AgentTestsOnly bool

+ var NoOFTests bool

Jun 21, 2018

Changes in this version

+ var AnalyzerListen string

+ var FlowBackend string

+ var TopologyBackend string

Apr 12, 2018

Changes in this version

+ func DecodeWSStructMessageJSON(b []byte) *shttp.WSStructMessage

Aug 1, 2017

Changes in this version

+ var GraphOutputFormat string

+ var RecordVideo bool

+ func WSClose(ws *websocket.Conn) error

Mar 31, 2017

Changes in this version

+ var Standalone bool

+ func FlowsToString(flows []*flow.Flow) string

+ func SendPCAPFile(filename string, socket string) error

Jan 27, 2017

Changes in this version

+ func WSConnect(endpoint string, timeout int, onReady func(*websocket.Conn)) (*websocket.Conn, error)

type GremlinQueryHelper

+ func (g *GremlinQueryHelper) GetFlowMetricFromGremlinReply(t *testing.T, query string) flow.FlowMetric

Dec 9, 2016

Changes in this version

+ func CleanGraph(g *graph.Graph)

+ func GenerateFakeX509Certificate(certType string) (string, string)

Nov 8, 2016

Changes in this version

+ func FilterIPv6AddrAnd(flows []*flow.Flow, A, B string) (r []*flow.Flow)

Oct 6, 2016

Changes in this version

+ type GremlinQueryHelper struct

+ func NewGremlinQueryHelper(authOptions *shttp.AuthenticationOpts) *GremlinQueryHelper

+ func (g *GremlinQueryHelper) GetFlowSetBandwidthFromGremlinReply(t *testing.T, query string) flow.FlowSetBandwidth

+ func (g *GremlinQueryHelper) GetFlowsFromGremlinReply(t *testing.T, query string) (flows []*flow.Flow)

+ func (g *GremlinQueryHelper) GetNodeFromGremlinReply(t *testing.T, query string) *graph.Node

+ func (g *GremlinQueryHelper) GetNodesFromGremlinReply(t *testing.T, query string) []graph.Node

+ func (g *GremlinQueryHelper) GremlinQuery(t *testing.T, query string, values interface{})

Aug 4, 2016

Changes in this version

+ func NewGraph(t *testing.T) *graph.Graph

+ func StartAnalyzerWithConfig(t *testing.T, conf string, s storage.Storage, params ...HelperParams) *analyzer.Server

+ func WaitApi(t *testing.T, analyzer *analyzer.Server)

+ type HelperParams map[string]interface

Apr 26, 2016

Changes in this version

+ func NewAgent() *agent.Agent

+ func NewAnalyzerStorage(t *testing.T, s storage.Storage) *analyzer.Server

+ type HelperAgentAnalyzer struct

+ Agent *agent.Agent

+ Analyzer *analyzer.Server

+ func NewAgentAnalyzerWithConfig(t *testing.T, conf string, s storage.Storage) *HelperAgentAnalyzer

+ func (h *HelperAgentAnalyzer) Flush()

+ func (h *HelperAgentAnalyzer) Start()

+ func (h *HelperAgentAnalyzer) Stop()

Feb 23, 2016

Changes in this version

+ func ExecCmds(t *testing.T, cmds ...Cmd)

+ func StartAgentAndAnalyzerWithConfig(t *testing.T, conf string, s storage.Storage) (*agent.Agent, *analyzer.Server)

+ func StartAgentWithConfig(t *testing.T, conf string) *agent.Agent

+ type Cmd struct

+ Check bool

+ Cmd string

Feb 10, 2016

Changes in this version

+ func InitConfig(t *testing.T, conf string)

+ func ReplayTraceHelper(t *testing.T, trace string, target string)

+ func SFlowSetup(t *testing.T) (*net.UDPConn, error)

+ func StartAgent(t *testing.T) *agent.Agent