executor

Documentation

Index

• Constants
• Variables
• func GetQueryResponse(rows *sql.Rows) (map[string]string, [][]interface{}, []string, error)
• func InitializeAthenaClient(config *driverConfig.AthenaConfig) error
• func InitializeMysqlClient(config *driverConfig.MysqlConfig) error
• func InitializePrestoClient(config *driverConfig.PrestoConfig) error
• func InitializeTrinoClient(config *driverConfig.TrinoConfig) error
• func MapAthenaResponse(response *athena.GetQueryResultsOutput) (map[string]string, [][]interface{}, []string)
• func RunAthenaQuery(query string) (*athena.GetQueryResultsOutput, error)
• type Executor

Constants

const (
	CONST_ATHENA_QUERY_SLEEP_DURATION = 2 // in seconds
	CONST_ATHENA_QUERY_SUCCESS        = "SUCCEEDED"
	CONST_ATHENA_QUERY_FAILED         = "FAILED"
	CONST_NIL                         = "NIL"
	CONST_DATABASE_REWARDS_GATEWAY    = "rewards_gateway"
)

const READ_REPLICA_DRIVER_INDEX = 1

Variables

var (
	AthenaExecutorInstance *athenaExecutor

	AtheClient *athena.Athena
)

var (
	MysqlExecutorInstance *mysqlExecutor

	MysqlClient *sql.DB
)

var (
	PrestoExecutorInstance *prestoExecutor

	PrestoClient *sql.DB
)

var (
	TrinoExecutorInstance *trinoExecutor

	TrinoClient *sql.DB
)

Functions

func GetQueryResponse

func GetQueryResponse(rows *sql.Rows) (map[string]string, [][]interface{}, []string, error)

func InitializeAthenaClient

func InitializeAthenaClient(config *driverConfig.AthenaConfig) error

func InitializeMysqlClient

func InitializeMysqlClient(config *driverConfig.MysqlConfig) error

func InitializePrestoClient

func InitializePrestoClient(config *driverConfig.PrestoConfig) error

func InitializeTrinoClient

func InitializeTrinoClient(config *driverConfig.TrinoConfig) error

func MapAthenaResponse

func MapAthenaResponse(response *athena.GetQueryResultsOutput) (map[string]string, [][]interface{}, []string)

func RunAthenaQuery

func RunAthenaQuery(query string) (*athena.GetQueryResultsOutput, error)

Types

type Executor

type Executor interface {
	Execute(query string) (map[string]string, [][]interface{}, error)
}