query

Documentation

Index

• func Create(request events.APIGatewayProxyRequest, t table.Table, s storage.Storage) (events.APIGatewayProxyResponse, error)
• func Delete(request events.APIGatewayProxyRequest, t table.Table, s storage.Storage) (events.APIGatewayProxyResponse, error)
• func Run(s storage.Storage, t table.Table) (events.APIGatewayProxyResponse, error)

Functions

func Create

func Create(request events.APIGatewayProxyRequest, t table.Table, s storage.Storage) (events.APIGatewayProxyResponse, error)

Create adds a query to S3 for periodic execution

func Delete

func Delete(request events.APIGatewayProxyRequest, t table.Table, s storage.Storage) (events.APIGatewayProxyResponse, error)

Delete removes a query from S3 - internal use only

func Run

func Run(s storage.Storage, t table.Table) (events.APIGatewayProxyResponse, error)

Run executes all stored queries and returns results to subscribers