txn_service

Documentation

Index

• type FileTransactionLogger
  • func NewFileTransactionLogger(filePath string) (*FileTransactionLogger, error)
  • func (l *FileTransactionLogger) Close()
  • func (l *FileTransactionLogger) HandleTransactions() <-chan error
  • func (l *FileTransactionLogger) ReadTransactions() (<-chan *apitypes.Transaction, <-chan error)
  • func (l *FileTransactionLogger) WriteTransaction(*apitypes.Transaction)
• type PostgresTransactionLogger
  • func NewPostgresTransactionLogger(postgresUrl string) (*PostgresTransactionLogger, error)
  • func (l *PostgresTransactionLogger) Close()
  • func (l *PostgresTransactionLogger) HandleTransactions() <-chan error
  • func (l *PostgresTransactionLogger) ReadTransactions() (<-chan *apitypes.Transaction, <-chan error)
  • func (l *PostgresTransactionLogger) WriteTransaction(transact *apitypes.Transaction)
• type TransactionLogger
• type TransactionService
  • func NewTransactionService(logger TransactionLogger, allowUnauthorized bool) *TransactionService

Types

type FileTransactionLogger

type FileTransactionLogger struct {
}

func NewFileTransactionLogger

func NewFileTransactionLogger(filePath string) (*FileTransactionLogger, error)

func (*FileTransactionLogger) Close

func (l *FileTransactionLogger) Close()

func (*FileTransactionLogger) HandleTransactions

func (l *FileTransactionLogger) HandleTransactions() <-chan error

func (*FileTransactionLogger) ReadTransactions

func (l *FileTransactionLogger) ReadTransactions() (<-chan *apitypes.Transaction, <-chan error)

func (*FileTransactionLogger) WriteTransaction

func (l *FileTransactionLogger) WriteTransaction(*apitypes.Transaction)

type PostgresTransactionLogger

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

func NewPostgresTransactionLogger

func NewPostgresTransactionLogger(postgresUrl string) (*PostgresTransactionLogger, error)

func (*PostgresTransactionLogger) Close

func (l *PostgresTransactionLogger) Close()

func (*PostgresTransactionLogger) HandleTransactions

func (l *PostgresTransactionLogger) HandleTransactions() <-chan error

func (*PostgresTransactionLogger) ReadTransactions

func (l *PostgresTransactionLogger) ReadTransactions() (<-chan *apitypes.Transaction, <-chan error)

func (*PostgresTransactionLogger) WriteTransaction

func (l *PostgresTransactionLogger) WriteTransaction(transact *apitypes.Transaction)

type TransactionLogger

type TransactionLogger interface {
	ReadTransactions() (<-chan *apitypes.Transaction, <-chan error)
	WriteTransaction(*apitypes.Transaction)
	HandleTransactions() <-chan error
	Close()
}

type TransactionService

type TransactionService struct {
	TransactionLogger
	AllowUnauthorized bool
}

func NewTransactionService

func NewTransactionService(logger TransactionLogger, allowUnauthorized bool) *TransactionService