event

Documentation

Index

• Variables
• type BlockEventer
  • func NewBlockEventer(eventer Eventer, continueFcns ...ContinueFcn) BlockEventer
  • func NewSimpleBlockEventer(eventer Eventer) BlockEventer
• type ContinueFcn
  • func ContinueBuilder(continueFcns ...ContinueFcn) ContinueFcn
• type DeliverResponseType
• type Eventer
  • func NewEventer(ctx context.Context, connect *grpc.ClientConn) Eventer
  • func (eventer Eventer) SendRecv(seek *common.Envelope) (interface{}, []DeliverResponseType)
• type SeekInfo
  • func SeekInfoFrom(start, stop *orderer.SeekPosition) *SeekInfo
  • func (seekInfo *SeekInfo) Fetch() *SeekInfo
  • func (seekInfo SeekInfo) SignBy(channel string, signer protoutil.Signer) *common.Envelope
  • func (seekInfo *SeekInfo) WaitUtilReady() *SeekInfo
• type TransactionListener
  • func (TransactionListener) GetSeekInfo() SeekInfo
  • func (t *TransactionListener) WaitForTx(txid string)

Variables

var SeekMax = &orderer.SeekPosition{
	Type: &orderer.SeekPosition_Specified{
		Specified: &orderer.SeekSpecified{
			Number: math.MaxUint64,
		},
	},
}

var SeekNewest = &orderer.SeekPosition{
	Type: &orderer.SeekPosition_Newest{
		Newest: &orderer.SeekNewest{},
	},
}

var SeekOldest = &orderer.SeekPosition{
	Type: &orderer.SeekPosition_Oldest{
		Oldest: &orderer.SeekOldest{},
	},
}

Types

type BlockEventer

type BlockEventer struct {
	Eventer
}

func NewBlockEventer

func NewBlockEventer(eventer Eventer, continueFcns ...ContinueFcn) BlockEventer

func NewSimpleBlockEventer

func NewSimpleBlockEventer(eventer Eventer) BlockEventer

type ContinueFcn

type ContinueFcn func(currentDeliverResponse DeliverResponseType, deliverResponses []DeliverResponseType) (bool, interface{})

func ContinueBuilder

func ContinueBuilder(continueFcns ...ContinueFcn) ContinueFcn

type DeliverResponseType

type DeliverResponseType struct {
	*common.Status                                          // from peer.DeliverResponse_Status
	*common.Block                                           // from peer.DeliverResponse_Block or peer.DeliverResponse_BlockAndPrivateData
	*peer.FilteredBlock                                     // from peer.DeliverResponse_FilteredBlock
	PrivateDataMap      map[uint64]*rwset.TxPvtReadWriteSet // from peer.DeliverResponse_BlockAndPrivateData
}

type Eventer

type Eventer struct {
	peer.DeliverClient
	peer.Deliver_DeliverClient
	context.Context
	Continue ContinueFcn
}

func NewEventer

func NewEventer(ctx context.Context, connect *grpc.ClientConn) Eventer

func (Eventer) SendRecv

func (eventer Eventer) SendRecv(seek *common.Envelope) (interface{}, []DeliverResponseType)

type SeekInfo

type SeekInfo struct {
	*orderer.SeekInfo
}

func SeekInfoFrom

func SeekInfoFrom(start, stop *orderer.SeekPosition) *SeekInfo

func (*SeekInfo) Fetch

func (seekInfo *SeekInfo) Fetch() *SeekInfo

Fetch will only get current existing blocks. Commonly used for: get genesis block, query block content

func (SeekInfo) SignBy

func (seekInfo SeekInfo) SignBy(channel string, signer protoutil.Signer) *common.Envelope

func (*SeekInfo) WaitUtilReady

func (seekInfo *SeekInfo) WaitUtilReady() *SeekInfo

WaitUtilReady will wait for future block Commonly used for: Wait for next block, confirming tx finality

type TransactionListener

type TransactionListener struct {
	BlockEventer
}

func (TransactionListener) GetSeekInfo

func (TransactionListener) GetSeekInfo() SeekInfo

func (*TransactionListener) WaitForTx

func (t *TransactionListener) WaitForTx(txid string)