Documentation
¶
Index ¶
- func AddBlock(block *types.Block)
- func BroadCastBlock(block *types.Block)
- func ConsensusProducedBlock(block *types.Block)
- func GetAllPendingTrx() []*types.Transaction
- func NewProducerActor(env *env.ActorEnv) *actor.PID
- func SetChainActorPid(tpid *actor.PID)
- func SetConsensusActorPid(tpid *actor.PID)
- func SetNetActorPid(tpid *actor.PID)
- func SetTrxPoolActorPid(tpid *actor.PID)
- type ProducerActor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConsensusProducedBlock ¶
ConsensusProducedBlock is to consensus produced blocks
func GetAllPendingTrx ¶
func GetAllPendingTrx() []*types.Transaction
GetAllPendingTrx is to retrieve the pending transactions
func NewProducerActor ¶
NewProducerActor is to create actor for producer
func SetChainActorPid ¶
SetChainActorPid is to set chain actor PID for use
func SetConsensusActorPid ¶
SetConsensusActorPid is to set consensus actor PID for use
func SetTrxPoolActorPid ¶
SetTrxPoolActorPid is to set transaction actor PID for use
Types ¶
type ProducerActor ¶
type ProducerActor struct {
// contains filtered or unexported fields
}
ProducerActor is to define actor for producer
func (*ProducerActor) Receive ¶
func (p *ProducerActor) Receive(context actor.Context)
Receive is to receive and handle message
Source Files
Click to show internal directories.
Click to hide internal directories.