pipe

Documentation

Index

• func NewEventParserPipe(ctx context.Context, cfg *core.ClientConfig, opts ...component.Option) (component.Component, error)
• type EventDefinition
  • func NewEventDefinition(ctx context.Context, n core.Network) (*EventDefinition, error)
  • func (ed *EventDefinition) Transform(ctx context.Context, td core.TransitData) ([]core.TransitData, error)

Functions

func NewEventParserPipe

func NewEventParserPipe(ctx context.Context, cfg *core.ClientConfig,
	opts ...component.Option) (component.Component, error)

NewEventParserPipe ... Initializer

Types

type EventDefinition

type EventDefinition struct {
	SK *core.StateKey
	// contains filtered or unexported fields
}

EventDefinition ... Represents the stateful definition of the event log pipe component Used to transform block data into event logs (block->events) Uses a DLQ to reprocess failed queries & state store to get events to monitor

func NewEventDefinition

func NewEventDefinition(ctx context.Context, n core.Network) (*EventDefinition, error)

NewEventDefinition ... Initializes the event log pipe definition

func (*EventDefinition) Transform

func (ed *EventDefinition) Transform(ctx context.Context, td core.TransitData) ([]core.TransitData, error)

Transform ... Attempts to reprocess previously failed queries first before attempting to process the current block data