processors

Documentation

Index

• Constants
• type ContextFilter
  • func (p *ContextFilter) Name() string
  • func (p *ContextFilter) ProcessLedger(ctx context.Context, store *pipeline.Store, r io.LedgerReader, ...) error
  • func (p *ContextFilter) ProcessState(ctx context.Context, store *pipeline.Store, r io.StateReader, w io.StateWriter) error
  • func (p *ContextFilter) Reset()
• type DatabaseProcessor
  • func (p *DatabaseProcessor) Name() string
  • func (p *DatabaseProcessor) ProcessLedger(ctx context.Context, store *pipeline.Store, r io.LedgerReader, ...) error
  • func (p *DatabaseProcessor) ProcessState(ctx context.Context, store *pipeline.Store, r io.StateReader, w io.StateWriter) error
  • func (p *DatabaseProcessor) Reset()
• type DatabaseProcessorActionType
• type OrderbookProcessor
  • func (p *OrderbookProcessor) Name() string
  • func (p *OrderbookProcessor) ProcessLedger(ctx context.Context, store *pipeline.Store, r io.LedgerReader, ...) error
  • func (p *OrderbookProcessor) ProcessState(ctx context.Context, store *pipeline.Store, r io.StateReader, w io.StateWriter) error
  • func (p *OrderbookProcessor) Reset()
• type PipelineContextKey

Constants

const (
	IngestUpdateDatabase = PipelineContextKey("IngestUpdateDatabase")
)

Types

type ContextFilter

type ContextFilter struct {
	Key PipelineContextKey
}

ContextFilter writes read objects only if a given key is present in the pipline context.

func (*ContextFilter) Name

func (p *ContextFilter) Name() string

func (*ContextFilter) ProcessLedger

func (p *ContextFilter) ProcessLedger(ctx context.Context, store *pipeline.Store, r io.LedgerReader, w io.LedgerWriter) error

func (*ContextFilter) ProcessState

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

func (*ContextFilter) Reset

func (p *ContextFilter) Reset()

type DatabaseProcessor

type DatabaseProcessor struct {
	HistoryQ history.QSigners
	OffersQ  history.QOffers
	Action   DatabaseProcessorActionType
}

DatabaseProcessor is a processor (both state and ledger) that's responsible for persisting ledger data used in expingest in a database. It's possible to create multiple procesors of this type but they all should share the same *history.Q object to share a common transaction. `Action` defines what each processor is responsible for.

func (*DatabaseProcessor) Name

func (p *DatabaseProcessor) Name() string

func (*DatabaseProcessor) ProcessLedger

func (p *DatabaseProcessor) ProcessLedger(ctx context.Context, store *pipeline.Store, r io.LedgerReader, w io.LedgerWriter) error

func (*DatabaseProcessor) ProcessState

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

func (*DatabaseProcessor) Reset

func (p *DatabaseProcessor) Reset()

type DatabaseProcessorActionType

type DatabaseProcessorActionType string

const (
	AccountsForSigner DatabaseProcessorActionType = "AccountsForSigner"
	Offers            DatabaseProcessorActionType = "Offers"
)

type OrderbookProcessor

type OrderbookProcessor struct {
	OrderBookGraph *orderbook.OrderBookGraph
}

OrderbookProcessor is a processor (both state and ledger) that's responsible for updating orderbook graph with new/updated/removed offers. Orderbook graph can be later used for path finding.

func (*OrderbookProcessor) Name

func (p *OrderbookProcessor) Name() string

func (*OrderbookProcessor) ProcessLedger

func (p *OrderbookProcessor) ProcessLedger(ctx context.Context, store *pipeline.Store, r io.LedgerReader, w io.LedgerWriter) error

func (*OrderbookProcessor) ProcessState

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

func (*OrderbookProcessor) Reset

func (p *OrderbookProcessor) Reset()

type PipelineContextKey

type PipelineContextKey string