event

Documentation

Index

• Variables
• type BlockEventer
  • func NewBlockEventer(eventer Eventer) BlockEventer
• type ContinueFcn
• type Eventer
  • func NewEventer(ctx context.Context, connect *grpc.ClientConn) Eventer
  • func (Eventer) ContinueBuilder(next ContinueFcn) ContinueFcn
  • func (eventer Eventer) SendRecv(seek *common.Envelope) ([]interface{}, error)
  • func (e *Eventer) SetDefaultContinue()
• 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, error)
  • func (seekInfo SeekInfo) WaitUtilReady() SeekInfo
• type TransactionListener
  • func NewTransactionListener(eventer BlockEventer, txid string) TransactionListener
  • func (TransactionListener) GetSeekInfo() SeekInfo

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{},
	},
}

Types

type BlockEventer

type BlockEventer struct {
	Eventer
	peer.Deliver_DeliverWithPrivateDataClient
}

func NewBlockEventer

func NewBlockEventer(eventer Eventer) BlockEventer

type ContinueFcn

type ContinueFcn func(currentDeliverResponse interface{}, currentError error, deliverResponses []interface{}, errors []error) bool

type Eventer

type Eventer struct {
	peer.DeliverClient
	peer.Deliver_DeliverClient
	context.Context
	Continue     ContinueFcn
	ErrorReducer func(errors []error) error
}

func NewEventer

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

func (Eventer) ContinueBuilder

func (Eventer) ContinueBuilder(next ContinueFcn) ContinueFcn

func (Eventer) SendRecv

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

func (*Eventer) SetDefaultContinue

func (e *Eventer) SetDefaultContinue()

SetDefaultContinue TODO

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, error)

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
	ReceiptData string
}

func NewTransactionListener

func NewTransactionListener(eventer BlockEventer, txid string) TransactionListener

func (TransactionListener) GetSeekInfo

func (TransactionListener) GetSeekInfo() SeekInfo