postgres

package

v0.0.0-...-a23bd61 Latest Latest Go to latest Published: Jun 2, 2020 License: BSD-2-Clause Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jasonish/evebox

Documentation ¶

Index ¶

Constants
type PgConfig
- func ManagedConfig(dataDirectory string) (PgConfig, error)
type PgDB
- func NewPgDatabase(config PgConfig) (*PgDB, error)
type PgDatastore
- func NewPgDatastore(pg *PgDB) *PgDatastore
- func (d *PgDatastore) AlertQuery(options core.AlertQueryOptions) ([]core.AlertGroup, error)
- func (d *PgDatastore) ArchiveAlertGroup(p core.AlertGroupQueryParams, user core.User) (err error)
- func (d *PgDatastore) ArchiveEvent(eventId string, user core.User) error
- func (d *PgDatastore) CommentOnAlertGroup(p core.AlertGroupQueryParams, user core.User, comment string) (err error)
- func (d *PgDatastore) CommentOnEventId(eventId string, user core.User, comment string) error
- func (d *PgDatastore) DeEscalateAlertGroup(p core.AlertGroupQueryParams, user core.User) (err error)
- func (d *PgDatastore) DeEscalateEvent(eventId string, user core.User) error
- func (d *PgDatastore) EscalateAlertGroup(p core.AlertGroupQueryParams, user core.User) (err error)
- func (d *PgDatastore) EscalateEvent(eventId string, user core.User) error
- func (s *PgDatastore) EventQuery(options core.EventQueryOptions) (interface{}, error)
- func (d *PgDatastore) FindFlow(flowId uint64, proto string, timestamp string, srcIp string, destIp string) (interface{}, error)
- func (d *PgDatastore) GetEveEventSink() core.EveEventSink
- func (d *PgDatastore) GetEventById(eventId string) (map[string]interface{}, error)
type PgEventIndexer
- func NewPgEventIndexer(pg *PgDB) *PgEventIndexer
- func (i *PgEventIndexer) Commit() (interface{}, error)
- func (i *PgEventIndexer) CreateTable(timestamp string)
- func (i *PgEventIndexer) Submit(event eve.EveEvent) error
type PostgresManager
- func ConfigureManaged(dataDirectory string) (*PostgresManager, error)
- func NewPostgresManager(directory string) (*PostgresManager, error)
- func (p *PostgresManager) Init() error
- func (p *PostgresManager) IsInitialized() bool
- func (p *PostgresManager) Start() error
- func (p *PostgresManager) StopFast()
- func (p *PostgresManager) StopImmediate()
- func (p *PostgresManager) StopSmart()
type PostgresVersion
- func GetVersion() (*PostgresVersion, error)
- func ParseVersion(versionString string) (*PostgresVersion, error)
- func (v *PostgresVersion) String() string
type Service
type SqlMigrator
- func NewSqlMigrator(db *PgDB, directory string) *SqlMigrator
- func (m *SqlMigrator) Migrate() error

Constants ¶

View Source

const PGDATABASE = "evebox"

View Source

const PGPASS = "evebox"

View Source

const PGUSER = "evebox"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type PgConfig ¶

type PgConfig struct {
	Database string
	User     string
	Password string
	Host     string
}

func ManagedConfig ¶

func ManagedConfig(dataDirectory string) (PgConfig, error)

type PgDB ¶

type PgDB struct {
	*sql.DB
}

func NewPgDatabase ¶

func NewPgDatabase(config PgConfig) (*PgDB, error)

type PgDatastore ¶

type PgDatastore struct {
	core.UnimplementedDatastore
	// contains filtered or unexported fields
}

func NewPgDatastore ¶

func NewPgDatastore(pg *PgDB) *PgDatastore

func (*PgDatastore) AlertQuery ¶

func (d *PgDatastore) AlertQuery(options core.AlertQueryOptions) ([]core.AlertGroup, error)

