Versions in this module Expand all Collapse all v1 v1.0.0 Mar 3, 2023 Changes in this version + type Dispatcher interface + EventCh func() (chan<- interface{}, error) + LastBlockNum func() uint64 + Start func() error + type EventProducer interface + Register func(eventch chan<- interface{}) + type Service struct + func New(dispatcher Dispatcher, opts ...options.Opt) *Service + func (p *Service) SetEventConsumerBufferSize(value uint) + func (s *Service) Dispatcher() Dispatcher + func (s *Service) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error) + func (s *Service) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error) + func (s *Service) RegisterFilteredBlockEvent() (fab.Registration, <-chan *fab.FilteredBlockEvent, error) + func (s *Service) RegisterTxStatusEvent(txID string) (fab.Registration, <-chan *fab.TxStatusEvent, error) + func (s *Service) Start() error + func (s *Service) Stop() + func (s *Service) StopAndTransfer() (fab.EventSnapshot, error) + func (s *Service) Submit(event interface{}) error + func (s *Service) Transfer() (fab.EventSnapshot, error) + func (s *Service) Unregister(reg fab.Registration)