hekalocal

type HashUUIDDecoder struct {
	Timestamp time.Time // Hard-code the timestamp for testing
}

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

type JSONDecoderConfig struct {
	TimestampField   string            `toml:"timestamp_field"`
	UUIDField        string            `toml:"uuid_field"`
	TypeField        string            `toml:"type_field"`
	LoggerField      string            `toml:"logger_field"`
	EnvVersionField  string            `toml:"env_version_field"`
	HostnameField    string            `toml:"hostname_field"`
	SeverityField    string            `toml:"severity_field"`
	PIDField         string            `toml:"pid_field"`
	Flatten          bool              `toml:"flatten"`
	FlattenPrefix    string            `toml:"flatten_prefix"`
	FlattenToStrings bool              `toml:"flatten_to_strings"`
	MoveFields       map[string]string `toml:"move_fields"`
	KeepFields       []string          `toml:"keep_fields"`
	RemoveFields     []string          `toml:"remove_fields"`

	// The message payload will be hashed and made into a UUID along with the timestamp.
	HashUUID bool `toml:"hash_uuid"`
	// contains filtered or unexported fields
}

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

type JSONEncoderConfig struct {
	TimestampField  string `toml:"timestamp_field"`
	UUIDField       string `toml:"uuid_field"`
	SeverityField   string `toml:"severity_field"`
	TypeField       string `toml:"type_field"`
	LoggerField     string `toml:"logger_field"`
	EnvVersionField string `toml:"env_version_field"`
	HostnameField   string `toml:"hostname_field"`
	PIDField        string `toml:"pid_field"`

	ElasticsearchBulk  bool   `toml:"elasticsearch_bulk"`
	ElasticsearchIndex string `toml:"elasticsearch_index"`
	ElasticsearchType  string `toml:"elasticsearch_type"`
	ElasticsearchID    string `toml:"elasticsearch_id"`
	// contains filtered or unexported fields
}

type UnflattenDecoder struct{}