Documentation
¶
Index ¶
- func JsonLogEntryConstructor() ports.LogEntry
- func SqlLogEntryConstructor() ports.LogEntry
- type JsonLogEntry
- func (j *JsonLogEntry) ID() string
- func (j *JsonLogEntry) LoadBytes(raw []byte) error
- func (j *JsonLogEntry) LoadMap(raw map[string]interface{}) error
- func (j *JsonLogEntry) LoadString(raw string) error
- func (j *JsonLogEntry) Map() map[string]interface{}
- func (j *JsonLogEntry) RawBytes() []byte
- func (j *JsonLogEntry) RawString() string
- func (j *JsonLogEntry) Timestamp() time.Time
- type LogFileProvider
- func (f *LogFileProvider) AggregateResult(request *models.SearchAggregation) *models.AggregationResult
- func (f *LogFileProvider) BeginScan(r *models.SearchRequest)
- func (f *LogFileProvider) EndScan()
- func (f *LogFileProvider) Err() error
- func (f *LogFileProvider) LogEntry() ports.LogEntry
- func (f *LogFileProvider) Scan() bool
- func (f *LogFileProvider) Text() string
- type SQLDBLogEntry
- func (S *SQLDBLogEntry) ID() string
- func (S *SQLDBLogEntry) LoadBytes(bytes []byte) error
- func (S *SQLDBLogEntry) LoadMap(raw map[string]interface{}) error
- func (S *SQLDBLogEntry) LoadString(string string) error
- func (S *SQLDBLogEntry) Map() map[string]interface{}
- func (S *SQLDBLogEntry) RawBytes() []byte
- func (S *SQLDBLogEntry) RawString() string
- func (S *SQLDBLogEntry) Timestamp() time.Time
- type SQLDatabaseProvider
- func (s *SQLDatabaseProvider) AggregateResult(request *models.SearchAggregation) *models.AggregationResult
- func (s *SQLDatabaseProvider) BeginScan(r *models.SearchRequest)
- func (s *SQLDatabaseProvider) EndScan()
- func (s *SQLDatabaseProvider) Err() error
- func (s *SQLDatabaseProvider) LogEntry() ports.LogEntry
- func (s *SQLDatabaseProvider) Scan() bool
- func (s *SQLDatabaseProvider) Text() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func JsonLogEntryConstructor ¶
JsonLogEntryConstructor creates a new JsonLogEntry struct
func SqlLogEntryConstructor ¶
SqlLogEntryConstructor is a constructor for SQLDBLogEntry
Types ¶
type JsonLogEntry ¶
type JsonLogEntry struct {
TimeStampField string
// contains filtered or unexported fields
}
func (*JsonLogEntry) ID ¶
func (j *JsonLogEntry) ID() string
As json log does not have an id generate new uuid
func (*JsonLogEntry) LoadBytes ¶
func (j *JsonLogEntry) LoadBytes(raw []byte) error
func (*JsonLogEntry) LoadMap ¶
func (j *JsonLogEntry) LoadMap(raw map[string]interface{}) error
func (*JsonLogEntry) LoadString ¶
func (j *JsonLogEntry) LoadString(raw string) error
func (*JsonLogEntry) Map ¶
func (j *JsonLogEntry) Map() map[string]interface{}
func (*JsonLogEntry) RawBytes ¶
func (j *JsonLogEntry) RawBytes() []byte
func (*JsonLogEntry) RawString ¶
func (j *JsonLogEntry) RawString() string
func (*JsonLogEntry) Timestamp ¶
func (j *JsonLogEntry) Timestamp() time.Time
type LogFileProvider ¶
type LogFileProvider struct {
// contains filtered or unexported fields
}
func NewLogFileProvider ¶
func NewLogFileProvider(filePath string, constructor ports.EntryConstructor, indexer ports.Indexer, intervalParser ports.SearchInternalParser, filterFactory ports.SearchFilterFactory) *LogFileProvider
NewLogFileProvider creates a new LogFileProvider struct
func (*LogFileProvider) AggregateResult ¶
func (f *LogFileProvider) AggregateResult(request *models.SearchAggregation) *models.AggregationResult
func (*LogFileProvider) BeginScan ¶
func (f *LogFileProvider) BeginScan(r *models.SearchRequest)
func (*LogFileProvider) EndScan ¶
func (f *LogFileProvider) EndScan()
func (*LogFileProvider) Err ¶
func (f *LogFileProvider) Err() error
func (*LogFileProvider) LogEntry ¶
func (f *LogFileProvider) LogEntry() ports.LogEntry
func (*LogFileProvider) Scan ¶
func (f *LogFileProvider) Scan() bool
func (*LogFileProvider) Text ¶
func (f *LogFileProvider) Text() string
type SQLDBLogEntry ¶
type SQLDBLogEntry struct {
// contains filtered or unexported fields
}
func NewSQLDBLogEntry ¶
func NewSQLDBLogEntry() *SQLDBLogEntry
NewSQLDBLogEntry creates a new SQLDBLogEntry
func (*SQLDBLogEntry) ID ¶
func (S *SQLDBLogEntry) ID() string
func (*SQLDBLogEntry) LoadBytes ¶
func (S *SQLDBLogEntry) LoadBytes(bytes []byte) error
func (*SQLDBLogEntry) LoadMap ¶
func (S *SQLDBLogEntry) LoadMap(raw map[string]interface{}) error
func (*SQLDBLogEntry) LoadString ¶
func (S *SQLDBLogEntry) LoadString(string string) error
func (*SQLDBLogEntry) Map ¶
func (S *SQLDBLogEntry) Map() map[string]interface{}
func (*SQLDBLogEntry) RawBytes ¶
func (S *SQLDBLogEntry) RawBytes() []byte
func (*SQLDBLogEntry) RawString ¶
func (S *SQLDBLogEntry) RawString() string
func (*SQLDBLogEntry) Timestamp ¶
func (S *SQLDBLogEntry) Timestamp() time.Time
type SQLDatabaseProvider ¶
type SQLDatabaseProvider struct {
// contains filtered or unexported fields
}
func NewClickhouseProvider ¶
func NewClickhouseProvider(dsn, table string, queryBuilder ports.QueryBuilderFactory, entryConstructor ports.EntryConstructor) *SQLDatabaseProvider
func NewSQLDatabaseProvider ¶
func NewSQLDatabaseProvider(queryBuilder ports.QueryBuilderFactory, db *sql.DB, table string, entryConstructor ports.EntryConstructor, iparser ports.SearchInternalParser) *SQLDatabaseProvider
func (*SQLDatabaseProvider) AggregateResult ¶
func (s *SQLDatabaseProvider) AggregateResult(request *models.SearchAggregation) *models.AggregationResult
func (*SQLDatabaseProvider) BeginScan ¶
func (s *SQLDatabaseProvider) BeginScan(r *models.SearchRequest)
func (*SQLDatabaseProvider) EndScan ¶
func (s *SQLDatabaseProvider) EndScan()
func (*SQLDatabaseProvider) Err ¶
func (s *SQLDatabaseProvider) Err() error
func (*SQLDatabaseProvider) LogEntry ¶
func (s *SQLDatabaseProvider) LogEntry() ports.LogEntry
func (*SQLDatabaseProvider) Scan ¶
func (s *SQLDatabaseProvider) Scan() bool
func (*SQLDatabaseProvider) Text ¶
func (s *SQLDatabaseProvider) Text() string
Source Files
Click to show internal directories.
Click to hide internal directories.