db

package

v1.3.1 Latest Latest Go to latest Published: Oct 18, 2023 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/saxypandabear/twitchsongrequests

Links

Open Source Insights

Documentation ¶

Overview ¶

nolint

Index ¶

Constants
func FetchSpotifyToken(userStore UserStore, id string) (*oauth2.Token, error)
func FetchTwitchToken(userStore UserStore, id string) (*oauth2.Token, error)
type MessageCounter
type PostgresMessageCounter
- func NewPostgresMessageCounter(pool *pgxpool.Pool) *PostgresMessageCounter
type PostgresPreferenceStore
- func NewPostgresPreferenceStore(pool *pgxpool.Pool) *PostgresPreferenceStore
type PostgresUserStore
- func NewPostgresUserStore(pool *pgxpool.Pool) *PostgresUserStore
type PreferenceStore
type UserStore

Constants ¶

View Source

const (
	LIMIT = 100
)

Variables ¶

This section is empty.

Functions ¶

func FetchSpotifyToken ¶

func FetchSpotifyToken(userStore UserStore, id string) (*oauth2.Token, error)

func FetchTwitchToken ¶

func FetchTwitchToken(userStore UserStore, id string) (*oauth2.Token, error)

Types ¶

type MessageCounter ¶

type MessageCounter interface {
	AddMessage(*metrics.Message)
	TotalMessages() uint64
	RunningCount(int) uint64
	MessagesForUser(string) []*metrics.Message
}

type PostgresMessageCounter ¶

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

func NewPostgresMessageCounter ¶

func NewPostgresMessageCounter(pool *pgxpool.Pool) *PostgresMessageCounter

func (*PostgresMessageCounter) AddMessage ¶

func (p *PostgresMessageCounter) AddMessage(m *metrics.Message)

func (*PostgresMessageCounter) MessagesForUser ¶ added in v1.3.1

func (p *PostgresMessageCounter) MessagesForUser(id string) []*metrics.Message

MessagesForUser reads out of the database of queued songs to track successful queues, but doesn't provide a lot of user value. Leaving this here for now, but might remove in the future.

func (*PostgresMessageCounter) RunningCount ¶

func (p *PostgresMessageCounter) RunningCount(days int) uint64

func (*PostgresMessageCounter) TotalMessages ¶

func (p *PostgresMessageCounter) TotalMessages() uint64

TotalMessages counts only the successful messages that were queued

type PostgresPreferenceStore ¶

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

func NewPostgresPreferenceStore ¶

func NewPostgresPreferenceStore(pool *pgxpool.Pool) *PostgresPreferenceStore

func (*PostgresPreferenceStore) AddPreference ¶

func (s *PostgresPreferenceStore) AddPreference(p *preferences.Preference) error

func (*PostgresPreferenceStore) DeletePreference ¶

func (s *PostgresPreferenceStore) DeletePreference(id string) error

func (*PostgresPreferenceStore) GetPreference ¶

func (s *PostgresPreferenceStore) GetPreference(id string) (*preferences.Preference, error)

func (*PostgresPreferenceStore) UpdatePreference ¶

func (s *PostgresPreferenceStore) UpdatePreference(p *preferences.Preference) error

type PostgresUserStore ¶

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

func NewPostgresUserStore ¶

func NewPostgresUserStore(pool *pgxpool.Pool) *PostgresUserStore

func (*PostgresUserStore) AddUser ¶

func (s *PostgresUserStore) AddUser(user *users.User) error

func (*PostgresUserStore) DeleteUser ¶

func (s *PostgresUserStore) DeleteUser(id string) error

func (*PostgresUserStore) GetUser ¶

func (s *PostgresUserStore) GetUser(id string) (*users.User, error)

func (*PostgresUserStore) UpdateUser ¶

func (s *PostgresUserStore) UpdateUser(user *users.User) error

type PreferenceStore ¶

type PreferenceStore interface {
	GetPreference(string) (*preferences.Preference, error)
	AddPreference(*preferences.Preference) error
	UpdatePreference(*preferences.Preference) error
	DeletePreference(string) error
}

type UserStore ¶

type UserStore interface {
	GetUser(id string) (*users.User, error)
	AddUser(user *users.User) error
	UpdateUser(user *users.User) error
	DeleteUser(id string) error
}

Source Files ¶

View all Source files

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