Share via


FunctionExecutor<TInput> Class

Definition

Executes a user-provided asynchronous function in response to workflow messages of the specified input type.

public class FunctionExecutor<TInput> : Microsoft.Agents.AI.Workflows.Executor<TInput>
type FunctionExecutor<'Input> = class
    inherit Executor<'Input>
Public Class FunctionExecutor(Of TInput)
Inherits Executor(Of TInput)

Type Parameters

TInput

The type of input message.

Inheritance
FunctionExecutor<TInput>

Constructors

Name Description
FunctionExecutor<TInput>(String, Action<TInput,IWorkflowContext,CancellationToken>, ExecutorOptions, IEnumerable<Type>, IEnumerable<Type>, Boolean)

Creates a new instance of the FunctionExecutor<TInput> class.

FunctionExecutor<TInput>(String, Func<TInput,IWorkflowContext, CancellationToken,ValueTask>, ExecutorOptions, IEnumerable<Type>, IEnumerable<Type>, Boolean)

Executes a user-provided asynchronous function in response to workflow messages of the specified input type.

Properties

Name Description
Id

A unique identifier for the executor.

(Inherited from Executor)
InputTypes

A set of Types, representing the messages this executor can handle.

(Inherited from Executor)
Options

Gets the configuration options for the executor.

(Inherited from Executor)
OutputTypes

A set of Types, representing the messages this executor can produce as output.

(Inherited from Executor)

Methods

Name Description
CanHandle(Type)

Checks if the executor can handle a specific message type.

(Inherited from Executor)
ConfigureProtocol(ProtocolBuilder)

Configures the protocol by setting up routes and declaring the message types used for sending and yielding output.

DescribeProtocol()

Describes the protocol for communication with this Executor.

(Inherited from Executor)
ExecuteCoreAsync(Object, TypeId, IWorkflowContext, CancellationToken)

Process an incoming message using the registered handlers.

(Inherited from Executor)
HandleAsync(TInput, IWorkflowContext, CancellationToken)

Handles the incoming message asynchronously.

InitializeAsync(IWorkflowContext, CancellationToken)

Perform any asynchronous initialization required by the executor. This method is called once per executor instance,

(Inherited from Executor)
OnCheckpointingAsync(IWorkflowContext, CancellationToken)

Invoked before a checkpoint is saved, allowing custom pre-save logic in derived classes.

(Inherited from Executor)
OnCheckpointRestoredAsync(IWorkflowContext, CancellationToken)

Invoked after a checkpoint is loaded, allowing custom post-load logic in derived classes.

(Inherited from Executor)

Extension Methods

Name Description
BindExecutor(Executor)

Configures an Executor instance for use in a workflow.

Applies to