Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[WIP] Add logs at FunctionsDurableClient For Investigations #3031

Draft
wants to merge 6 commits into
base: dev
Choose a base branch
from
Draft

[WIP] Add logs at FunctionsDurableClient For Investigations #3031

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
a6c26c3
initial commit
nytian Feb 4, 2025
e405f79
Merge branch 'dev' into nytian/grpclog
nytian Feb 5, 2025
f5e0ce7
update version
nytian Feb 5, 2025
2774f89
use extensioninformationevent log
nytian Feb 5, 2025
a099f4d
update log
nytian Feb 5, 2025
f9976b4
update worker extension version suffix name
nytian Feb 5, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion src/WebJobs.Extensions.DurableTask/WebJobs.Extensions.DurableTask.csproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,8 @@
<RootNamespace>Microsoft.Azure.WebJobs.Extensions.DurableTask</RootNamespace>
<MajorVersion>3</MajorVersion>
<MinorVersion>0</MinorVersion>
<PatchVersion>2</PatchVersion>
<PatchVersion>3</PatchVersion>
<VersionSuffix>private</VersionSuffix>
<VersionPrefix>$(MajorVersion).$(MinorVersion).$(PatchVersion)</VersionPrefix>
<FileVersion>$(MajorVersion).$(MinorVersion).$(PatchVersion)</FileVersion>
<AssemblyVersion>$(MajorVersion).0.0.0</AssemblyVersion>
Expand Down
349 changes: 349 additions & 0 deletions src/Worker.Extensions.DurableTask/EtwEventSource.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,349 @@
// Copyright (c) .NET Foundation. All rights reserved.
// Licensed under the MIT License. See LICENSE in the project root for license information.
#nullable enable
using System.Diagnostics.Tracing;

