Documentation ¶
Index ¶
- func CreateSignedDeliverNewestEnv(ch string, signer *basic.CryptoImpl) (*common.Envelope, error)
- type AddressedBlock
- type BlockCollector
- type CommitObserver
- type EndorseObserver
- type Observer
- type ObserverFactory
- func (of *ObserverFactory) CreateCommitObserverWorkers() ([]infra.Worker, infra.ObserverWorker, error)
- func (of *ObserverFactory) CreateEndorsementObserverWorkers() ([]infra.Worker, infra.ObserverWorker, error)
- func (of *ObserverFactory) CreateFullProcessObserverWorkers() ([]infra.Worker, infra.ObserverWorker, error)
- func (of *ObserverFactory) CreateObserverWorkers(mode int) ([]infra.Worker, infra.ObserverWorker, error)
- type Observers
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AddressedBlock ¶
type AddressedBlock struct { *peer.FilteredBlock Address int // source peer's number Now time.Duration }
AddressedBlock describe the source of block
type BlockCollector ¶
BlockCollector keeps track of committed blocks on multiple peers. This is used when a block is considered confirmed only when committed on a certain number of peers within network.
func NewBlockCollector ¶
func NewBlockCollector(threshold int, totalP int, ctx context.Context, blockCh chan *AddressedBlock, finishCh chan struct{}, totalTx int, printResult bool, logger *log.Logger, once *sync.Once, finishflag bool) (*BlockCollector, error)
NewBlockCollector creates a BlockCollector
func (*BlockCollector) Start ¶
func (bc *BlockCollector) Start()
type CommitObserver ¶
func CreateCommitObserver ¶
func (*CommitObserver) GetTime ¶
func (o *CommitObserver) GetTime() time.Time
func (*CommitObserver) Start ¶
func (o *CommitObserver) Start()
type EndorseObserver ¶
type EndorseObserver struct { Envs chan *basic.TracingEnvelope Now time.Time // contains filtered or unexported fields }
func CreateEndorseObserver ¶
func CreateEndorseObserver(Envs chan *basic.TracingEnvelope, N int, finishCh chan struct{}, once *sync.Once, logger *log.Logger) *EndorseObserver
func (*EndorseObserver) GetTime ¶
func (o *EndorseObserver) GetTime() time.Time
func (*EndorseObserver) Start ¶
func (o *EndorseObserver) Start()
type Observer ¶
type Observer struct { Address string // contains filtered or unexported fields }
func CreateObserver ¶
type ObserverFactory ¶
type ObserverFactory struct {
// contains filtered or unexported fields
}
func NewObserverFactory ¶
func NewObserverFactory(config basic.Config, crypto infra.Crypto, blockCh chan *AddressedBlock, logger *log.Logger, ctx context.Context, finishCh chan struct{}, num, parallel int, envs chan *basic.TracingEnvelope, errorCh chan error) *ObserverFactory
func (*ObserverFactory) CreateCommitObserverWorkers ¶
func (of *ObserverFactory) CreateCommitObserverWorkers() ([]infra.Worker, infra.ObserverWorker, error)
3
func (*ObserverFactory) CreateEndorsementObserverWorkers ¶
func (of *ObserverFactory) CreateEndorsementObserverWorkers() ([]infra.Worker, infra.ObserverWorker, error)
4
func (*ObserverFactory) CreateFullProcessObserverWorkers ¶
func (of *ObserverFactory) CreateFullProcessObserverWorkers() ([]infra.Worker, infra.ObserverWorker, error)
6
func (*ObserverFactory) CreateObserverWorkers ¶
func (of *ObserverFactory) CreateObserverWorkers(mode int) ([]infra.Worker, infra.ObserverWorker, error)
type Observers ¶
type Observers struct {
// contains filtered or unexported fields
}
func CreateObservers ¶
Click to show internal directories.
Click to hide internal directories.