chainservice

package
v1.8.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 11, 2022 License: Apache-2.0 Imports: 37 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIServer added in v1.6.3 

type APIServer interface {
	GetActions(ctx context.Context, in *iotexapi.GetActionsRequest) (*iotexapi.GetActionsResponse, error)
	GetReceiptByAction(ctx context.Context, in *iotexapi.GetReceiptByActionRequest) (*iotexapi.GetReceiptByActionResponse, error)
}

APIServer defines the interface of core service of the server

type Builder added in v1.8.0 

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

Builder is a builder to build chainservice

func NewBuilder added in v1.8.0 

func NewBuilder(cfg config.Config) *Builder

NewBuilder creates a new chainservice builder

func (*Builder) Build added in v1.8.0 

func (builder *Builder) Build() (*ChainService, error)

Build builds a chainservice

func (*Builder) BuildForSubChain added in v1.8.0 

func (builder *Builder) BuildForSubChain() (*ChainService, error)

BuildForSubChain builds a chainservice for subchain

func (*Builder) BuildForTest added in v1.8.0 

func (builder *Builder) BuildForTest() (*ChainService, error)

BuildForTest builds a chainservice for test purpose

func (*Builder) SetActionPool added in v1.8.0 

func (builder *Builder) SetActionPool(ap actpool.ActPool) *Builder

SetActionPool sets the action pool instance

func (*Builder) SetBlockDAO added in v1.8.0 

func (builder *Builder) SetBlockDAO(bd blockdao.BlockDAO) *Builder

SetBlockDAO sets the blockdao instance

func (*Builder) SetBlockSync added in v1.8.0 

func (builder *Builder) SetBlockSync(bs blocksync.BlockSync) *Builder

SetBlockSync sets the block sync instance

func (*Builder) SetBlockchain added in v1.8.0 

func (builder *Builder) SetBlockchain(bc blockchain.Blockchain) *Builder

SetBlockchain sets the blockchain instance

func (*Builder) SetElectionCommittee added in v1.8.0 

func (builder *Builder) SetElectionCommittee(c committee.Committee) *Builder

SetElectionCommittee sets the election committee instance

func (*Builder) SetFactory added in v1.8.0 

func (builder *Builder) SetFactory(f factory.Factory) *Builder

SetFactory sets the factory instance

func (*Builder) SetP2PAgent added in v1.8.0 

func (builder *Builder) SetP2PAgent(agent p2p.Agent) *Builder

SetP2PAgent sets the P2PAgent instance

type ChainService 

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

ChainService is a blockchain service with all blockchain components.

func (*ChainService) APIServer added in v0.11.0 

func (cs *ChainService) APIServer() APIServer

APIServer returns the API server

func (*ChainService) ActionPool 

func (cs *ChainService) ActionPool() actpool.ActPool

ActionPool returns the Action pool

func (*ChainService) BlockDAO added in v0.11.0 

func (cs *ChainService) BlockDAO() blockdao.BlockDAO

BlockDAO returns the blockdao

func (*ChainService) BlockSync 

func (cs *ChainService) BlockSync() blocksync.BlockSync

BlockSync returns the block syncer

func (*ChainService) Blockchain 

func (cs *ChainService) Blockchain() blockchain.Blockchain

Blockchain returns the Blockchain

func (*ChainService) ChainID 

func (cs *ChainService) ChainID() uint32

ChainID returns ChainID.

func (*ChainService) Consensus 

func (cs *ChainService) Consensus() consensus.Consensus

Consensus returns the consensus instance

func (*ChainService) HandleAction 

func (cs *ChainService) HandleAction(ctx context.Context, actPb *iotextypes.Action) error

HandleAction handles incoming action request.

func (*ChainService) HandleBlock 

func (cs *ChainService) HandleBlock(ctx context.Context, peer string, pbBlock *iotextypes.Block) error

HandleBlock handles incoming block request.

func (*ChainService) HandleConsensusMsg added in v0.4.4 

func (cs *ChainService) HandleConsensusMsg(msg *iotextypes.ConsensusMessage) error

HandleConsensusMsg handles incoming consensus message.

func (*ChainService) HandleSyncRequest 

func (cs *ChainService) HandleSyncRequest(ctx context.Context, peer peer.AddrInfo, sync *iotexrpc.BlockSync) error

HandleSyncRequest handles incoming sync request.

func (*ChainService) Registry added in v0.5.0 

func (cs *ChainService) Registry() *protocol.Registry

Registry returns a pointer to the registry

func (*ChainService) ReportFullness added in v1.2.0 

func (cs *ChainService) ReportFullness(_ context.Context, _ iotexrpc.MessageType, fullness float32)

ReportFullness switch on or off block sync

func (*ChainService) Start 

func (cs *ChainService) Start(ctx context.Context) error

Start starts the server

func (*ChainService) StateFactory added in v0.11.0 

func (cs *ChainService) StateFactory() factory.Factory

StateFactory returns the state factory

func (*ChainService) Stop 

func (cs *ChainService) Stop(ctx context.Context) error

Stop stops the server

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.