loadgen/eventhandler/event.go (8 lines of code) (raw):

// Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one // or more contributor license agreements. Licensed under the Elastic License 2.0; // you may not use this file except in compliance with the Elastic License 2.0. package eventhandler import "time" type EventCollector interface { Filter([]byte) error IsMeta([]byte) bool Process([]byte) event } type EventWriter func(config Config, minTimestamp time.Time, w *eventWriter, b batch, baseTimestamp time.Time, randomBits uint64) error