Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Job ¶
type Job struct { ID uuid.UUID IngestionClient Ingestion Configuration *cingestion.IngestionJobConfiguration JobStatus cingestion.JobStatus // contains filtered or unexported fields }
func NewJob ¶
func NewJob(cfg *cingestion.IngestionJobConfiguration, table *entities.Table) (*Job, error)
NewJob creates a new Job based on the configuration in input
func (*Job) Initialize ¶
Initialize initiate the client and prepare for data reading process
Click to show internal directories.
Click to hide internal directories.