postgres

type DBInterface interface {
	Ping() error
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	Close() error
}

type MockDBInterface struct {
	mock.Mock
}

type MockResultInterface struct {
	mock.Mock
}

type Options struct {
	Start          string
	End            string
	Version        int32
	Type           uint32
	SessionId      string
	AttributeKey   string
	AttributeValue string
	TagKey         string
	TagValue       string
	Order          string
	Limit          uint
}

type Plugin struct {
	DBName      string
	User        string
	Password    string
	Host        string
	Port        string
	SSLMode     string
	Timeout     string
	SSLCert     string
	SSLKey      string
	SSLRootCert string

	Start          string
	End            string
	Version        int32
	Type           uint32
	SessionId      string
	AttributeKey   string
	AttributeValue string
	TagKey         string
	TagValue       string
	Order          string
	Limit          uint

	BufferSize int
}

type Postgres struct {
	DB DBInterface
}

type PostgresRecv struct {
	*Postgres
	Options       *Options
	BufferSize    int
	MessageBuffer chan *cypress.Message
}

type Recv struct {
	DBName      string `long:"dbname" description:"The name of the database to connect to"`
	User        string `long:"user" description:"The user to sign in as"`
	Password    string `long:"password" description:"The user's password"`
	Host        string `` /* 126-byte string literal not displayed */
	Port        string `long:"port" description:"The port to bind to. (default is 5432)"`
	SSLMode     string `long:"sslmode" description:"Whether or not to use SSL (default is require, this is not the default for libpq)"`
	Timeout     string `long:"timeout" description:"Maximum wait for connection, in seconds. Zero or not specified means wait indefinitely."`
	SSLCert     string `long:"sslcert" description:"Cert file location. The file must contain PEM encoded data."`
	SSLKey      string `long:"sslkey" description:"Key file location. The file must contain PEM encoded data."`
	SSLRootCert string `long:"sslrootcert" description:"The location of the root certificate file. The file must contain PEM encoded data."`

	Start          string
	End            string
	Version        int32
	Type           uint32
	SessionId      string
	AttributeKey   string
	AttributeValue string
	TagKey         string
	TagValue       string
	Order          string
	Limit          uint

	BufferSize int `long:"buffersize" default:"100"`
}

type ResultInterface interface {
	LastInsertId() (int64, error)
	RowsAffected() (int64, error)
}

type Send struct {
	DBName      string `long:"dbname" description:"The name of the database to connect to"`
	User        string `long:"user" description:"The user to sign in as"`
	Password    string `long:"password" description:"The user's password"`
	Host        string `` /* 126-byte string literal not displayed */
	Port        string `long:"port" description:"The port to bind to. (default is 5432)"`
	SSLMode     string `long:"sslmode" description:"Whether or not to use SSL (default is require, this is not the default for libpq)"`
	Timeout     string `long:"timeout" description:"Maximum wait for connection, in seconds. Zero or not specified means wait indefinitely."`
	SSLCert     string `long:"sslcert" description:"Cert file location. The file must contain PEM encoded data."`
	SSLKey      string `long:"sslkey" description:"Key file location. The file must contain PEM encoded data."`
	SSLRootCert string `long:"sslrootcert" description:"The location of the root certificate file. The file must contain PEM encoded data."`
}