test

Documentation

Index

• Constants
• func CreateAllCerts(t *testing.T) (string, string, string, func())
• func CreateCACert(t *testing.T) (string, func())
• func CreateMockAgg(name, operationKey, groupByKeys, agg, op string, totalValue float64, ...) config.GenericMap
• func DeserializeJSONToMap(t *testing.T, in string) config.GenericMap
• func DumpToTemp(content string) (string, error, func())
• func FakeLokiHandler(flowsData chan<- map[string]interface{}) http.HandlerFunc
• func GetExtractMockEntries2() []config.GenericMap
• func GetExtractMockEntry() config.GenericMap
• func GetIngestMockEntry(missingKey bool) config.GenericMap
• func InitConfig(t *testing.T, conf string) (*viper.Viper, *config.ConfigFileStruct)
• func ReadExposedMetrics(t *testing.T) string
• func ResetPromRegistry()
• func RunCommand(command string) string
• func UDPPort() (int, error)
• func WaitFromChannel(in chan config.GenericMap, timeout time.Duration) (config.GenericMap, error)
• type IPFIXClient
  • func NewIPFIXClient(port int) (*IPFIXClient, error)
  • func (ke *IPFIXClient) SendFlow(timestamp uint32, srcIP string) error
  • func (ke *IPFIXClient) SendTemplate() error

Constants

const ConfgenLongConfig = `` /* 587-byte string literal not displayed */

const ConfgenNetworkDefBase = `` /* 719-byte string literal not displayed */

const ConfgenNetworkDefHisto = `` /* 458-byte string literal not displayed */

const ConfgenNetworkDefNoAgg = `` /* 527-byte string literal not displayed */

const ConfgenShortConfig = `` /* 412-byte string literal not displayed */

Functions

func CreateAllCerts

func CreateAllCerts(t *testing.T) (string, string, string, func())

CreateAllCerts returns paths to: - ca - user cert - user key and the cleanup function to defer

func CreateCACert

func CreateCACert(t *testing.T) (string, func())

CreateCACert returns paths to CA cert and the cleanup function to defer

func CreateMockAgg

func CreateMockAgg(name, operationKey, groupByKeys, agg, op string, totalValue float64, totalCount int, rrv []float64, recentOpValue float64, recentCount int) config.GenericMap

func DeserializeJSONToMap

func DeserializeJSONToMap(t *testing.T, in string) config.GenericMap

func DumpToTemp

func DumpToTemp(content string) (string, error, func())

func FakeLokiHandler

func FakeLokiHandler(flowsData chan<- map[string]interface{}) http.HandlerFunc

FakeLokiHandler is a fake loki HTTP service that decodes the snappy/protobuf messages and forwards them for later assertions

func GetExtractMockEntries2

func GetExtractMockEntries2() []config.GenericMap

func GetExtractMockEntry

func GetExtractMockEntry() config.GenericMap

func GetIngestMockEntry

func GetIngestMockEntry(missingKey bool) config.GenericMap

func InitConfig

func InitConfig(t *testing.T, conf string) (*viper.Viper, *config.ConfigFileStruct)

func ReadExposedMetrics

func ReadExposedMetrics(t *testing.T) string

func ResetPromRegistry

func ResetPromRegistry()

func RunCommand

func RunCommand(command string) string

func UDPPort

func UDPPort() (int, error)

UDPPort asks the kernel for a free open port that is ready to use.

func WaitFromChannel

func WaitFromChannel(in chan config.GenericMap, timeout time.Duration) (config.GenericMap, error)

Types

type IPFIXClient

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

IPFIXClient for IPFIX tests

func NewIPFIXClient

func NewIPFIXClient(port int) (*IPFIXClient, error)

NewIPFIXClient returns an IPFIXClient that sends data to the given port

func (*IPFIXClient) SendFlow

func (ke *IPFIXClient) SendFlow(timestamp uint32, srcIP string) error

SendFlow containing the information passed as an argument

func (*IPFIXClient) SendTemplate

func (ke *IPFIXClient) SendTemplate() error

SendTemplate must be executed before sending any flow