beater

Documentation

Index

• func New(b *beat.Beat, cfg *libbeatCommon.Config) (beat.Beater, error)
• type Fabricbeat
  • func (bt *Fabricbeat) ProcessNewBlocks(b *beat.Beat, ledgerClient *ledger.Client, index int) error
  • func (bt *Fabricbeat) Run(b *beat.Beat) error
  • func (bt *Fabricbeat) Stop()

Functions

func New

func New(b *beat.Beat, cfg *libbeatCommon.Config) (beat.Beater, error)

New creates an instance of fabricbeat.

Types

type Fabricbeat

type Fabricbeat struct {
	Fsetup *fabricsetup.FabricSetup
	// contains filtered or unexported fields
}

Fabricbeat configuration.

func (*Fabricbeat) ProcessNewBlocks

func (bt *Fabricbeat) ProcessNewBlocks(b *beat.Beat, ledgerClient *ledger.Client, index int) error

Gets the blocks from the ledger and sends their data to Elasticsearch.

func (*Fabricbeat) Run

func (bt *Fabricbeat) Run(b *beat.Beat) error

Run starts fabricbeat.

func (*Fabricbeat) Stop

func (bt *Fabricbeat) Stop()

Stop stops fabricbeat.