Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ArchiveDownloader ¶
type ArchiveDownloader struct {
// contains filtered or unexported fields
}
ArchiveDownloader downloads, decompress and store events for github orgs
func NewArchiveDownloader ¶
func NewArchiveDownloader( engine *xorm.Engine, overrideAllFiles bool, url string, orgNames []string, startDate, stopDate time.Time, numWorkers int, skipErrors bool, logger log.Logger, ) *ArchiveDownloader
NewArchiveDownloader creates a new downloader
func (*ArchiveDownloader) DownloadEvents ¶
func (ad *ArchiveDownloader) DownloadEvents(ctx context.Context) error
DownloadEvents start to download all archive events
type ArchiveReader ¶
type ArchiveReader struct {
// contains filtered or unexported fields
}
ArchiveReader reads all events stored in archive database
func NewArchiveReader ¶
NewArchiveReader creates a new reader
func (*ArchiveReader) ReadAllEvents ¶
func (ar *ArchiveReader) ReadAllEvents() (streams.Readable, <-chan error)
ReadAllEvents reads all events stored in archive database
type RawSQLMigration ¶
type RawSQLMigration struct {
migrator.MigrationBase
// contains filtered or unexported fields
}
func NewRawSQLMigration ¶
func NewRawSQLMigration(sql string) *RawSQLMigration
Source Files
Click to show internal directories.
Click to hide internal directories.