logger

Documentation

Index

• type Logger
  • func NewLogger(logDir string, logBlocks bool, logTransactions bool, logBalanceChanges bool, ...) *Logger
  • func (l *Logger) AddBlockStream(ctx context.Context, block *types.Block) error
  • func (l *Logger) BalanceStream(ctx context.Context, balanceChanges []*parser.BalanceChange) error
  • func (l *Logger) ReconcileFailureStream(ctx context.Context, reconciliationType string, ...) error
  • func (l *Logger) ReconcileSuccessStream(ctx context.Context, reconciliationType string, ...) error
  • func (l *Logger) RemoveBlockStream(ctx context.Context, block *types.BlockIdentifier) error
  • func (l *Logger) TransactionStream(ctx context.Context, block *types.Block) error

Types

type Logger

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

Logger contains all logic to record validator output and benchmark a Rosetta Server.

func NewLogger

func NewLogger(
	logDir string,
	logBlocks bool,
	logTransactions bool,
	logBalanceChanges bool,
	logReconciliation bool,
) *Logger

NewLogger constructs a new Logger.

func (*Logger) AddBlockStream

func (l *Logger) AddBlockStream(
	ctx context.Context,
	block *types.Block,
) error

AddBlockStream writes the next processed block to the end of the blockStreamFile output file.

func (*Logger) BalanceStream

func (l *Logger) BalanceStream(
	ctx context.Context,
	balanceChanges []*parser.BalanceChange,
) error

BalanceStream writes a slice of storage.BalanceChanges to the balanceStreamFile.

func (*Logger) ReconcileFailureStream

func (l *Logger) ReconcileFailureStream(
	ctx context.Context,
	reconciliationType string,
	account *types.AccountIdentifier,
	currency *types.Currency,
	computedBalance string,
	nodeBalance string,
	block *types.BlockIdentifier,
) error

ReconcileFailureStream logs all reconciliation checks performed during syncing.

func (*Logger) ReconcileSuccessStream

func (l *Logger) ReconcileSuccessStream(
	ctx context.Context,
	reconciliationType string,
	account *types.AccountIdentifier,
	currency *types.Currency,
	balance string,
	block *types.BlockIdentifier,
) error

ReconcileSuccessStream logs all reconciliation checks performed during syncing.

func (*Logger) RemoveBlockStream

func (l *Logger) RemoveBlockStream(
	ctx context.Context,
	block *types.BlockIdentifier,
) error

RemoveBlockStream writes the next processed block to the end of the blockStreamFile output file.

func (*Logger) TransactionStream

func (l *Logger) TransactionStream(
	ctx context.Context,
	block *types.Block,
) error

TransactionStream writes the next processed block's transactions to the end of the transactionStreamFile.