db

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
  • func (p *PostgresMessageCounter) AddMessage(m *metrics.Message)
  • func (p *PostgresMessageCounter) MessagesForUser(id string) []*metrics.Message
  • func (p *PostgresMessageCounter) RunningCount(days int) uint64
  • func (p *PostgresMessageCounter) TotalMessages() uint64
• type PostgresPreferenceStore
  • func NewPostgresPreferenceStore(pool *pgxpool.Pool) *PostgresPreferenceStore
  • func (s *PostgresPreferenceStore) AddPreference(p *preferences.Preference) error
  • func (s *PostgresPreferenceStore) DeletePreference(id string) error
  • func (s *PostgresPreferenceStore) GetPreference(id string) (*preferences.Preference, error)
  • func (s *PostgresPreferenceStore) UpdatePreference(p *preferences.Preference) error
• type PostgresUserStore
  • func NewPostgresUserStore(pool *pgxpool.Pool) *PostgresUserStore
  • func (s *PostgresUserStore) AddUser(user *users.User) error
  • func (s *PostgresUserStore) DeleteUser(id string) error
  • func (s *PostgresUserStore) GetUser(id string) (*users.User, error)
  • func (s *PostgresUserStore) UpdateUser(user *users.User) error
• type PreferenceStore
• type UserStore

Constants

const (
	LIMIT = 100
)

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

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
}