chcollector

Documentation

Index

• type ChCollector
  • func NewCollector(ctx context.Context, parser ChDataParser, dataReady chan<- struct{}, ...) (*ChCollector, error)
  • func (cc *ChCollector) Close()
  • func (cc *ChCollector) GetData() <-chan *collectordto.BlockData
  • func (cc *ChCollector) RaiseReadySignal()
• type ChDataParser

Types

type ChCollector

type ChCollector struct {
	Log       glog.Logger
	Metrics   metrics.Metrics
	Events    <-chan *fab.BlockEvent
	DataReady chan<- struct{}
	OutData   chan *collectordto.BlockData
	Parser    ChDataParser
	Cancel    context.CancelFunc
	WgLoop    *sync.WaitGroup
}

func NewCollector

func NewCollector(ctx context.Context,
	parser ChDataParser,
	dataReady chan<- struct{},
	events <-chan *fab.BlockEvent,
	bufSize uint,
) (*ChCollector, error)

func (*ChCollector) Close

func (cc *ChCollector) Close()

func (*ChCollector) GetData

func (cc *ChCollector) GetData() <-chan *collectordto.BlockData

func (*ChCollector) RaiseReadySignal

func (cc *ChCollector) RaiseReadySignal()

type ChDataParser

type ChDataParser interface {
	ExtractData(block *common.Block) (*collectordto.BlockData, error)
}