base

Documentation

Index

• Constants
• func Die(args ...interface{})
• func Logger() *logging.Logger
• func LoggerWithLevel(levelStr string) *logging.Logger
• type AbstractGarinDB
  • func (self *AbstractGarinDB) Close()
  • func (self *AbstractGarinDB) Open()
  • func (self *AbstractGarinDB) RecordDestination(destination *Destination)
  • func (self *AbstractGarinDB) Setup(dbType string, dbArgs string)
• type Destination
  • func NewDestination(serverName string, sourceIp string, destIp string) *Destination
  • func (self *Destination) Hash() string
  • func (self *Destination) Save(db GarinDB)
• type GarinDB
  • func NewGarinDB(dbType string, dbArgs string) GarinDB
• type MongoGarinDB
  • func (self *MongoGarinDB) Close()
  • func (self *MongoGarinDB) Open()
  • func (self *MongoGarinDB) RecordDestination(destination *Destination)
• type SQLGarinDB
  • func (self *SQLGarinDB) Close()
  • func (self *SQLGarinDB) Open()
  • func (self *SQLGarinDB) RecordDestination(destination *Destination)

Constants

const DESTINATIONS_TABLE_NAME = "destinations"

Functions

func Die

func Die(args ...interface{})

func Logger

func Logger() *logging.Logger

func LoggerWithLevel

func LoggerWithLevel(levelStr string) *logging.Logger

Types

type AbstractGarinDB

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

func (*AbstractGarinDB) Close

func (self *AbstractGarinDB) Close()

func (*AbstractGarinDB) Open

func (self *AbstractGarinDB) Open()

func (*AbstractGarinDB) RecordDestination

func (self *AbstractGarinDB) RecordDestination(destination *Destination)

func (*AbstractGarinDB) Setup

func (self *AbstractGarinDB) Setup(dbType string, dbArgs string)

type Destination

type Destination struct {
	SourceIp      string    `db:"source_ip"`
	DestinationIp string    `db:"destination_ip"`
	ServerName    string    `db:"server_name"`
	Protocol      string    `db:"protocol"`
	Timestamp     time.Time `db:"timestamp"`
}

func NewDestination

func NewDestination(serverName string, sourceIp string, destIp string) *Destination

func (*Destination) Hash

func (self *Destination) Hash() string

func (*Destination) Save

func (self *Destination) Save(db GarinDB)

type GarinDB

type GarinDB interface {
	Setup(string, string)
	Open()
	Close()
	RecordDestination(*Destination)
}

func NewGarinDB

func NewGarinDB(dbType string, dbArgs string) GarinDB

type MongoGarinDB

type MongoGarinDB struct {
	AbstractGarinDB
	Session *mgo.Session
}

func (*MongoGarinDB) Close

func (self *MongoGarinDB) Close()

func (*MongoGarinDB) Open

func (self *MongoGarinDB) Open()

func (*MongoGarinDB) RecordDestination

func (self *MongoGarinDB) RecordDestination(destination *Destination)

type SQLGarinDB

type SQLGarinDB struct {
	AbstractGarinDB
	Handle *sqlx.DB
}

func (*SQLGarinDB) Close

func (self *SQLGarinDB) Close()

func (*SQLGarinDB) Open

func (self *SQLGarinDB) Open()

func (*SQLGarinDB) RecordDestination

func (self *SQLGarinDB) RecordDestination(destination *Destination)