gluetables

Documentation

Index

• func CreateOrUpdateGlueTables(glueClient glueiface.GlueAPI, bucket string, ...) (ruleTable *awsglue.GlueTableMetadata, err error)
• func CreateOrUpdateGlueTablesForLogType(glueClient glueiface.GlueAPI, logType, bucket string) (*awsglue.GlueTableMetadata, *awsglue.GlueTableMetadata, error)
• func DeployedLogTables(glueClient glueiface.GlueAPI) (deployedLogTables []*awsglue.GlueTableMetadata, err error)
• func DeployedTablesSignature(glueClient glueiface.GlueAPI) (deployedLogTablesSignature string, err error)

Functions

func CreateOrUpdateGlueTables

func CreateOrUpdateGlueTables(glueClient glueiface.GlueAPI, bucket string,
	logTable *awsglue.GlueTableMetadata) (ruleTable *awsglue.GlueTableMetadata, err error)

CreateOrUpdateGlueTables, given a log meta data table, creates a log and rule table in the glue catalog

func CreateOrUpdateGlueTablesForLogType

func CreateOrUpdateGlueTablesForLogType(glueClient glueiface.GlueAPI, logType,
	bucket string) (*awsglue.GlueTableMetadata, *awsglue.GlueTableMetadata, error)

CreateOrUpdateGlueTablesForLogType uses the parser registry to get the table meta data and creates tables in the glue catalog

func DeployedLogTables

func DeployedLogTables(glueClient glueiface.GlueAPI) (deployedLogTables []*awsglue.GlueTableMetadata, err error)

DeployedLogTables returns the glue tables from the registry that have been deployed

func DeployedTablesSignature

func DeployedTablesSignature(glueClient glueiface.GlueAPI) (deployedLogTablesSignature string, err error)

DeployedTablesSignature returns a string "signature" for the schema of the deployed tables used to detect change