Class AgentMessenger

Namespace

Microsoft.AutoGen.Core

Assembly

Microsoft.AutoGen.Core.dll

public sealed class AgentMessenger

Inheritance

object

AgentMessenger

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AgentMessenger(IAgentWorker, DistributedContextPropagator)

public AgentMessenger(IAgentWorker worker, DistributedContextPropagator distributedContextPropagator)

Parameters

worker IAgentWorker

distributedContextPropagator DistributedContextPropagator

Methods

ExtractMetadata(MapField<string, CloudEventAttributeValue>)

public IDictionary<string, string> ExtractMetadata(MapField<string, CloudEvent.Types.CloudEventAttributeValue> metadata)

Parameters

metadata MapField<string, CloudEvent.Types.CloudEventAttributeValue>

Returns

IDictionary<string, string>

ExtractMetadata(IDictionary<string, string>)

public IDictionary<string, string> ExtractMetadata(IDictionary<string, string> metadata)

Parameters

metadata IDictionary<string, string>

Returns

IDictionary<string, string>

GetTraceIdAndState(MapField<string, CloudEventAttributeValue>)

public (string?, string?) GetTraceIdAndState(MapField<string, CloudEvent.Types.CloudEventAttributeValue> metadata)

Parameters

metadata MapField<string, CloudEvent.Types.CloudEventAttributeValue>

Returns

(string, string)

GetTraceIdAndState(IDictionary<string, string>)

public (string?, string?) GetTraceIdAndState(IDictionary<string, string> metadata)

Parameters

metadata IDictionary<string, string>

Returns

(string, string)

PublishEventAsync(CloudEvent, CancellationToken)

public ValueTask PublishEventAsync(CloudEvent @event, CancellationToken cancellationToken = default)

Parameters

event CloudEvent

cancellationToken CancellationToken

Returns

ValueTask

ReadAsync(AgentId, CancellationToken)

public ValueTask<AgentState> ReadAsync(AgentId agentId, CancellationToken cancellationToken = default)

Parameters

agentId AgentId

cancellationToken CancellationToken

Returns

ValueTask<AgentState>

SendMessageAsync(Message, CancellationToken)

public ValueTask SendMessageAsync(Message message, CancellationToken cancellationToken = default)

Parameters

message Message

cancellationToken CancellationToken

Returns

ValueTask

SendRequestAsync(Agent, RpcRequest, CancellationToken)

public ValueTask SendRequestAsync(Agent agent, RpcRequest request, CancellationToken cancellationToken = default)

Parameters

agent Agent

request RpcRequest

cancellationToken CancellationToken

Returns

ValueTask

SendResponseAsync(RpcRequest, RpcResponse, CancellationToken)

public ValueTask SendResponseAsync(RpcRequest request, RpcResponse response, CancellationToken cancellationToken = default)

Parameters

request RpcRequest

response RpcResponse

cancellationToken CancellationToken

Returns

ValueTask

StoreAsync(AgentState, CancellationToken)

public ValueTask StoreAsync(AgentState value, CancellationToken cancellationToken = default)

Parameters

value AgentState

cancellationToken CancellationToken

Returns

ValueTask

Update(CloudEvent, Activity?)

public void Update(CloudEvent cloudEvent, Activity? activity = null)

Parameters

cloudEvent CloudEvent

activity Activity

Update(RpcRequest, Activity?)

public void Update(RpcRequest request, Activity? activity = null)

Parameters

request RpcRequest

activity Activity