Documentation
¶
Index ¶
- Constants
- Variables
- func InitPurger(db *SqliteService)
- func InitSqlite(appContext *appcontext.AppContext) (err error)
- type DataStore
- func (s *DataStore) AlertQuery(options core.AlertQueryOptions) ([]core.AlertGroup, error)
- func (s *DataStore) ArchiveAlertGroup(p core.AlertGroupQueryParams, user core.User) error
- func (s *DataStore) DeEscalateAlertGroup(p core.AlertGroupQueryParams, user core.User) error
- func (s *DataStore) EscalateAlertGroup(p core.AlertGroupQueryParams, user core.User) error
- func (s *DataStore) EventQuery(options core.EventQueryOptions) (interface{}, error)
- func (d *DataStore) FindFlow(flowId uint64, proto string, timestamp string, srcIp string, destIp string) (interface{}, error)
- func (d *DataStore) GetEveEventSink() core.EveEventSink
- func (s *DataStore) GetEventById(id string) (map[string]interface{}, error)
- type QueryStringParser
- type SqlBuilder
- func (b *SqlBuilder) Args() []interface{}
- func (b *SqlBuilder) Build() string
- func (b *SqlBuilder) BuildFrom() string
- func (b *SqlBuilder) BuildWhere() string
- func (b *SqlBuilder) From(table string)
- func (b *SqlBuilder) HasWhere() bool
- func (b *SqlBuilder) Limit(limit int)
- func (b *SqlBuilder) Select(what string) (builder *SqlBuilder)
- func (b *SqlBuilder) Where(where string)
- func (b *SqlBuilder) WhereEquals(field string, value interface{})
- func (b *SqlBuilder) WhereGte(field string, value interface{})
- func (b *SqlBuilder) WhereLte(field string, value interface{})
- type SqliteIndexer
- type SqlitePurger
- type SqliteService
Constants ¶
View Source
const BATCH_SIZE = 100
View Source
const DB_FILENAME = "events.sqlite"
View Source
const OLD_DB_FILENAME = "evebox.sqlite"
Variables ¶
View Source
var LIMIT int64 = 1000
Functions ¶
func InitPurger ¶
func InitPurger(db *SqliteService)
func InitSqlite ¶
func InitSqlite(appContext *appcontext.AppContext) (err error)
Types ¶
type DataStore ¶
type DataStore struct {
core.UnimplementedDatastore
// contains filtered or unexported fields
}
func NewDataStore ¶
func NewDataStore(db *SqliteService) *DataStore
func (*DataStore) AlertQuery ¶
func (s *DataStore) AlertQuery(options core.AlertQueryOptions) ([]core.AlertGroup, error)
func (*DataStore) ArchiveAlertGroup ¶
func (*DataStore) DeEscalateAlertGroup ¶
func (*DataStore) EscalateAlertGroup ¶
func (*DataStore) EventQuery ¶
func (s *DataStore) EventQuery(options core.EventQueryOptions) (interface{}, error)
func (*DataStore) GetEveEventSink ¶
func (d *DataStore) GetEveEventSink() core.EveEventSink
type QueryStringParser ¶
type QueryStringParser struct {
// contains filtered or unexported fields
}
func NewQueryStringParser ¶
func NewQueryStringParser(q string) *QueryStringParser
func (*QueryStringParser) Next ¶
func (p *QueryStringParser) Next() (string, string)
type SqlBuilder ¶
type SqlBuilder struct {
// contains filtered or unexported fields
}
func (*SqlBuilder) Args ¶
func (b *SqlBuilder) Args() []interface{}
func (*SqlBuilder) Build ¶
func (b *SqlBuilder) Build() string
func (*SqlBuilder) BuildFrom ¶
func (b *SqlBuilder) BuildFrom() string
func (*SqlBuilder) BuildWhere ¶
func (b *SqlBuilder) BuildWhere() string
func (*SqlBuilder) From ¶
func (b *SqlBuilder) From(table string)
func (*SqlBuilder) HasWhere ¶
func (b *SqlBuilder) HasWhere() bool
func (*SqlBuilder) Limit ¶
func (b *SqlBuilder) Limit(limit int)
func (*SqlBuilder) Select ¶
func (b *SqlBuilder) Select(what string) (builder *SqlBuilder)
func (*SqlBuilder) Where ¶
func (b *SqlBuilder) Where(where string)
func (*SqlBuilder) WhereEquals ¶
func (b *SqlBuilder) WhereEquals(field string, value interface{})
func (*SqlBuilder) WhereGte ¶
func (b *SqlBuilder) WhereGte(field string, value interface{})
func (*SqlBuilder) WhereLte ¶
func (b *SqlBuilder) WhereLte(field string, value interface{})
type SqliteIndexer ¶
type SqliteIndexer struct {
// contains filtered or unexported fields
}
func NewSqliteIndexer ¶
func NewSqliteIndexer(db *SqliteService) *SqliteIndexer
func (*SqliteIndexer) Commit ¶
func (i *SqliteIndexer) Commit() (interface{}, error)
type SqlitePurger ¶
type SqlitePurger struct {
// contains filtered or unexported fields
}
func (*SqlitePurger) Purge ¶
func (p *SqlitePurger) Purge() (int64, error)
func (*SqlitePurger) Run ¶
func (p *SqlitePurger) Run()
type SqliteService ¶
func NewSqliteService ¶
func NewSqliteService(filename string) (*SqliteService, error)
func (*SqliteService) Migrate ¶
func (s *SqliteService) Migrate() error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.