test

func CreateAllCerts ¶ added in v0.1.3

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 ¶ added in v0.1.3

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

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

func CreateMockAgg ¶

func CreateMockAgg(name, recordKey, by, 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 ¶ added in v0.1.3

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 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 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 ¶ added in v0.1.3

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