azure

package

v0.3.0 Latest Latest Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	ErrUnsupportedEventSource = fmt.Errorf("unsupported event source")
)

This section is empty.

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

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

func (p *Processor) EventDataProcessor(activityLogEvent *azure.ActivityLogEventRecord) (commons.DataAdapter[*azure.ActivityLogEventRecord], error)

func (p *Processor) GetDataFromLiveEvent(event entities.PipelineEvent) ([]byte, error)

func (p *Processor) Process(input entities.PipelineEvent) (entities.PipelineEvent, error)