Documentation ¶
Index ¶
- func Connect(ds string) (*sqlx.DB, error)
- type Job
- type Line
- type Report
- type Repository
- func (repo *Repository) InsertJob(job *storage.Job) error
- func (repo *Repository) InsertLine(line *storage.Line) error
- func (repo *Repository) InsertReport(report *storage.Report) error
- func (repo *Repository) JobReaders(j storage.Job) (io.Reader, io.Reader)
- func (repo *Repository) JobsByReport(report storage.Report) ([]storage.Job, error)
- func (repo *Repository) LastReport() (storage.Report, error)
- func (repo *Repository) Report(name string) (storage.Report, error)
- func (repo *Repository) Reports() ([]storage.Report, error)
- type RowIterator
- type Time
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Job ¶
type Line ¶
type Report ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
func NewRepository ¶
func NewRepository(conn *sqlx.DB) *Repository
func (*Repository) InsertJob ¶
func (repo *Repository) InsertJob(job *storage.Job) error
func (*Repository) InsertLine ¶
func (repo *Repository) InsertLine(line *storage.Line) error
func (*Repository) InsertReport ¶
func (repo *Repository) InsertReport(report *storage.Report) error
func (*Repository) JobReaders ¶
func (*Repository) JobsByReport ¶
func (*Repository) LastReport ¶
func (repo *Repository) LastReport() (storage.Report, error)
func (*Repository) Reports ¶
func (repo *Repository) Reports() ([]storage.Report, error)
type RowIterator ¶
type RowIterator struct {
// contains filtered or unexported fields
}
func (*RowIterator) Next ¶
func (rc *RowIterator) Next() ([]byte, error)
Click to show internal directories.
Click to hide internal directories.