gluetables

Documentation

Index

• func DeployedLogTypes(ctx context.Context, glueClient glueiface.GlueAPI, logTypes []string) ([]string, error)
• func LogTypeTableMeta(entry logtypes.Entry) *loganalysisglue.GlueTableMetadata
• func ResolveTables(ctx context.Context, resolver logtypes.Resolver, logTypes ...string) ([]*loganalysisglue.GlueTableMetadata, error)
• type TablesForLogType
  • func CreateOrUpdateGlueTables(glueClient glueiface.GlueAPI, bucket string, ...) (*TablesForLogType, error)

Functions

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 LogTypeTableMeta

func LogTypeTableMeta(entry logtypes.Entry) *loganalysisglue.GlueTableMetadata

func ResolveTables

func ResolveTables(ctx context.Context, resolver logtypes.Resolver, logTypes ...string) ([]*loganalysisglue.GlueTableMetadata, error)

ResolveTables is a helper to resolve all glue table metadata for all log types

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.