deliver

Documentation

Index

• func FromTxID(qscc GetBlockerInfo, txID string) func(*subscribeEventOption) error
• func WithDefaultSeek(seekOpts ...api.EventCCSeekOption) func(*subscribeEventOption) error
• func WithGetBlockByTx(seekOpts ...api.EventCCSeekOption) func(*subscribeEventOption)
• type Deliver
  • func New(deliverClient peer.DeliverClient, identity msp.SigningIdentity, ...) *Deliver
  • func (d *Deliver) SubscribeBlock(ctx context.Context, channelName string, seekOpt ...api.EventCCSeekOption) (api.BlockSubscription, error)
  • func (d *Deliver) SubscribeCC(ctx context.Context, channelName string, ccName string, ...) (api.EventCCSubscription, error)
  • func (d *Deliver) SubscribeEvents(ctx context.Context, channelName string, ccName string, ...) (api.EventCCSubscription, error)
  • func (d *Deliver) SubscribeTx(ctx context.Context, channelName string, txID string, ...) (api.TxSubscription, error)
• type GetBlockerInfo
• type SeekOptConverter
  • func NewSeekOptConverter(channelInfo api.ChannelInfo, logger *zap.Logger) *SeekOptConverter
  • func (so *SeekOptConverter) ByBlockRange(ctx context.Context, channel string, blockRange ...int64) (api.EventCCSeekOption, error)
  • func (so *SeekOptConverter) ChannelHeight(ctx context.Context, channel string) (uint64, error)

Functions

func FromTxID

func FromTxID(qscc GetBlockerInfo, txID string) func(*subscribeEventOption) error

func WithDefaultSeek

func WithDefaultSeek(seekOpts ...api.EventCCSeekOption) func(*subscribeEventOption) error

WithDefaultSeek need if fromTxID is empty

func WithGetBlockByTx

func WithGetBlockByTx(seekOpts ...api.EventCCSeekOption) func(*subscribeEventOption)

Types

type Deliver

type Deliver struct {
	Client   peer.DeliverClient
	Identity msp.SigningIdentity
	// TlsCertHash used when creating seek envelope with enabled tls
	TLSCertHash []byte
}

func New

func New(deliverClient peer.DeliverClient, identity msp.SigningIdentity, tlsCertHash []byte) *Deliver

func (*Deliver) SubscribeBlock

func (d *Deliver) SubscribeBlock(ctx context.Context, channelName string, seekOpt ...api.EventCCSeekOption) (api.BlockSubscription, error)

func (*Deliver) SubscribeCC

func (d *Deliver) SubscribeCC(ctx context.Context, channelName string, ccName string, seekOpt ...api.EventCCSeekOption) (api.EventCCSubscription, error)

func (*Deliver) SubscribeEvents

func (d *Deliver) SubscribeEvents(ctx context.Context, channelName string, ccName string, setOpts ...func(*subscribeEventOption) error) (api.EventCCSubscription, error)

SubscribeEvents it is just once helper for save to api version today

func (*Deliver) SubscribeTx

func (d *Deliver) SubscribeTx(ctx context.Context, channelName string, txID string, seekOpt ...api.EventCCSeekOption) (api.TxSubscription, error)

type GetBlockerInfo

type GetBlockerInfo interface {
	GetBlockByTxID(ctx context.Context, channelName string, txID string) (*common.Block, error)
}

type SeekOptConverter

type SeekOptConverter struct {
	GetChannelHeight func(ctx context.Context, channel string) (uint64, error)

	Logger *zap.Logger
	// contains filtered or unexported fields
}

func NewSeekOptConverter

func NewSeekOptConverter(channelInfo api.ChannelInfo, logger *zap.Logger) *SeekOptConverter

func (*SeekOptConverter) ByBlockRange

func (so *SeekOptConverter) ByBlockRange(ctx context.Context, channel string, blockRange ...int64) (api.EventCCSeekOption, error)

func (*SeekOptConverter) ChannelHeight

func (so *SeekOptConverter) ChannelHeight(ctx context.Context, channel string) (uint64, error)