engine

Documentation

Index

• func CreateS3Node(events []engine.Event, logger *zerolog.Logger, config *config.Config, ...) ([]map[string]interface{}, []string, []string, error)
• func ProcessMessage(ctx context.Context, logger *zerolog.Logger, consumer *common.Consumer, ...) error
• func PulumiMapper(ctx context.Context, logger *zerolog.Logger, consumer *common.Consumer, ...) error
• type PulumiIacMetadata
• type PulumiNode
  • func CreatePulumiNodes(events []engine.Event, logger *zerolog.Logger, config *config.Config, ...) (result []PulumiNode, assetTypesWithRegions []string, err error)

Functions

func CreateS3Node

func CreateS3Node(events []engine.Event, logger *zerolog.Logger, config *config.Config, consumer *common.Consumer, vcsData map[string]interface{}) ([]map[string]interface{}, []string, []string, error)

func ProcessMessage

func ProcessMessage(ctx context.Context, logger *zerolog.Logger, consumer *common.Consumer, message string) error

func PulumiMapper

func PulumiMapper(
	ctx context.Context,
	logger *zerolog.Logger,
	consumer *common.Consumer,
	lastUpdate *int64, resourceCount *int) error

Types

type PulumiIacMetadata

type PulumiIacMetadata struct {
	StackId          string                   `json:"stackId"`
	StackName        string                   `json:"stackName"`
	ProjectName      string                   `json:"projectName"`
	OrganizationName string                   `json:"organizationName"`
	PulumiType       string                   `json:"pulumiType"`
	PulumiState      string                   `json:"pulumiState"`
	PulumiDrifts     []map[string]interface{} `json:"pulumiDrifts"`
	VcsRepo          string                   `json:"vcsRepo"`
	VcsProvider      string                   `json:"vcsProvider"`
}

type PulumiNode

type PulumiNode struct {
	Type                string
	AccountId           string
	StackId             string
	Iac                 string
	PulumiIntegrationId string
	Arn                 string
	Region              string
	ProviderAccountId   string
	AwsIntegration      string
	K8sIntegration      string
	Location            string
	Name                string
	ResourceId          string
	AssetId             string
	Kind                string
	IsOrchestrator      bool
	UpdatedAt           int64
	Metadata            PulumiIacMetadata
	ObjectType          string
	Attributes          string
}

func CreatePulumiNodes

func CreatePulumiNodes(events []engine.Event, logger *zerolog.Logger, config *config.Config, consumer *common.Consumer, vcsData map[string]interface{}) (result []PulumiNode, assetTypesWithRegions []string, err error)