pipeline

Documentation

Index

• type DebugConfig
  • func AllDebugLevel() *DebugConfig
• type FetchInputsPallet
• type Pipeline
  • func NewPipeline(tg *tangle.Tangle, debugConfig ...*DebugConfig) *Pipeline
  • func (pi *Pipeline) Start()
  • func (pi *Pipeline) Stop()
  • func (pi *Pipeline) TerminalConsumer() *consumer.Consumer[*TerminalPallet]
  • func (pi *Pipeline) TerminateDrop(txid *ledger.TransactionID, reasonFormat string, args ...interface{})
  • func (pi *Pipeline) TerminateSuccess(txid *ledger.TransactionID)
  • func (pi *Pipeline) TransactionIn(txBytes []byte, fromStorage ...bool)
• type PipelineInputPallet
• type PullInputsPallet
• type SolidifyPallet
• type SolidityCheckPallet
• type TerminalPallet

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
}