Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBInterface ¶
type MockDBInterface ¶
func (*MockDBInterface) Close ¶
func (m *MockDBInterface) Close() error
func (*MockDBInterface) Exec ¶
func (m *MockDBInterface) Exec(query string, args ...interface{}) (sql.Result, error)
func (*MockDBInterface) Ping ¶
func (m *MockDBInterface) Ping() error
type MockResultInterface ¶
func (*MockResultInterface) LastInsertId ¶
func (m *MockResultInterface) LastInsertId() (int64, error)
func (*MockResultInterface) RowsAffected ¶
func (m *MockResultInterface) RowsAffected() (int64, error)
type Plugin ¶
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 ¶
type Postgres struct {
DB DBInterface
}
func (*Postgres) Init ¶
func (p *Postgres) Init(db DBInterface)
type PostgresRecv ¶
type PostgresRecv struct { *Postgres Options *Options BufferSize int MessageBuffer chan *cypress.Message }
func NewPostgresRecv ¶
func NewPostgresRecv(postgres *Postgres, options *Options, bufferSize int) (*PostgresRecv, error)
func (*PostgresRecv) BufferMessages ¶
func (pr *PostgresRecv) BufferMessages(messages []*cypress.Message) error
func (*PostgresRecv) BuildStmt ¶
func (pr *PostgresRecv) BuildStmt(o *Options) string
func (*PostgresRecv) Close ¶
func (pr *PostgresRecv) Close() error
type Recv ¶
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 ¶
type Send ¶
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."` }
Click to show internal directories.
Click to hide internal directories.