Documentation
¶
Index ¶
- func Usage() string
- func ValidateOptions(options *Options)
- type Connection
- func (conn *Connection) CreateDatabase()
- func (conn *Connection) InsertMaps(tagsSet map[string]bool, maps []map[string]interface{})
- func (conn *Connection) QueryForLastTimestamp(mainColumnName string) time.Time
- func (conn *Connection) QueryForLastTimestampForTag(mainColumnName, tagName, tagValue string) time.Time
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateOptions ¶
func ValidateOptions(options *Options)
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(opts *Options, configPath string) *Connection
func (*Connection) CreateDatabase ¶
func (conn *Connection) CreateDatabase()
func (*Connection) InsertMaps ¶
func (conn *Connection) InsertMaps(tagsSet map[string]bool, maps []map[string]interface{})
func (*Connection) QueryForLastTimestamp ¶
func (conn *Connection) QueryForLastTimestamp(mainColumnName string) time.Time
func (*Connection) QueryForLastTimestampForTag ¶
func (conn *Connection) QueryForLastTimestampForTag(mainColumnName, tagName, tagValue string) time.Time
Source Files
Click to show internal directories.
Click to hide internal directories.