jobs

Mar 20, 2023

Changes in this version

+ type AsyncJobPayload struct

+ AsyncJobType string

+ DestinationID string

+ Id string

+ MetaData json.RawMessage

+ SourceID string

+ TableName string

+ WorkspaceID string

+ type AsyncJobWh struct

+ AsyncJobTimeOut time.Duration

+ MaxAttemptsPerJob int

+ MaxBatchSizeToProcess int

+ MaxCleanUpRetries int

+ MaxQueryRetries int

+ RetryTimeInterval time.Duration

+ func (a *AsyncJobWh) AddWarehouseJobHandler(w http.ResponseWriter, r *http.Request)

+ func (a *AsyncJobWh) InitAsyncJobRunner() error

+ func (a *AsyncJobWh) StatusWarehouseJobHandler(w http.ResponseWriter, r *http.Request)

Feb 23, 2023

Changes in this version

type AsyncJobPayloadT

+ WorkspaceID string

type StartJobReqPayload

+ WorkspaceID string

Dec 6, 2022

Changes in this version

+ func WithConfig(a *AsyncJobWhT, config *config.Config)

type AsyncJobWhT

+ AsyncJobTimeOut time.Duration

+ MaxAttemptsPerJob int

+ MaxBatchSizeToProcess int

+ MaxCleanUpRetries int

+ MaxQueryRetries int

+ RetryTimeInterval time.Duration

Nov 11, 2022

Changes in this version

+ type AsyncJobStatus struct

+ Error error

+ Id string

+ Status string

Oct 12, 2022

Changes in this version

+ const AsyncJobType

+ const MaxAttemptsPerJob

+ const MaxBatchSizeToProcess

+ const MaxCleanUpRetries

+ const MaxQueryRetries

+ const RetryTimeInterval

+ const WhAsyncJobTimeOut

+ const WhJobAborted

+ const WhJobExecuting

+ const WhJobFailed

+ const WhJobSucceeded

+ const WhJobWaiting

+ type AsyncJobPayloadT struct

+ AsyncJobType string

+ DestinationID string

+ Id string

+ MetaData json.RawMessage

+ SourceID string

+ TableName string

+ type AsyncJobWhT struct

+ func InitWarehouseJobsAPI(ctx context.Context, dbHandle *sql.DB, notifier *pgnotifier.PgNotifierT) *AsyncJobWhT

+ func (asyncWhJob *AsyncJobWhT) AddWarehouseJobHandler(w http.ResponseWriter, r *http.Request)

+ func (asyncWhJob *AsyncJobWhT) InitAsyncJobRunner() error

+ func (asyncWhJob *AsyncJobWhT) StatusWarehouseJobHandler(w http.ResponseWriter, r *http.Request)

+ type AsyncJobsStatusMap struct

+ Error error

+ Id string

+ Status string

+ type PGNotifierOutput struct

+ Id string

+ type StartJobReqPayload struct

+ AsyncJobType string

+ Channel string

+ DestinationID string

+ JobRunID string

+ SourceID string

+ StartTime string

+ TaskRunID string

+ Type string

+ type WhAddJobResponse struct

+ Err error

+ JobIds []int64

+ type WhAsyncJob struct

+ func (*WhAsyncJob) GetFirstLastEvent() (time.Time, time.Time)

+ func (*WhAsyncJob) GetLoadFileGenStartTIme() time.Time

+ func (*WhAsyncJob) GetLoadFileType() string

+ func (*WhAsyncJob) GetLoadFilesMetadata(warehouseutils.GetLoadFilesOptionsT) []warehouseutils.LoadFileT

+ func (*WhAsyncJob) GetLocalSchema() warehouseutils.SchemaT

+ func (*WhAsyncJob) GetSampleLoadFileLocation(string) (string, error)

+ func (*WhAsyncJob) GetSchemaInWarehouse() warehouseutils.SchemaT

+ func (*WhAsyncJob) GetSingleLoadFile(string) (warehouseutils.LoadFileT, error)

+ func (*WhAsyncJob) GetTableSchemaInUpload(string) warehouseutils.TableSchemaT

+ func (*WhAsyncJob) GetTableSchemaInWarehouse(string) warehouseutils.TableSchemaT

+ func (*WhAsyncJob) ShouldOnDedupUseNewRecord() bool

+ func (*WhAsyncJob) UpdateLocalSchema(warehouseutils.SchemaT) error

+ func (*WhAsyncJob) UseRudderStorage() bool

+ type WhAsyncJobRunner interface

+ type WhJobsMetaData struct

+ JobRunID string

+ JobType string

+ StartTime string

+ TaskRunID string

+ type WhStatusResponse struct

+ Err string

+ Status string