gcpaggregator

package

v0.5.0 Latest Latest Go to latest Published: Jul 23, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

Index ¶

func New(logger *logrus.Logger, authOptions config.AuthOptions) (entities.Processor, error)
type GCPCloudVendorAggregator

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(logger *logrus.Logger, authOptions config.AuthOptions) (entities.Processor, error)

Types ¶

type GCPCloudVendorAggregator ¶

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

func (*GCPCloudVendorAggregator) EventDataProcessor ¶

func (c *GCPCloudVendorAggregator) EventDataProcessor(event gcppubsubevents.IInventoryEvent) (commons.DataAdapter[gcppubsubevents.IInventoryEvent], error)

func (*GCPCloudVendorAggregator) ParseEvent ¶

func (c *GCPCloudVendorAggregator) ParseEvent(event entities.PipelineEvent) (gcppubsubevents.IInventoryEvent, error)

func (*GCPCloudVendorAggregator) Process ¶

func (c *GCPCloudVendorAggregator) Process(input entities.PipelineEvent) (entities.PipelineEvent, error)

Source Files ¶

View all Source files

processor.go

Directories ¶

Path	Synopsis
clients
runservice
storage
services
service
storage

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