Class WorkflowStreamState

Serializable Workflow Streams state for continue-as-new.

public sealed class WorkflowStreamState

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

WARNING: Workflow Streams is experimental and may change.

Gets or sets the global offset represented by the start of Log.

[JsonPropertyName("base_offset")]
public long BaseOffset { get; set; }

Gets or sets the retained stream log.

[JsonPropertyName("log")]
public IReadOnlyCollection<WorkflowStreamWireItem> Log { get; set; }

Gets or sets each publisher's last-seen Unix timestamp in seconds.

[JsonPropertyName("publisher_last_seen")]
public IReadOnlyDictionary<string, double> PublisherLastSeen { get; set; }

Gets or sets the most recently observed sequence for each publisher.

[JsonPropertyName("publisher_sequences")]
public IReadOnlyDictionary<string, long> PublisherSequences { get; set; }