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) SampleUsers(n int) ([]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) SampleUsers

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

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

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