subs

Mar 4, 2022

Changes in this version

+ type ChaincodeEventWithBlock struct

+ func (eb *ChaincodeEventWithBlock) Block() uint64

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

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

type EventSubscription

+ func (e *EventSubscription) EventsExtended() ...

Sep 6, 2019

Changes in this version

type ErrorCloser

+ Done func() <-chan struct{}

+ type ReadyForHandling func()

Apr 5, 2019

Changes in this version

+ type BlockHandler func(block *common.Block) bool

+ type BlockSubscription struct

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

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

+ func (b *BlockSubscription) Serve(base ErrorCloser) *BlockSubscription

+ type ErrorCloser interface

+ Close func() error

+ Err func() <-chan error

+ Errors func() chan error

+ type EventSubscription struct

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

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

+ func (e *EventSubscription) Serve(base ErrorCloser) *EventSubscription

+ type TxSubscription struct

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

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

+ func (ts *TxSubscription) Serve(sub ErrorCloser) *TxSubscription

Mar 1, 2019

Changes in this version

+ func NewBlockSubscription(ctx context.Context, channelName string, identity msp.SigningIdentity, ...) (api.BlockSubscription, error)

+ func NewEventSubscription(ctx context.Context, ccname string, blockChan chan *common.Block, ...) api.EventCCSubscription

+ func NewTxSubscription(ctx context.Context, txId api.ChaincodeTx, blockChan chan *common.Block, ...) api.TxSubscription