forwarder

Documentation

Index

• Constants
• type ComplianceChange
• type ResourceAttributes
• type ResourceChange
• type StreamHandler
  • func (sh *StreamHandler) Run(ctx context.Context, logger *zap.Logger, event *events.DynamoDBEvent) (err error)

Constants

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

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

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

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