Documentation
¶
Index ¶
- Constants
- func ExecuteAthenaQuery(ctx context.Context, query string, campaignId int64) (map[string]string, [][]string, error)
- func MapAthenaResponse(response *athena.GetQueryResultsOutput) (map[string]string, [][]string)
- func PutObjectInBucket(data []byte, bucket string, key string) error
- func RunAthenaQuery(query string, campaignId int64) (*athena.GetQueryResultsOutput, error)
Constants ¶
View Source
const ( CONST_AWS_REGION = "ap-south-1" CONST_ATHENA_QUERY_SLEEP_DURATION = 2 // in seconds CONST_ATHENA_QUERY_SUCCESS = "SUCCEEDED" CONST_ATHENA_QUERY_FAILED = "FAILED" CONST_DATABASE_REWARDS_GATEWAY = "rewards_gateway" CONST_NIL = "NIL" )
Variables ¶
This section is empty.
Functions ¶
func ExecuteAthenaQuery ¶
func MapAthenaResponse ¶
func MapAthenaResponse(response *athena.GetQueryResultsOutput) (map[string]string, [][]string)
func RunAthenaQuery ¶
func RunAthenaQuery(query string, campaignId int64) (*athena.GetQueryResultsOutput, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.