subs

Documentation

Index

• 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

Functions

func NewBlockSubscription

func NewBlockSubscription(ctx context.Context, channelName string, identity msp.SigningIdentity, conn *grpc.ClientConn, log *zap.Logger, seekOpt ...api.EventCCSeekOption) (api.BlockSubscription, error)

func NewEventSubscription

func NewEventSubscription(ctx context.Context, ccname string, blockChan chan *common.Block, errChan chan error, stop context.CancelFunc, log *zap.Logger) api.EventCCSubscription

func NewTxSubscription

func NewTxSubscription(ctx context.Context, txId api.ChaincodeTx, blockChan chan *common.Block, errChan chan error, stop context.CancelFunc, log *zap.Logger) api.TxSubscription