Documentation ¶
Index ¶
- Variables
- type DB
- func (db *DB) CleanUpCache() error
- func (db *DB) Close()
- func (db *DB) CreateIteration() (*Iteration, error)
- func (db *DB) InsertStats(self *twitter.User) error
- func (db *DB) LoadLastIteration() (*Iteration, error)
- func (db *DB) Log(level, message string)
- func (db *DB) SaveIteration(it *Iteration) error
- func (db *DB) SelectUsersForPull(t time.Time, limit int) ([]string, error)
- func (db *DB) StashUsers() error
- func (db *DB) SumUserEvents(t time.Time) error
- func (db *DB) UpdateUserInfo(relation string, users []twitter.User) error
- func (db *DB) UpdateUserUpdateTime(users []string) error
- type Iteration
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type DB ¶
type DB struct {
// contains filtered or unexported fields
}
func (*DB) CleanUpCache ¶
func (*DB) CreateIteration ¶
func (*DB) LoadLastIteration ¶
func (*DB) SaveIteration ¶
func (*DB) SelectUsersForPull ¶
func (*DB) StashUsers ¶
func (*DB) UpdateUserInfo ¶
func (*DB) UpdateUserUpdateTime ¶
type Iteration ¶
type Iteration struct { ID int64 `db:"id"` State string `db:"state"` StartedAt time.Time `db:"started_at"` CompleteFetchFollowersAt sql.NullTime `db:"complete_fetch_followers_at"` CompleteFetchFollowingAt sql.NullTime `db:"complete_fetch_following_at"` CompletePullUsersAt sql.NullTime `db:"complete_pull_users_at"` CompleteSumEventsAt sql.NullTime `db:"complete_sum_events_at"` CompleteStashUsersAt sql.NullTime `db:"complete_stash_users_at"` CompletedAt sql.NullTime `db:"completed_at"` NextToken string `db:"next_token"` }
Click to show internal directories.
Click to hide internal directories.