func (*PgDatastore) ArchiveAlertGroup ¶

func (d *PgDatastore) ArchiveAlertGroup(p core.AlertGroupQueryParams, user core.User) (err error)

func (*PgDatastore) ArchiveEvent ¶

func (d *PgDatastore) ArchiveEvent(eventId string, user core.User) error

func (*PgDatastore) CommentOnAlertGroup ¶

func (d *PgDatastore) CommentOnAlertGroup(p core.AlertGroupQueryParams, user core.User, comment string) (err error)

func (*PgDatastore) CommentOnEventId ¶

func (d *PgDatastore) CommentOnEventId(eventId string, user core.User, comment string) error

func (*PgDatastore) DeEscalateAlertGroup ¶

func (d *PgDatastore) DeEscalateAlertGroup(p core.AlertGroupQueryParams, user core.User) (err error)

func (*PgDatastore) DeEscalateEvent ¶

func (d *PgDatastore) DeEscalateEvent(eventId string, user core.User) error

func (*PgDatastore) EscalateAlertGroup ¶

func (d *PgDatastore) EscalateAlertGroup(p core.AlertGroupQueryParams, user core.User) (err error)

func (*PgDatastore) EscalateEvent ¶

func (d *PgDatastore) EscalateEvent(eventId string, user core.User) error

func (*PgDatastore) EventQuery ¶

func (s *PgDatastore) EventQuery(options core.EventQueryOptions) (interface{}, error)

func (*PgDatastore) FindFlow ¶

func (d *PgDatastore) FindFlow(flowId uint64, proto string, timestamp string,
	srcIp string, destIp string) (interface{}, error)

func (*PgDatastore) GetEveEventSink ¶

func (d *PgDatastore) GetEveEventSink() core.EveEventSink

func (*PgDatastore) GetEventById ¶

func (d *PgDatastore) GetEventById(eventId string) (map[string]interface{}, error)

type PgEventIndexer ¶

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

func NewPgEventIndexer ¶

func NewPgEventIndexer(pg *PgDB) *PgEventIndexer

func (*PgEventIndexer) Commit ¶

func (i *PgEventIndexer) Commit() (interface{}, error)

func (*PgEventIndexer) CreateTable ¶

func (i *PgEventIndexer) CreateTable(timestamp string)

func (*PgEventIndexer) Submit ¶

func (i *PgEventIndexer) Submit(event eve.EveEvent) error

type PostgresManager ¶

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

func ConfigureManaged ¶

func ConfigureManaged(dataDirectory string) (*PostgresManager, error)

func NewPostgresManager ¶

func NewPostgresManager(directory string) (*PostgresManager, error)

func (*PostgresManager) Init ¶

func (p *PostgresManager) Init() error

func (*PostgresManager) IsInitialized ¶

func (p *PostgresManager) IsInitialized() bool

func (*PostgresManager) Start ¶

func (p *PostgresManager) Start() error

func (*PostgresManager) StopFast ¶

func (p *PostgresManager) StopFast()

func (*PostgresManager) StopImmediate ¶

func (p *PostgresManager) StopImmediate()

func (*PostgresManager) StopSmart ¶

func (p *PostgresManager) StopSmart()

type PostgresVersion ¶

type PostgresVersion struct {
	Raw        string
	Full       string
	MajorMinor string
	Major      int64
	Minor      int64
}

func GetVersion ¶

func GetVersion() (*PostgresVersion, error)

func ParseVersion ¶

func ParseVersion(versionString string) (*PostgresVersion, error)

func (*PostgresVersion) String ¶

func (v *PostgresVersion) String() string

type Service ¶

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

type SqlMigrator ¶

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

func NewSqlMigrator ¶

func NewSqlMigrator(db *PgDB, directory string) *SqlMigrator

func (*SqlMigrator) Migrate ¶

func (m *SqlMigrator) Migrate() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL