processors

package

v0.5.4 Latest Latest Go to latest Published: Oct 4, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
type CloseableProcessor
type Processors
- func New(logger *logrus.Logger, cfg config.Processors) (*Processors, error)
- func (p *Processors) Close() error
- func (p *Processors) Process(_ context.Context, message entities.PipelineEvent) (entities.PipelineEvent, error)

Constants ¶

const (
	Mapper                = "mapper"
	Filter                = "filter"
	RPC                   = "rpc-plugin"
	CloudVendorAggregator = "cloud-vendor-aggregator"
)

Variables ¶

View Source

var (
	ErrProcessorNotSupported = errors.New("processor not supported")
)

Functions ¶

This section is empty.

Types ¶

type CloseableProcessor ¶ added in v0.3.0

type CloseableProcessor interface {
	Close() error
}

type Processors ¶

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

func New ¶

func New(logger *logrus.Logger, cfg config.Processors) (*Processors, error)

func (*Processors) Close ¶ added in v0.3.0

func (p *Processors) Close() error

func (*Processors) Process ¶

func (p *Processors) Process(_ context.Context, message entities.PipelineEvent) (entities.PipelineEvent, error)

Source Files ¶

View all Source files

processor.go

Directories ¶

Path	Synopsis
cloud-vendor-aggregator
aws
aws/services
aws/services/lambda
aws/services/s3
azure
commons
config
gcp
gcp/clients/runservice
gcp/clients/storage
gcp/services/service
gcp/services/storage
filter
hcgp
mapper

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