file

package

v0.2.3 Latest Latest Go to latest Published: Dec 28, 2025 License: Apache-2.0 Imports: 7 Imported by: 5

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Breeze0806/go-etl

Links

Open Source Insights

Documentation ¶

Overview ¶

Package file describes the file reader. For Tasks and Readers like CSV, independent implementation of Job is required, specifically implementing the `Split` method for splitting and the `Init` method for initialization.

Index ¶

type Job
- func NewJob() *Job
- func (j *Job) Destroy(ctx context.Context) (err error)
type Task
- func NewTask() *Task

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Job ¶

type Job struct {
	*plugin.BaseJob
}

Job normal file job

func NewJob ¶

func NewJob() *Job

NewJob create normal file job

func (*Job) Destroy ¶

func (j *Job) Destroy(ctx context.Context) (err error)

Destroy destroy normal file job

type Task ¶

type Task struct {
	*plugin.BaseTask
	// contains filtered or unexported fields
}

Task normal file task

func NewTask ¶

func NewTask() *Task

NewTask Create normal file task

func (*Task) Destroy ¶

func (t *Task) Destroy(ctx context.Context) (err error)

Destroy Destroy normal file task

func (*Task) Init ¶

func (t *Task) Init(ctx context.Context) (err error)

Init Initialize the task

func (*Task) StartRead ¶

func (t *Task) StartRead(ctx context.Context, sender plugin.RecordSender) (err error)

StartRead Start reading data and send it to the sender

Source Files ¶

View all Source files

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