sql_api

package

v0.0.0-...-cfc85e1 Latest Latest Go to latest Published: Oct 4, 2024 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SQLAPIParams struct {
	StartAt time.Time
	EndAt   time.Time
}

func ParseOpts(opts map[string]interface{}) (SQLAPIParams, error)

type SQLAPISource struct {
	Model    *models.Model
	Endpoint string
	APIToken string
	Query    string
	Date     string
}

func (s *SQLAPISource) Close() error

func (s *SQLAPISource) FetchData(opts map[string]interface{}) ([]map[string]interface{}, error)

func (s *SQLAPISource) Init(config map[string]interface{}, model *models.Model) error

func (s *SQLAPISource) Transform(item interface{}) (map[string]interface{}, error)