etl

Documentation

Index

• Variables
• func ArchivePost(p reddit.Post, sub string, conn db.Connection)
• func CountRef(p []reddit.Post, tickers []stocks.Stock) (r []report.StockReport, err error)
• func GetPosts(sub string, limit int, auth reddit.AuthToken, conn db.Connection) (p []reddit.Post, err error)
• func GetTradeableSecurities(svc *s3.S3, bucket string) ([]stocks.Stock, error)
• func PutRecord(conn db.Connection, sr []report.StockReport, sub string, t time.Time) (err error)

Variables

var FetchTargets = []string{
	"stocks",
	"wallstreetbets",
	"investing",
}

Functions

func ArchivePost

func ArchivePost(p reddit.Post, sub string, conn db.Connection)

func CountRef

func CountRef(p []reddit.Post, tickers []stocks.Stock) (r []report.StockReport, err error)

func GetPosts

func GetPosts(sub string, limit int, auth reddit.AuthToken, conn db.Connection) (p []reddit.Post, err error)

func GetTradeableSecurities

func GetTradeableSecurities(svc *s3.S3, bucket string) ([]stocks.Stock, error)

func PutRecord

func PutRecord(conn db.Connection, sr []report.StockReport, sub string, t time.Time) (err error)