pipeline

package
v0.0.0-...-1c999d7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DebugConfig

type DebugConfig struct {
	Input           zapcore.Level
	Prevalid        zapcore.Level
	SolidityChecker zapcore.Level
	Solidify        zapcore.Level
	PullInputs      zapcore.Level
	FetchInputs     zapcore.Level
	Terminal        zapcore.Level
}

func AllDebugLevel

func AllDebugLevel() *DebugConfig

type FetchInputsPallet

type FetchInputsPallet struct {
	*SolidityCheckPallet
	// contains filtered or unexported fields
}

type Pipeline

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

func NewPipeline

func NewPipeline(tg *tangle.Tangle, debugConfig ...*DebugConfig) *Pipeline

func (*Pipeline) Start

func (pi *Pipeline) Start()

func (*Pipeline) Stop

func (pi *Pipeline) Stop()

func (*Pipeline) TerminalConsumer

func (pi *Pipeline) TerminalConsumer() *consumer.Consumer[*TerminalPallet]

func (*Pipeline) TerminateDrop

func (pi *Pipeline) TerminateDrop(txid *ledger.TransactionID, reasonFormat string, args ...interface{})

func (*Pipeline) TerminateSuccess

func (pi *Pipeline) TerminateSuccess(txid *ledger.TransactionID)

func (*Pipeline) TransactionIn

func (pi *Pipeline) TransactionIn(txBytes []byte, fromStorage ...bool)

type PipelineInputPallet

type PipelineInputPallet struct {
	WhenReceived         time.Time
	TxBytes              []byte
	TxID                 ledger.TransactionID
	CertainlyFromStorage bool
}

type PullInputsPallet

type PullInputsPallet struct {
	*SolidifyPallet
}

type SolidifyPallet

type SolidifyPallet struct {

	// used if newTx is == nil
	*SolidityCheckPallet
	// contains filtered or unexported fields
}

type SolidityCheckPallet

type SolidityCheckPallet struct {
	*PipelineInputPallet
	Tx *state.Transaction
}

type TerminalPallet

type TerminalPallet struct {
	TxID    *ledger.TransactionID
	Dropped bool
	Reason  string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL