transact

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)

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)