app

package

v0.0.0-...-b4828b3 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

Processor is responsible to process events

func NewProcessor(configurationPath string, platformConfigurationPath string) (*Processor, error)

NewProcessor returns a new Processor

func (p *Processor) GetStatus() status.Status

GetStatus returns the processor's status based on its workers' readiness

func (p *Processor) GetTriggers() []trigger.Trigger

GetTriggers returns triggers

func (p *Processor) GetWorkers() []*worker.Worker

GetWorkers returns workers

func (p *Processor) Start() error

Start starts the processor

func (p *Processor) Stop()

Stop stops the processor