pipeline

Documentation

Index

• type Pipeline
  • func Combine(pipelines ...Pipeline) Pipeline
  • func IfFirstTrueContinueToSecond(a, b Pipeline) Pipeline
  • func WrapFunc(name string, fn func(signedMessage *proto.SignedMessage) error) Pipeline
• type SetStage
• type SignAndBroadcast

Types

type Pipeline

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

Pipeline represents the behavior of round pipeline

func Combine

func Combine(pipelines ...Pipeline) Pipeline

Combine is the constructor of pipelinesCombination

func IfFirstTrueContinueToSecond

func IfFirstTrueContinueToSecond(a, b Pipeline) Pipeline

IfFirstTrueContinueToSecond runs pipeline a, if returns no error continues to pipeline b. otherwise returns without an error

func WrapFunc

func WrapFunc(name string, fn func(signedMessage *proto.SignedMessage) error) Pipeline

WrapFunc represents the given function as a pipeline implementor

type SetStage

type SetStage func(stage proto.RoundState)

SetStage sets the given stage

type SignAndBroadcast

type SignAndBroadcast func(msg *proto.Message) error

SignAndBroadcast is the function to sign and broadcast message