engine

Apr 29, 2024

Changes in this version

type Task

+ BuildActivity func(options ...activityx.Option) (*activityx.Activity, error)

type Worker

+ Network func() []network.Network

+ Platform func() string

+ Tags func() []tag.Tag

+ Types func() []schema.Type

Apr 11, 2024

Changes in this version

+ func BuildTaskTraceAttributes(task Task) []attribute.KeyValue

+ type Tasks struct

+ Tasks []Task

+ func (t *Tasks) Get(key string) string

+ func (t *Tasks) Keys() []string

+ func (t *Tasks) Len() int

+ func (t *Tasks) Set(key string, value string)

Jan 30, 2024

Changes in this version

+ type Checkpoint struct

+ ID string

+ IndexCount int64

+ Network filter.Network

+ State json.RawMessage

+ UpdatedAt time.Time

+ Worker string

+ type CheckpointTransformer interface

+ Export func() (*Checkpoint, error)

+ Import func(checkpoint *Checkpoint) error

+ type Source interface

+ Network func() filter.Network

+ Start func(ctx context.Context, tasksChan chan<- []Task, errorChan chan<- error)

+ State func() json.RawMessage

+ type SourceFilter interface

+ type Task interface

+ BuildFeed func(options ...schema.FeedOption) (*schema.Feed, error)

+ GetNetwork func() filter.Network

+ GetTimestamp func() uint64

+ ID func() string

+ Validate func() error

+ type Worker interface

+ Filter func() SourceFilter

+ Match func(ctx context.Context, task Task) (bool, error)

+ Name func() string

+ Transform func(ctx context.Context, task Task) (*schema.Feed, error)