Documentation
¶
Index ¶
- func NewFileTransactionLogger(filename string) (core.TransactionLogger, error)
- func NewPostgresTransactionLogger(param PostgresDbParams) (core.TransactionLogger, error)
- func NewTestTransactionLogger() (core.TransactionLogger, error)
- func NewTransactionLogger(s string) (core.TransactionLogger, error)
- type FileTransactionLogger
- func (l *FileTransactionLogger) Close() error
- func (l *FileTransactionLogger) Err() <-chan error
- func (l *FileTransactionLogger) LastSequence() uint64
- func (l *FileTransactionLogger) ReadEvents() (<-chan core.Event, <-chan error)
- func (l *FileTransactionLogger) Run()
- func (l *FileTransactionLogger) Wait()
- func (l *FileTransactionLogger) WriteDelete(key string)
- func (l *FileTransactionLogger) WritePut(key, value string)
- type PostgresDbParams
- type PostgresTransactionLogger
- func (l *PostgresTransactionLogger) Close() error
- func (l *PostgresTransactionLogger) Err() <-chan error
- func (l *PostgresTransactionLogger) LastSequence() uint64
- func (l *PostgresTransactionLogger) ReadEvents() (<-chan core.Event, <-chan error)
- func (l *PostgresTransactionLogger) Run()
- func (l *PostgresTransactionLogger) Wait()
- func (l *PostgresTransactionLogger) WriteDelete(key string)
- func (l *PostgresTransactionLogger) WritePut(key, value string)
- type TestTransactionLogger
- func (l *TestTransactionLogger) Close() error
- func (l *TestTransactionLogger) Err() <-chan error
- func (l *TestTransactionLogger) LastSequence() uint64
- func (l *TestTransactionLogger) ReadEvents() (<-chan core.Event, <-chan error)
- func (l *TestTransactionLogger) Run()
- func (l *TestTransactionLogger) Wait()
- func (l *TestTransactionLogger) WriteDelete(key string)
- func (l *TestTransactionLogger) WritePut(key, value string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFileTransactionLogger ¶
func NewFileTransactionLogger(filename string) (core.TransactionLogger, error)
func NewPostgresTransactionLogger ¶
func NewPostgresTransactionLogger(param PostgresDbParams) (core.TransactionLogger, error)
func NewTestTransactionLogger ¶
func NewTestTransactionLogger() (core.TransactionLogger, error)
func NewTransactionLogger ¶
func NewTransactionLogger(s string) (core.TransactionLogger, error)
Types ¶
type FileTransactionLogger ¶
type FileTransactionLogger struct {
// contains filtered or unexported fields
}
func (*FileTransactionLogger) Close ¶
func (l *FileTransactionLogger) Close() error
func (*FileTransactionLogger) Err ¶
func (l *FileTransactionLogger) Err() <-chan error
func (*FileTransactionLogger) LastSequence ¶
func (l *FileTransactionLogger) LastSequence() uint64
func (*FileTransactionLogger) ReadEvents ¶
func (l *FileTransactionLogger) ReadEvents() (<-chan core.Event, <-chan error)
func (*FileTransactionLogger) Run ¶
func (l *FileTransactionLogger) Run()
func (*FileTransactionLogger) Wait ¶
func (l *FileTransactionLogger) Wait()
func (*FileTransactionLogger) WriteDelete ¶
func (l *FileTransactionLogger) WriteDelete(key string)
func (*FileTransactionLogger) WritePut ¶
func (l *FileTransactionLogger) WritePut(key, value string)
type PostgresDbParams ¶
type PostgresDbParams struct {
// contains filtered or unexported fields
}
type PostgresTransactionLogger ¶
type PostgresTransactionLogger struct {
// contains filtered or unexported fields
}
func (*PostgresTransactionLogger) Close ¶
func (l *PostgresTransactionLogger) Close() error
func (*PostgresTransactionLogger) Err ¶
func (l *PostgresTransactionLogger) Err() <-chan error
func (*PostgresTransactionLogger) LastSequence ¶
func (l *PostgresTransactionLogger) LastSequence() uint64
func (*PostgresTransactionLogger) ReadEvents ¶
func (l *PostgresTransactionLogger) ReadEvents() (<-chan core.Event, <-chan error)
func (*PostgresTransactionLogger) Run ¶
func (l *PostgresTransactionLogger) Run()
func (*PostgresTransactionLogger) Wait ¶
func (l *PostgresTransactionLogger) Wait()
func (*PostgresTransactionLogger) WriteDelete ¶
func (l *PostgresTransactionLogger) WriteDelete(key string)
func (*PostgresTransactionLogger) WritePut ¶
func (l *PostgresTransactionLogger) WritePut(key, value string)
type TestTransactionLogger ¶
type TestTransactionLogger struct {
// contains filtered or unexported fields
}
func (*TestTransactionLogger) Close ¶
func (l *TestTransactionLogger) Close() error
func (*TestTransactionLogger) Err ¶
func (l *TestTransactionLogger) Err() <-chan error
func (*TestTransactionLogger) LastSequence ¶
func (l *TestTransactionLogger) LastSequence() uint64
func (*TestTransactionLogger) ReadEvents ¶
func (l *TestTransactionLogger) ReadEvents() (<-chan core.Event, <-chan error)
func (*TestTransactionLogger) Run ¶
func (l *TestTransactionLogger) Run()
func (*TestTransactionLogger) Wait ¶
func (l *TestTransactionLogger) Wait()
func (*TestTransactionLogger) WriteDelete ¶
func (l *TestTransactionLogger) WriteDelete(key string)
func (*TestTransactionLogger) WritePut ¶
func (l *TestTransactionLogger) WritePut(key, value string)
Source Files
Click to show internal directories.
Click to hide internal directories.