Documentation ¶
Index ¶
- Variables
- type FileSaver
- type Saver
- type SqliteSaver
- type StatusTable
- type StatusTracker
- func (this *StatusTracker) GetStatus(job *dag.Job) (dag.JobStatus, error)
- func (this *StatusTracker) HasReRan(job *dag.Job) bool
- func (this *StatusTracker) IsJobTracked(job *dag.Job) bool
- func (this *StatusTracker) SetReRan(job *dag.Job)
- func (this *StatusTracker) SetStatus(job *dag.Job) error
- func (this *StatusTracker) String() string
- func (this *StatusTracker) ToJson() string
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type FileSaver ¶
type FileSaver struct {
// contains filtered or unexported fields
}
func NewFileSaver ¶
func NewHDFSSaver ¶
func (*FileSaver) DeleteFlag ¶
type SqliteSaver ¶
type SqliteSaver struct {
// contains filtered or unexported fields
}
func NewSqliteSaver ¶
func NewSqliteSaver(path string) (*SqliteSaver, error)
func (*SqliteSaver) DeleteFlag ¶
type StatusTable ¶
type StatusTracker ¶
func NewStatusTracker ¶
func NewStatusTracker(saver Saver) *StatusTracker
func (*StatusTracker) IsJobTracked ¶
func (this *StatusTracker) IsJobTracked(job *dag.Job) bool
func (*StatusTracker) SetReRan ¶
func (this *StatusTracker) SetReRan(job *dag.Job)
func (*StatusTracker) String ¶
func (this *StatusTracker) String() string
func (*StatusTracker) ToJson ¶
func (this *StatusTracker) ToJson() string
Click to show internal directories.
Click to hide internal directories.