db

type Capture struct {
	ID         string // the capture_id that together with the table makes it unique
	Timestamp  time.Time
	Origin     int // origin as
	Advertised []*net.IPNet
	Withdrawn  []*net.IPNet
	ASPath     []int
	ColIP      net.IP
	PeerIP     net.IP
	NextHop    net.IP
	// contains filtered or unexported fields
}

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

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

type CommonMessage interface {
	// This table holds the names of all other tables created.
	GetMainTable() string

	// This holds all info on the collectors.
	GetNodeTable() string

	// This holds info on customers or anyone interested in the stored
	// BGP data.
	GetEntityTable() string

	SetMainTable(string)
	SetNodeTable(string)
	SetEntityTable(string)
}

type CommonReply interface {
	Error() error
}

type DBer interface {
	DB() *sql.DB
}

type Entity struct {
	Name          string
	Email         string
	OwnedOrigins  []int
	OwnedPrefixes []*net.IPNet
}

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

type FilterOptions interface{}

type ReadStream interface {
	Read() bool

	// Data returns an interface so each implementation of a read stream is free to choose
	// what type it returns. This should be constant for each stream, and should be documented.
	Data() interface{}
	Bytes() []byte
	Err() error
	Close()
}

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

type SessionExecutor struct {
	util.SQLExecutor
	// contains filtered or unexported fields
}

type SessionType int

type TimeoutDBer interface {
	DBer
	util.GetTimeouter
}

type WriteStream interface {
	Write(interface{}) error
	Flush() error
	Cancel()
	Close()
}