helper

package

v0.9.0 Latest Latest Go to latest Published: Jan 27, 2017 License: Apache-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/redhat-cip/skydive

Links

Open Source Insights

Documentation ¶

Index ¶

func CleanGraph(g *graph.Graph)
func ExecCmds(t *testing.T, cmds ...Cmd)
func FilterIPv6AddrAnd(flows []*flow.Flow, A, B string) (r []*flow.Flow)
func GenerateFakeX509Certificate(certType string) (string, string)
func InitConfig(t *testing.T, conf string, params ...HelperParams)
func NewAgent() *agent.Agent
func NewAnalyzerStorage(t *testing.T, s storage.Storage) *analyzer.Server
func NewGraph(t *testing.T) *graph.Graph
func SFlowSetup(t *testing.T) (*net.UDPConn, error)
func StartAgentWithConfig(t *testing.T, conf string, params ...HelperParams) *agent.Agent
func StartAnalyzerWithConfig(t *testing.T, conf string, s storage.Storage, params ...HelperParams) *analyzer.Server
func WSConnect(endpoint string, timeout int, onReady func(*websocket.Conn)) (*websocket.Conn, error)
func WaitApi(t *testing.T, analyzer *analyzer.Server)
type Cmd
type GremlinQueryHelper
- func NewGremlinQueryHelper(authOptions *shttp.AuthenticationOpts) *GremlinQueryHelper
- func (g *GremlinQueryHelper) GetFlowMetricFromGremlinReply(t *testing.T, query string) flow.FlowMetric
- 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{})
type HelperAgentAnalyzer
- func NewAgentAnalyzerWithConfig(t *testing.T, conf string, s storage.Storage, params ...HelperParams) *HelperAgentAnalyzer
- func (h *HelperAgentAnalyzer) Flush()
- func (h *HelperAgentAnalyzer) Start()
- func (h *HelperAgentAnalyzer) Stop()
type HelperParams

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CleanGraph ¶ added in v0.8.0

func CleanGraph(g *graph.Graph)

func ExecCmds ¶ added in v0.2.0

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

func FilterIPv6AddrAnd ¶ added in v0.7.0

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

func GenerateFakeX509Certificate ¶ added in v0.8.0

func GenerateFakeX509Certificate(certType string) (string, string)

func InitConfig ¶

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

func NewAgent ¶ added in v0.3.0

func NewAgent() *agent.Agent

func NewAnalyzerStorage ¶ added in v0.3.0

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

func NewGraph ¶ added in v0.4.0

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

func SFlowSetup ¶

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

func StartAgentWithConfig ¶ added in v0.2.0

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

func StartAnalyzerWithConfig ¶ added in v0.4.0

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

func WSConnect ¶ added in v0.9.0

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

func WaitApi ¶ added in v0.4.0

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

Types ¶

type Cmd ¶ added in v0.2.0

type Cmd struct {
	Cmd   string
	Check bool
}

type GremlinQueryHelper ¶ added in v0.6.0

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

func NewGremlinQueryHelper ¶ added in v0.6.0

func NewGremlinQueryHelper(authOptions *shttp.AuthenticationOpts) *GremlinQueryHelper

func (*GremlinQueryHelper) GetFlowMetricFromGremlinReply ¶ added in v0.9.0

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

func (*GremlinQueryHelper) GetFlowsFromGremlinReply ¶ added in v0.6.0

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

func (*GremlinQueryHelper) GetNodeFromGremlinReply ¶ added in v0.6.0

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

func (*GremlinQueryHelper) GetNodesFromGremlinReply ¶ added in v0.6.0

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

func (*GremlinQueryHelper) GremlinQuery ¶ added in v0.6.0

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

type HelperAgentAnalyzer ¶ added in v0.3.0

type HelperAgentAnalyzer struct {
	Agent    *agent.Agent
	Analyzer *analyzer.Server
	// contains filtered or unexported fields
}

func NewAgentAnalyzerWithConfig ¶ added in v0.3.0

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

func (*HelperAgentAnalyzer) Flush ¶ added in v0.3.0

func (h *HelperAgentAnalyzer) Flush()

func (*HelperAgentAnalyzer) Start ¶ added in v0.3.0

func (h *HelperAgentAnalyzer) Start()

func (*HelperAgentAnalyzer) Stop ¶ added in v0.3.0

func (h *HelperAgentAnalyzer) Stop()

type HelperParams ¶ added in v0.4.0

type HelperParams map[string]interface{}

Source Files ¶

View all Source files

helper.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL