gluetables

Documentation

Index

• func BuildSignature(tables ...*loganalysisglue.GlueTableMetadata) (string, error)
• func DeployedLogTypes(ctx context.Context, glueClient glueiface.GlueAPI, logTypes []string) ([]string, error)
• func DeployedTablesSignature(glueClient glueiface.GlueAPI) (deployedLogTablesSignature string, err error)
• func ExpandLogTables(tables ...*loganalysisglue.GlueTableMetadata) (expanded []*loganalysisglue.GlueTableMetadata)
• type TablesForLogType
  • func CreateOrUpdateGlueTables(glueClient glueiface.GlueAPI, bucket string, ...) (*TablesForLogType, error)

Functions

func BuildSignature

func BuildSignature(tables ...*loganalysisglue.GlueTableMetadata) (string, error)

func DeployedLogTypes

func DeployedLogTypes(ctx context.Context, glueClient glueiface.GlueAPI, logTypes []string) ([]string, error)

DeployedLogTypes scans glue API to filter log types with deployed tables

func DeployedTablesSignature

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

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

func ExpandLogTables

func ExpandLogTables(tables ...*loganalysisglue.GlueTableMetadata) (expanded []*loganalysisglue.GlueTableMetadata)

Expand log tables expands tables from the log processing database to include additional tables (rules, ruleErrors)

Types

type TablesForLogType

type TablesForLogType struct {
	LogTable       *loganalysisglue.GlueTableMetadata
	RuleTable      *loganalysisglue.GlueTableMetadata
	RuleErrorTable *loganalysisglue.GlueTableMetadata
}

func CreateOrUpdateGlueTables

func CreateOrUpdateGlueTables(glueClient glueiface.GlueAPI, bucket string,
	logTable *loganalysisglue.GlueTableMetadata) (*TablesForLogType, error)

CreateOrUpdateGlueTables, given a log meta data table, creates all tables related to this log table in the glue catalog.