output

type DefaultSink struct{}

type FileConfig struct {
	Path string `json:"path"`
}

type FileOutput struct {
	FileName string
	// contains filtered or unexported fields
}

type Level int

type OutputEvent struct {
	Source      string
	EventTime   time.Time
	EventType   string
	Name        string
	Level       Level
	EventId     string
	Entity      string
	SourceIP    string
	Body        map[string]interface{}
	Occurrences int
}

type SQSOutput struct {
	QueueUrl string
	Region   string
	// contains filtered or unexported fields
}

type Sink interface {
	Sink(*chan interface{})
	Init(...interface{}) error
	Close() error
}

type SinkConfig struct {
	Type       string     `json:"type"`
	FileConfig FileConfig `json:"file_config,omitempty"`
	SqsConfig  SqsConfig  `json:"sqs_config,omitempty"`
}

type SinkIface interface {
	Create(config SinkConfig) (Sink, error)
}

type SqsConfig struct {
	QueueUrl string `json:"queueUrl"`
	Region   string `json:"region"`
}