reader

Documentation

Index

• type Job
• type Task

Types

type Job

type Job interface {
	plugin.Job

	// Split the existing task into a number of tasks based on the Job, and pass them to each task mainly in the form of a configuration file.
	Split(ctx context.Context, number int) ([]*config.JSON, error)
}

Job: a unit of work

type Task

type Task interface {
	plugin.Task

	// StartRead - Begins reading from the sender
	StartRead(ctx context.Context, sender plugin.RecordSender) error
}

Task - Represents a task to be performed