consumers

type BatchConsumer struct {
	Url        string
	Max        int
	DataBuffer []structs.EventData
	ItemBuffer []structs.Item
	Timeout    time.Duration
	// contains filtered or unexported fields
}

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

type ConcurrentLoggingConsumer struct {
	Fname string
	Hour  bool
	// contains filtered or unexported fields
}

type Consumer interface {
	Send(data structs.EventData) error
	Flush() error
	Close() error
	ItemSend(item structs.Item) error
}

type DebugConsumer struct {
	Url       string
	WriteData bool
	Timeout   time.Duration
}

type DefaultConsumer struct {
	Url     string
	Timeout time.Duration
}

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

type LoggingConsumer struct {
	Fname string
	Hour  bool
	// contains filtered or unexported fields
}