task

Documentation

Index

• Constants
• type DefaultTask
  • func (t *DefaultTask) GetID() string
  • func (t *DefaultTask) Start() (err error)
  • func (t *DefaultTask) Stop()
• type Task
  • func NewTask(config core.StringMap) Task
  • func NewTaskFromJson(path string) (Task, error)

Constants

const (
	// StateKey is default key in state store
	StateKey                   = "state"
	DefaultSyncStateIntervalMS = 10000
)

Types

type DefaultTask

type DefaultTask struct {
	ID string
	// contains filtered or unexported fields
}

func (*DefaultTask) GetID

func (t *DefaultTask) GetID() string

func (*DefaultTask) Start

func (t *DefaultTask) Start() (err error)

func (*DefaultTask) Stop

func (t *DefaultTask) Stop()

type Task

type Task interface {
	// GetID returns the id of the task.
	GetID() string

	// Start starts the task and blocks until task finished or error thrown.
	Start() error

	// Stop stops the task and blocks until stopped.
	Stop()
}

Task is the runnable instance to do all ETL tasks.

func NewTask

func NewTask(config core.StringMap) Task

func NewTaskFromJson

func NewTaskFromJson(path string) (Task, error)