indexing

package
v0.9.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ParserTaskName1 = "ParserExample (Task 1)"
	ParserTaskName2 = "ParserExample (Task 2)"
)
View Source
const (
	ValidatorTaskName1 = "ValidatorExample (Task 1)"
	ValidatorTaskName2 = "ValidatorExample (Task 2)"
)
View Source
const (
	AggregatorTaskName = "AggregatorExample"
)
View Source
const (
	FetcherTaskName = "FetcherExample"
)
View Source
const (
	SequencerTaskName = "SequencerExample"
)
View Source
const (
	SyncerTaskName = "SyncerExample"
)

Variables

This section is empty.

Functions

func NewAggregatorTask

func NewAggregatorTask() pipeline.Task

func NewFetcherTask

func NewFetcherTask() pipeline.Task

func NewParserTask

func NewParserTask() pipeline.Task

func NewParserTask2

func NewParserTask2() pipeline.Task

func NewPayloadFactory

func NewPayloadFactory() *payloadFactory

func NewSequencerTask

func NewSequencerTask() pipeline.Task

func NewSink

func NewSink() pipeline.Sink

func NewSource

func NewSource() pipeline.Source

func NewSyncerTask

func NewSyncerTask() pipeline.Task

func NewValidatorTask

func NewValidatorTask() pipeline.Task

func NewValidatorTask2

func NewValidatorTask2() pipeline.Task

func StartPipeline

func StartPipeline() error

Types

type AggregatorTask

type AggregatorTask struct {
}

func (*AggregatorTask) GetName

func (t *AggregatorTask) GetName() string

func (*AggregatorTask) Run

type FetcherTask

type FetcherTask struct {
}

func (*FetcherTask) GetName

func (t *FetcherTask) GetName() string

func (*FetcherTask) Run

type ParserTask

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

func (*ParserTask) GetName

func (t *ParserTask) GetName() string

func (*ParserTask) Run

type SequencerTask

type SequencerTask struct {
}

func (*SequencerTask) GetName

func (t *SequencerTask) GetName() string

func (*SequencerTask) Run

type SyncerTask

type SyncerTask struct {
}

func (*SyncerTask) GetName

func (t *SyncerTask) GetName() string

func (*SyncerTask) Run

type ValidatorTask

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

func (*ValidatorTask) GetName

func (t *ValidatorTask) GetName() string

func (*ValidatorTask) Run

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL