sqlite

Documentation

Index

• type Context
  • func NewSQLite(cfg map[string]string) (*Context, error)
  • func (c *Context) CleanUpRecordsByAge() error
  • func (c *Context) CleanUpRecordsByCount() error
  • func (c *Context) DeleteAll() error
  • func (c *Context) DeleteBan(target string) (int, error)
  • func (c *Context) DeleteExpired() error
  • func (c *Context) Flush() error
  • func (c *Context) GetBansAt(at time.Time) ([]map[string]string, error)
  • func (c *Context) GetStats(since time.Duration) ([]map[string]string, error)
  • func (c *Context) StartAutoCommit() error
  • func (c *Context) WriteBanApplication(ban types.BanApplication) error
  • func (c *Context) WriteSignal(sig types.SignalOccurence) error

Types

type Context

type Context struct {
	Db *gorm.DB //Pointer to sqlite db

	PusherTomb tomb.Tomb
	// contains filtered or unexported fields
}

func NewSQLite

func NewSQLite(cfg map[string]string) (*Context, error)

func (*Context) CleanUpRecordsByAge

func (c *Context) CleanUpRecordsByAge() error

func (*Context) CleanUpRecordsByCount

func (c *Context) CleanUpRecordsByCount() error

func (*Context) DeleteAll

func (c *Context) DeleteAll() error

func (*Context) DeleteBan

func (c *Context) DeleteBan(target string) (int, error)

try to delete entries with matching fields

func (*Context) DeleteExpired

func (c *Context) DeleteExpired() error

func (*Context) Flush

func (c *Context) Flush() error

func (*Context) GetBansAt

func (c *Context) GetBansAt(at time.Time) ([]map[string]string, error)

GetBansAt returns the IPs that were banned at a given time

func (*Context) GetStats

func (c *Context) GetStats(since time.Duration) ([]map[string]string, error)

func (*Context) StartAutoCommit

func (c *Context) StartAutoCommit() error

func (*Context) WriteBanApplication

func (c *Context) WriteBanApplication(ban types.BanApplication) error

we simply append the event to the transaction

func (*Context) WriteSignal

func (c *Context) WriteSignal(sig types.SignalOccurence) error