hubble

Documentation

Index

• func NewStatePipelineSession(esUrl, esIndex string) (*ingest.SingleLedgerSession, error)
• type ESProcessor
  • func (p *ESProcessor) Name() string
  • func (p *ESProcessor) ProcessState(ctx context.Context, store *supportPipeline.Store, r io.StateReader, ...) error
  • func (p *ESProcessor) PutEntry(ctx context.Context, entry string, id int) error
  • func (p *ESProcessor) Reset()

Functions

func NewStatePipelineSession

func NewStatePipelineSession(esUrl, esIndex string) (*ingest.SingleLedgerSession, error)

NewStatePipelineSession runs a single ledger session.

Types

type ESProcessor

type ESProcessor struct {
	// contains filtered or unexported fields
}

ESProcessor serializes ledger change entries as JSONs and writes them to an ElasticSearch cluster.

func (*ESProcessor) Name

func (p *ESProcessor) Name() string

Name returns the processor name.

func (*ESProcessor) ProcessState

func (p *ESProcessor) ProcessState(ctx context.Context, store *supportPipeline.Store, r io.StateReader, w io.StateWriter) error

ProcessState reads, prints, and writes changes to ledger state to ElasticSearch.

func (*ESProcessor) PutEntry

func (p *ESProcessor) PutEntry(ctx context.Context, entry string, id int) error

PutEntry puts a ledger entry in ElasticSearch.

func (*ESProcessor) Reset

func (p *ESProcessor) Reset()

Reset is a no-op for this processor.