store

package
v0.0.0-...-1723f64 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 28, 2022 License: BSD-3-Clause Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DB_HOST   string
	DB_PORT   string
	DB_USER   string
	DB_NAME   string
	DB_PASSWD string
)

Functions

This section is empty.

Types

type DB

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

func NewDB

func NewDB() (*DB, error)

func (*DB) CleanUpCache

func (db *DB) CleanUpCache() error

func (*DB) Close

func (db *DB) Close()

func (*DB) CreateIteration

func (db *DB) CreateIteration() (*Iteration, error)

func (*DB) InsertStats

func (db *DB) InsertStats(self *twitter.User) error

func (*DB) LoadLastIteration

func (db *DB) LoadLastIteration() (*Iteration, error)

func (*DB) Log

func (db *DB) Log(level, message string)

func (*DB) SaveIteration

func (db *DB) SaveIteration(it *Iteration) error

func (*DB) SelectUsersForPull

func (db *DB) SelectUsersForPull(t time.Time, limit int) ([]string, error)

func (*DB) StashUsers

func (db *DB) StashUsers() error

func (*DB) SumUserEvents

func (db *DB) SumUserEvents(t time.Time) error

func (*DB) UpdateUserInfo

func (db *DB) UpdateUserInfo(relation string, users []twitter.User) error

func (*DB) UpdateUserUpdateTime

func (db *DB) UpdateUserUpdateTime(users []string) error

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL