job

Documentation

Index

• type FailedJob
• type JobService
  • func NewJobService(ctx context.Context) (*JobService, error)
  • func (s *JobService) Cancel(projectID string, jobID string) error
  • func (s *JobService) ListFailedJob(projectID string, jobType string, limit int64) ([]*FailedJob, error)
  • func (s *JobService) ListJob(projectID string, jobType string, state string, limit int64) ([]*bigquery.JobListJobs, error)

Types

type FailedJob

type FailedJob struct {
	JobID     string
	Query     *bigquery.JobConfigurationQuery
	Load      *bigquery.JobConfigurationLoad
	Extract   *bigquery.JobConfigurationExtract
	TableCopy *bigquery.JobConfigurationTableCopy
	Message   string
	StartTime time.Time
	EndTime   time.Time
}

type JobService

type JobService struct {
	// contains filtered or unexported fields
}

func NewJobService

func NewJobService(ctx context.Context) (*JobService, error)

func (*JobService) Cancel

func (s *JobService) Cancel(projectID string, jobID string) error

func (*JobService) ListFailedJob

func (s *JobService) ListFailedJob(projectID string, jobType string, limit int64) ([]*FailedJob, error)

func (*JobService) ListJob

func (s *JobService) ListJob(projectID string, jobType string, state string, limit int64) ([]*bigquery.JobListJobs, error)

ListJob jobType: Can be QUERY, LOAD, EXTRACT, COPY or UNKNOWN. State: Can be done, pending, running