blockproposal

Documentation

Index

• type Service
  • func New(readySignal chan consensus.ProposalType, commitSigsChan chan []byte, ...) *Service
  • func (s *Service) APIs() []rpc.API
  • func (s *Service) Init()
  • func (s *Service) NotifyService(params map[string]interface{})
  • func (s *Service) Run(stopChan chan struct{}, stoppedChan chan struct{})
  • func (s *Service) SetMessageChan(messageChan chan *msg_pb.Message)
  • func (s *Service) StartService()
  • func (s *Service) StopService()

Types

type Service

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

Service is a block proposal service.

func New

func New(readySignal chan consensus.ProposalType, commitSigsChan chan []byte, waitForConsensusReady func(readySignal chan consensus.ProposalType, commitSigsChan chan []byte, stopChan chan struct{}, stoppedChan chan struct{})) *Service

New returns a block proposal service.

func (*Service) APIs

func (s *Service) APIs() []rpc.API

APIs for the services.

func (*Service) Init

func (s *Service) Init()

Init initializes block proposal service.

func (*Service) NotifyService

func (s *Service) NotifyService(params map[string]interface{})

NotifyService notify service

func (*Service) Run

func (s *Service) Run(stopChan chan struct{}, stoppedChan chan struct{})

Run runs block proposal.

func (*Service) SetMessageChan

func (s *Service) SetMessageChan(messageChan chan *msg_pb.Message)

SetMessageChan sets up message channel to service.

func (*Service) StartService

func (s *Service) StartService()

StartService starts block proposal service.

func (*Service) StopService

func (s *Service) StopService()

StopService stops block proposal service.