azure

package

v0.5.2 Latest Latest Go to latest Published: Jul 28, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

This section is empty.

View Source

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

This section is empty.

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

func NewClient(getter azure.ClientInterface, source string) *AzureClient

func (a *AzureClient) GetData(ctx context.Context, event *azure.ActivityLogEventRecord) ([]byte, error)

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)