The highest tagged major version is v2.

subs

package

v0.7.3 Latest Latest Go to latest Published: Mar 31, 2022 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BlockHandler func(block *common.Block) bool

BlockHandler when block == nil is eq EOF and signal for terminate all sub channels

type BlockSubscription struct {
	ErrorCloser
	// contains filtered or unexported fields
}

func NewBlockSubscription() *BlockSubscription

func (b *BlockSubscription) Blocks() <-chan *common.Block

func (b *BlockSubscription) Handler(block *common.Block) bool

func (b *BlockSubscription) Serve(base ErrorCloser, readyForHandling ReadyForHandling) *BlockSubscription

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

func (eb *ChaincodeEventWithBlock) Block() uint64

func (eb *ChaincodeEventWithBlock) Event() *peer.ChaincodeEvent

func (eb *ChaincodeEventWithBlock) TxTimestamp() *timestamp.Timestamp

type ErrorCloser interface {
	Done() <-chan struct{}
	Err() <-chan error
	Errors() chan error
	Close() error
}

type EventSubscription struct {
	ErrorCloser
	// contains filtered or unexported fields
}

func NewEventSubscription(cid string, fromTx api.ChaincodeTx) *EventSubscription

func (e *EventSubscription) Events() chan *peer.ChaincodeEvent

func (e *EventSubscription) EventsExtended() chan interface {
	Event() *peer.ChaincodeEvent
	Block() uint64
	TxTimestamp() *timestamp.Timestamp
}

func (e *EventSubscription) Handler(block *common.Block) bool

func (e *EventSubscription) Serve(base ErrorCloser, readyForHandling ReadyForHandling) *EventSubscription

type ReadyForHandling func()

type TxSubscription struct {
	ErrorCloser
	// contains filtered or unexported fields
}

func NewTxSubscription(txId api.ChaincodeTx) *TxSubscription

func (ts *TxSubscription) Handler(block *common.Block) bool

func (ts *TxSubscription) Result() (peer.TxValidationCode, error)

func (ts *TxSubscription) Serve(sub ErrorCloser, readyForHandling ReadyForHandling) *TxSubscription