Documentation ¶
Index ¶
- Constants
- type Connection
- func (conn *Connection) Close() error
- func (conn *Connection) GenerateRunID() (int, error)
- func (conn *Connection) GetAllSubreddits() (subs []string, err error)
- func (conn *Connection) InsertSentimentResult(input InsertSentimentResultInput) (err error)
- func (conn *Connection) InsertSubreddit(name string) error
- func (conn *Connection) UpdateWatermark(input UpdateWatermarkInput) error
- func (conn *Connection) UpsertSubreddit(name string) error
- type InsertSentimentResultInput
- type NewConnectionInput
- type UpdateWatermarkInput
Constants ¶
View Source
const DBNAME = "monty"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(input NewConnectionInput) (conn Connection, err error)
func (*Connection) Close ¶
func (conn *Connection) Close() error
func (*Connection) GenerateRunID ¶
func (conn *Connection) GenerateRunID() (int, error)
func (*Connection) GetAllSubreddits ¶
func (conn *Connection) GetAllSubreddits() (subs []string, err error)
func (*Connection) InsertSentimentResult ¶
func (conn *Connection) InsertSentimentResult(input InsertSentimentResultInput) (err error)
func (*Connection) InsertSubreddit ¶
func (conn *Connection) InsertSubreddit(name string) error
func (*Connection) UpdateWatermark ¶
func (conn *Connection) UpdateWatermark(input UpdateWatermarkInput) error
func (*Connection) UpsertSubreddit ¶
func (conn *Connection) UpsertSubreddit(name string) error
type NewConnectionInput ¶
Click to show internal directories.
Click to hide internal directories.