namespace Microsoft.Azure.Functions.Worker.Extensions.DurableTask
{
/// <summary>
/// ETW Event Provider for the WebJobs.Extensions.DurableTask extension.
/// </summary>
[EventSource(Name = "WebJobs-Extensions-DurableTask")]
internal sealed class EtwEventSource : EventSource
{
public static readonly EtwEventSource Instance = new EtwEventSource();

// Private .ctor - callers should use the shared static instance.
private EtwEventSource()
{ }

#pragma warning disable SA1313 // Parameter names should begin with lower-case letter

[Event(201, Level = EventLevel.Informational, Version = 2)]
public void FunctionScheduled(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(201, TaskHub, AppName, SlotName, FunctionName, InstanceId, Reason, FunctionType, ExtensionVersion, IsReplay);
}

[Event(202, Level = EventLevel.Informational, Version = 5)]
public void FunctionStarting(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
int TaskEventId,
string InstanceId,
string? Input,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(202, TaskHub, AppName, SlotName, FunctionName, TaskEventId, InstanceId, Input ?? "(null)", FunctionType, ExtensionVersion, IsReplay);
}

[Event(203, Level = EventLevel.Informational, Version = 4)]
public void FunctionAwaited(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(203, TaskHub, AppName, SlotName, FunctionName, InstanceId, FunctionType, ExtensionVersion, IsReplay);
}

[Event(204, Level = EventLevel.Informational, Version = 2)]
public void FunctionListening(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(204, TaskHub, AppName, SlotName, FunctionName, InstanceId, Reason, FunctionType, ExtensionVersion, IsReplay);
}

[Event(205, Level = EventLevel.Informational, Version = 2)]
public void ExternalEventRaised(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string EventName,
string? Input,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(205, TaskHub, AppName, SlotName, FunctionName, InstanceId, EventName, Input ?? "(null)", FunctionType, ExtensionVersion, IsReplay);
}

[Event(206, Level = EventLevel.Informational, Version = 5)]
public void FunctionCompleted(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
int TaskEventId,
string InstanceId,
string? Output,
bool ContinuedAsNew,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(206, TaskHub, AppName, SlotName, FunctionName, TaskEventId, InstanceId, Output ?? "(null)", ContinuedAsNew, FunctionType, ExtensionVersion, IsReplay);
}

[Event(207, Level = EventLevel.Warning, Version = 2)]
public void FunctionTerminated(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(207, TaskHub, AppName, SlotName, FunctionName, InstanceId, Reason, FunctionType, ExtensionVersion, IsReplay);
}

[Event(208, Level = EventLevel.Error, Version = 4)]
public void FunctionFailed(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
int TaskEventId,
string InstanceId,
string Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(208, TaskHub, AppName, SlotName, FunctionName, TaskEventId, InstanceId, Reason, FunctionType, ExtensionVersion, IsReplay);
}

[Event(209, Level = EventLevel.Informational, Version = 2)]
public void TimerExpired(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(209, TaskHub, AppName, SlotName, FunctionName, InstanceId, Reason, FunctionType, ExtensionVersion, IsReplay);
}


[Event(213, Level = EventLevel.Informational)]
public void ExtensionInformationalEvent(
string TaskHub,
string AppName,
string SlotName,
string? FunctionName,
string? InstanceId,
string Details,
string ExtensionVersion)
{
this.WriteEvent(213, TaskHub, AppName, SlotName, FunctionName ?? string.Empty, InstanceId ?? string.Empty, Details, ExtensionVersion);
}

[Event(214, Level = EventLevel.Warning)]
public void ExtensionWarningEvent(
string TaskHub,
string AppName,
string SlotName,
string? FunctionName,
string? InstanceId,
string Details,
string ExtensionVersion)
{
this.WriteEvent(214, TaskHub, AppName, SlotName, FunctionName ?? string.Empty, InstanceId ?? string.Empty, Details, ExtensionVersion);
}

[Event(215, Level = EventLevel.Informational, Version = 2)]
public void ExternalEventSaved(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string EventName,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(215, TaskHub, AppName, SlotName, FunctionName, InstanceId, EventName, FunctionType, ExtensionVersion, IsReplay);
}

[Event(216, Level = EventLevel.Informational)]
public void FunctionRewound(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string? Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(216, TaskHub, AppName, SlotName, FunctionName, InstanceId, Reason ?? string.Empty, FunctionType, ExtensionVersion, IsReplay);
}

[Event(217, Level = EventLevel.Informational)]
public void EntityOperationQueued(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string OperationId,
string OperationName,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(217, TaskHub, AppName, SlotName, FunctionName, InstanceId, OperationId, OperationName, FunctionType, ExtensionVersion, IsReplay);
}

[Event(218, Level = EventLevel.Informational)]
public void EntityResponseReceived(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string OperationId,
string? Result,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(218, TaskHub, AppName, SlotName, FunctionName, InstanceId, OperationId, Result ?? "(null)", FunctionType, ExtensionVersion, IsReplay);
}

[Event(219, Level = EventLevel.Informational, Version = 2)]
public void EntityLockAcquired(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string RequestingInstanceId,
string? RequestingExecutionId,
string RequestId,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(219, TaskHub, AppName, SlotName, FunctionName, InstanceId, RequestingInstanceId, RequestingExecutionId ?? "", RequestId, FunctionType, ExtensionVersion, IsReplay);
}

[Event(220, Level = EventLevel.Informational)]
public void EntityLockReleased(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string RequestingInstance,
string RequestId,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(220, TaskHub, AppName, SlotName, FunctionName, InstanceId, RequestingInstance, RequestId, FunctionType, ExtensionVersion, IsReplay);
}

[Event(221, Level = EventLevel.Informational)]
public void OperationCompleted(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string OperationId,
string OperationName,
string? Input,
string? Output,
double Duration,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(221, TaskHub, AppName, SlotName, FunctionName, InstanceId, OperationId, OperationName, Input ?? "(null)", Output ?? "(null)", Duration, FunctionType, ExtensionVersion, IsReplay);
}

[Event(222, Level = EventLevel.Error)]
public void OperationFailed(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string OperationId,
string OperationName,
string? Input,
string Exception,
double Duration,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(222, TaskHub, AppName, SlotName, FunctionName, InstanceId, OperationId, OperationName, Input ?? "(null)", Exception, Duration, FunctionType, ExtensionVersion, IsReplay);
}

[Event(223, Level = EventLevel.Informational)]
public void ExtensionConfiguration(
string TaskHub,
string AppName,
string SlotName,
string Details,
string ExtensionVersion)
{
this.WriteEvent(223, TaskHub, AppName, SlotName, Details, ExtensionVersion);
}

[Event(224, Level = EventLevel.Warning)]
public void FunctionAborted(
string TaskHub,
string AppName,
string SlotName,
string FunctionName,
string InstanceId,
string Reason,
string FunctionType,
string ExtensionVersion,
bool IsReplay)
{
this.WriteEvent(224, TaskHub, AppName, SlotName, FunctionName, InstanceId, Reason, FunctionType, ExtensionVersion, IsReplay);
}

#pragma warning restore SA1313 // Parameter names should begin with lower-case letter
}
}
Loading
Loading