benchmarkconsensus

Documentation

Index

• Variables
• type Config
• type Service
  • func NewBenchmarkConsensusAlgo(ctx context.Context, gossip gossiptopics.BenchmarkConsensus, ...) *Service
  • func (s *Service) HandleBenchmarkConsensusCommit(ctx context.Context, input *gossiptopics.BenchmarkConsensusCommitInput) (*gossiptopics.EmptyOutput, error)
  • func (s *Service) HandleBenchmarkConsensusCommitted(ctx context.Context, input *gossiptopics.BenchmarkConsensusCommittedInput) (*gossiptopics.EmptyOutput, error)
  • func (s *Service) HandleBlockConsensus(ctx context.Context, input *handlers.HandleBlockConsensusInput) (*handlers.HandleBlockConsensusOutput, error)

Variables

var LogTag = log.Service("consensus-algo-benchmark")

Types

type Config

type Config interface {
	NodeAddress() primitives.NodeAddress
	BenchmarkConsensusConstantLeader() primitives.NodeAddress
	ActiveConsensusAlgo() consensus.ConsensusAlgoType
	BenchmarkConsensusRetryInterval() time.Duration
	BenchmarkConsensusRequiredQuorumPercentage() uint32
}

type Service

type Service struct {
	govnr.TreeSupervisor
	// contains filtered or unexported fields
}

func NewBenchmarkConsensusAlgo

func NewBenchmarkConsensusAlgo(
	ctx context.Context,
	gossip gossiptopics.BenchmarkConsensus,
	blockStorage services.BlockStorage,
	consensusContext services.ConsensusContext,
	network []primitives.NodeAddress,
	signer signer.Signer,
	parentLogger log.Logger,
	config Config,
	metricFactory metric.Factory,
) *Service

func (*Service) HandleBenchmarkConsensusCommit

func (s *Service) HandleBenchmarkConsensusCommit(ctx context.Context, input *gossiptopics.BenchmarkConsensusCommitInput) (*gossiptopics.EmptyOutput, error)

func (*Service) HandleBenchmarkConsensusCommitted

func (s *Service) HandleBenchmarkConsensusCommitted(ctx context.Context, input *gossiptopics.BenchmarkConsensusCommittedInput) (*gossiptopics.EmptyOutput, error)

func (*Service) HandleBlockConsensus

func (s *Service) HandleBlockConsensus(ctx context.Context, input *handlers.HandleBlockConsensusInput) (*handlers.HandleBlockConsensusOutput, error)