pipelines

Documentation

Index

• type SignedMessagePipeline
  • func Combine(pipelines ...SignedMessagePipeline) SignedMessagePipeline
  • func CombineQuiet(quiet SignedMessagePipeline, pipeline SignedMessagePipeline) SignedMessagePipeline
  • func WrapFunc(name string, fn func(signedMessage *specqbft.SignedMessage) error) SignedMessagePipeline

Types

type SignedMessagePipeline

type SignedMessagePipeline interface {
	// Run runs the pipeline
	Run(signedMessage *specqbft.SignedMessage) error
	Name() string
}

SignedMessagePipeline represents the behavior of round pipeline

func Combine

func Combine(pipelines ...SignedMessagePipeline) SignedMessagePipeline

Combine is the constructor of pipelinesCombination

func CombineQuiet

func CombineQuiet(quiet SignedMessagePipeline, pipeline SignedMessagePipeline) SignedMessagePipeline

CombineQuiet runs quiet and afterwards pipeline if not error returned. if quiet returns an error it will be ignored

func WrapFunc

func WrapFunc(name string, fn func(signedMessage *specqbft.SignedMessage) error) SignedMessagePipeline

WrapFunc represents the given function as a pipeline implementor