forwarder

package
v1.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2021 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ChangeTypeCreate = "CREATED"
	ChangeTypeDelete = "DELETED"
	ChangeTypeModify = "MODIFIED"
	ChangeTypeSync   = "SYNC"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ComplianceChange

type ComplianceChange struct {
	ChangeType       string `json:"changeType"`
	IntegrationID    string `json:"integrationId"`
	IntegrationLabel string `json:"integrationLabel"`
	LastUpdated      string `json:"lastUpdated"`
	PolicyID         string `json:"policyId"`
	PolicySeverity   string `json:"policySeverity"`
	ResourceID       string `json:"resourceId"`
	ResourceType     string `json:"resourceType"`
	Status           string `json:"status"`
	Suppressed       bool   `json:"suppressed"`
}

type ResourceAttributes added in v1.15.0

type ResourceAttributes struct {
	ResourceID   *string           `json:"resourceId,omitempty"`
	ResourceType *string           `json:"resourceType,omitempty"`
	TimeCreated  *string           `json:"timeCreated,omitempty"`
	AccountID    *string           `json:"accountId,omitempty"`
	Region       *string           `json:"region,omitempty"`
	ARN          *string           `json:"arn,omitempty"`
	Name         *string           `json:"name,omitempty"`
	Tags         map[string]string `json:"tags,omitempty"`
}

type ResourceChange added in v1.15.0

type ResourceChange struct {
	ChangeType       string                 `json:"changeType"`
	Changes          diff.Changelog         `json:"changes"`
	IntegrationID    string                 `json:"integrationId"`
	IntegrationLabel string                 `json:"integrationLabel"`
	LastUpdated      string                 `json:"lastUpdated"`
	ID               string                 `json:"id"`
	Resource         map[string]interface{} `json:"resource"`
	ResourceAttributes
}

type StreamHandler

type StreamHandler struct {
	FirehoseClient firehoseiface.FirehoseAPI
	LambdaClient   lambdaiface.LambdaAPI
	StreamName     string
	// contains filtered or unexported fields
}

func (*StreamHandler) Run

func (sh *StreamHandler) Run(ctx context.Context, logger *zap.Logger, event *events.DynamoDBEvent) (err error)

Run is the entry point for the datalake-forwarder lambda

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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