datahistoryjob

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

type DataHistoryJob struct {
	ID                          string
	Nickname                    string
	ExchangeID                  string
	ExchangeName                string
	Asset                       string
	Base                        string
	Quote                       string
	StartDate                   time.Time
	EndDate                     time.Time
	Interval                    int64
	RequestSizeLimit            int64
	DataType                    int64
	MaxRetryAttempts            int64
	BatchSize                   int64
	Status                      int64
	CreatedDate                 time.Time
	Results                     []*datahistoryjobresult.DataHistoryJobResult
	PrerequisiteJobID           string
	PrerequisiteJobNickname     string
	ConversionInterval          int64
	OverwriteData               bool
	DecimalPlaceComparison      int64
	SecondarySourceExchangeName string
	IssueTolerancePercentage    float64
	ReplaceOnIssue              bool
}

type IDBService interface {
	Upsert(...*DataHistoryJob) error
	GetByNickName(string) (*DataHistoryJob, error)
	GetByID(string) (*DataHistoryJob, error)
	GetJobsBetween(time.Time, time.Time) ([]DataHistoryJob, error)
	GetAllIncompleteJobsAndResults() ([]DataHistoryJob, error)
	GetJobAndAllResults(string) (*DataHistoryJob, error)
	GetRelatedUpcomingJobs(string) ([]*DataHistoryJob, error)
	SetRelationshipByID(string, string, int64) error
	SetRelationshipByNickname(string, string, int64) error
}