storage

Documentation

Index

• type Store
  • func NewPostgresStore() (*Store, error)
  • func (store *Store) AddTransactions(item *venmo.FeedItem) error
  • func (store *Store) Flush() error
  • func (store *Store) SampleUsersWithFacebookResultsWithoutProfile(n int) ([]User, error)
  • func (store *Store) SampleUsersWithPeekYouMatchWithoutProfile(n int) ([]User, error)
  • func (store *Store) SampleUsersWithoutBingResults(n int) ([]User, error)
  • func (store *Store) SampleUsersWithoutDDGResults(n int) ([]User, error)
  • func (store *Store) SampleUsersWithoutFacebookResults(n int) ([]User, error)
  • func (store *Store) SampleUsersWithoutPeekYouResults(n int) ([]User, error)
  • func (store *Store) UpdateUser(user *User) error
• type Transaction
• type User
• type UserToTransaction

Types

type Store

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

Store is a storage client

func NewPostgresStore

func NewPostgresStore() (*Store, error)

NewPostgresStore creates a postgres client

func (*Store) AddTransactions

func (store *Store) AddTransactions(item *venmo.FeedItem) error

AddTransactions adds a transaction to the db

func (*Store) Flush

func (store *Store) Flush() error

Flush flushes the store buffer

func (*Store) SampleUsersWithFacebookResultsWithoutProfile

func (store *Store) SampleUsersWithFacebookResultsWithoutProfile(n int) ([]User, error)

SampleUsersWithFacebookResultsWithoutProfile samples users

func (*Store) SampleUsersWithPeekYouMatchWithoutProfile

func (store *Store) SampleUsersWithPeekYouMatchWithoutProfile(n int) ([]User, error)

SampleUsersWithPeekYouMatchWithoutProfile samples users

func (*Store) SampleUsersWithoutBingResults

func (store *Store) SampleUsersWithoutBingResults(n int) ([]User, error)

SampleUsersWithoutBingResults samples users

func (*Store) SampleUsersWithoutDDGResults

func (store *Store) SampleUsersWithoutDDGResults(n int) ([]User, error)

SampleUsersWithoutDDGResults samples users

func (*Store) SampleUsersWithoutFacebookResults

func (store *Store) SampleUsersWithoutFacebookResults(n int) ([]User, error)

SampleUsersWithoutFacebookResults samples users

func (*Store) SampleUsersWithoutPeekYouResults

func (store *Store) SampleUsersWithoutPeekYouResults(n int) ([]User, error)

SampleUsersWithoutPeekYouResults samples users

func (*Store) UpdateUser

func (store *Store) UpdateUser(user *User) error

UpdateUser updates a user

type Transaction

type Transaction struct {
	ID          int
	Message     string `pg:"type:'varchar'"`
	Story       string `pg:"type:'varchar'"`
	Type        string `pg:"type:'varchar'"`
	Created     string `pg:"type:'timestamp'"`
	Updated     string `pg:"type:'timestamp'"`
	ActorUserID int
	RecipientID int
}

Transaction is postgres transaction

type User

type User struct {

	// Venmo Fields
	ID           int
	Transactions []Transaction `pg:"many2many:user_to_transactions"`
	Username     string        `pg:"type:'varchar'"`
	PictureURL   string        `pg:"type:'varchar'"`
	Name         string        `pg:"type:'varchar'"`
	FirstName    string        `pg:"type:'varchar'"`
	LastName     string        `pg:"type:'varchar'"`
	Created      string        `pg:"type:'timestamp'"`
	IsBusiness   bool          `pg:"type:'boolean',default:false"`
	Cancelled    bool          `pg:"type:'boolean',default:false"`
	ExternalID   string        `pg:"type:'varchar'"`

	// Research Fields
	BingResults     map[string]interface{} `pg:"type:'json'"`
	DDGResults      string                 `pg:"type:'text'"`
	FacebookResults map[string]interface{} `pg:"type:'json'"`
	FacebookProfile map[string]interface{} `pg:"type:'json'"`
	PeekYouResults  map[string]interface{} `pg:"type:'json'"`
	// contains filtered or unexported fields
}

User is a postgres user

type UserToTransaction

type UserToTransaction struct {
	UserID        int
	TransactionID int
	IsActor       bool `pg:"type:'boolean'"`
}

UserToTransaction is relation between users and transactions