database

Documentation

Index

• type Context
  • func NewDatabase(cfg map[string]string) (*Context, error)
  • func (c *Context) CleanUpRecordsByAge() (int, error)
  • func (c *Context) CleanUpRecordsByCount() (int, error)
  • func (c *Context) DeleteAll() error
  • func (c *Context) DeleteBan(target string) (int, error)
  • func (c *Context) DeleteExpired() (int, error)
  • func (c *Context) Flush() error
  • func (c *Context) GetBansAt(at time.Time) ([]map[string]string, error)
  • func (c *Context) GetDeletedBanSince(since time.Time) ([]types.BanApplication, error)
  • func (c *Context) GetNewBan() ([]types.BanApplication, error)
  • func (c *Context) GetNewBanSince(since time.Time) ([]types.BanApplication, 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 database

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

func NewDatabase

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

func (*Context) CleanUpRecordsByAge

func (c *Context) CleanUpRecordsByAge() (int, error)

func (*Context) CleanUpRecordsByCount

func (c *Context) CleanUpRecordsByCount() (int, 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() (int, error)

func (*Context) Flush

func (c *Context) Flush() error

Flush doesn't do anything here : we are not using transactions or such, nothing to "flush" per se

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) GetDeletedBanSince

func (c *Context) GetDeletedBanSince(since time.Time) ([]types.BanApplication, error)

func (*Context) GetNewBan

func (c *Context) GetNewBan() ([]types.BanApplication, error)

func (*Context) GetNewBanSince

func (c *Context) GetNewBanSince(since time.Time) ([]types.BanApplication, 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