vpc_flow_log

package

v0.14.2 Latest Latest Go to latest Published: Jul 28, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/turbot/tailpipe-plugin-aws

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewVPCFlowLogExtractor(format formats.Format) artifact_source.Extractor
func NewVPCFlowLogTableFormat() formats.Format
type VPCFlowLogCloudWatchMapper
- func NewVPCFlowLogCloudWatchMapper(format *VPCFlowLogTableFormat) (*VPCFlowLogCloudWatchMapper, error)
- func (m *VPCFlowLogCloudWatchMapper) Identifier() string
- func (m *VPCFlowLogCloudWatchMapper) Map(ctx context.Context, a any, opts ...mappers.MapOption[*types.DynamicRow]) (*types.DynamicRow, error)
type VPCFlowLogExtractor
- func (c *VPCFlowLogExtractor) Extract(_ context.Context, a any) ([]any, error)
- func (c *VPCFlowLogExtractor) Identifier() string
type VPCFlowLogTableFormat
type VpcFlowLogTable

Constants ¶

View Source

const VpcFlowLogTableIdentifier = "aws_vpc_flow_log"

View Source

const VpcFlowLogTableNilValue = "-"

Variables ¶

View Source

var VPCFlowLogTableFormatPresets = []sdkformats.Format{
	defaultVPCFlowLogTableFormat,
}

Functions ¶

func NewVPCFlowLogExtractor ¶

func NewVPCFlowLogExtractor(format formats.Format) artifact_source.Extractor

NewVPCFlowLogExtractor creates a new VPCFlowLogExtractor

func NewVPCFlowLogTableFormat ¶ added in v0.11.0

func NewVPCFlowLogTableFormat() formats.Format

Types ¶

type VPCFlowLogCloudWatchMapper ¶ added in v0.11.0

type VPCFlowLogCloudWatchMapper struct {
	// contains filtered or unexported fields
}

VPCFlowLogCloudWatchMapper is a custom mapper for VPC flow logs from CloudWatch sources. It extracts the message field from the complete CloudWatch event JSON and processes it using the existing regex mapper for VPC flow logs.

func NewVPCFlowLogCloudWatchMapper ¶ added in v0.11.0

func NewVPCFlowLogCloudWatchMapper(format *VPCFlowLogTableFormat) (*VPCFlowLogCloudWatchMapper, error)

NewVPCFlowLogCloudWatchMapper creates a new CloudWatch mapper for VPC flow logs

func (*VPCFlowLogCloudWatchMapper) Identifier ¶ added in v0.11.0

func (m *VPCFlowLogCloudWatchMapper) Identifier() string

Identifier returns the mapper identifier

func (*VPCFlowLogCloudWatchMapper) Map ¶ added in v0.11.0

func (m *VPCFlowLogCloudWatchMapper) Map(ctx context.Context, a any, opts ...mappers.MapOption[*types.DynamicRow]) (*types.DynamicRow, error)

Map processes CloudWatch event data by extracting the message field and processing it with the regex mapper

type VPCFlowLogExtractor ¶

type VPCFlowLogExtractor struct {
	Format formats.Format
}

VPCFlowLogExtractor is an extractor that receives JSON serialised VPCFlowLogBatch objects and extracts VPCFlowLog records from them

func (*VPCFlowLogExtractor) Extract ¶

func (c *VPCFlowLogExtractor) Extract(_ context.Context, a any) ([]any, error)

Extract unmarshalls the artifact data as a VPCFlowLogBatch and returns the VPCFlowLog records

func (*VPCFlowLogExtractor) Identifier ¶

func (c *VPCFlowLogExtractor) Identifier() string

type VPCFlowLogTableFormat ¶ added in v0.11.0

type VPCFlowLogTableFormat struct {
	// the name of this format instance
	Name string `hcl:"name,label"`
	// Description of the format
	Description string `hcl:"description,optional"`
	// the layout of the log line
	Layout string `hcl:"layout"`
}

func (*VPCFlowLogTableFormat) GetDescription ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) GetDescription() string

func (*VPCFlowLogTableFormat) GetMapper ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) GetMapper() (mappers.Mapper[*types.DynamicRow], error)

func (*VPCFlowLogTableFormat) GetName ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) GetName() string

GetName returns the format instance name

func (*VPCFlowLogTableFormat) GetProperties ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) GetProperties() map[string]string

func (*VPCFlowLogTableFormat) GetRegex ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) GetRegex() (string, error)

func (*VPCFlowLogTableFormat) Identifier ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) Identifier() string

Identifier returns the format TYPE

func (*VPCFlowLogTableFormat) SetName ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) SetName(name string)

SetName sets the name of this format instance

func (*VPCFlowLogTableFormat) Validate ¶ added in v0.11.0

func (a *VPCFlowLogTableFormat) Validate() error

type VpcFlowLogTable ¶

type VpcFlowLogTable struct {
	table.CustomTableImpl
}

VpcFlowLogTable - table for VPC Flow Logs

func (*VpcFlowLogTable) EnrichRow ¶

func (c *VpcFlowLogTable) EnrichRow(row *types.DynamicRow, sourceEnrichmentFields schema.SourceEnrichment) (*types.DynamicRow, error)

EnrichRow implements table.Table

func (*VpcFlowLogTable) GetDefaultFormat ¶ added in v0.11.0

func (c *VpcFlowLogTable) GetDefaultFormat() formats.Format

func (*VpcFlowLogTable) GetDescription ¶ added in v0.8.0

func (c *VpcFlowLogTable) GetDescription() string

func (*VpcFlowLogTable) GetSourceMetadata ¶

func (c *VpcFlowLogTable) GetSourceMetadata() ([]*table.SourceMetadata[*types.DynamicRow], error)

func (*VpcFlowLogTable) GetTableDefinition ¶ added in v0.11.0

func (c *VpcFlowLogTable) GetTableDefinition() *schema.TableSchema

func (*VpcFlowLogTable) Identifier ¶

func (c *VpcFlowLogTable) Identifier() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL