Struct Session 

pub struct Session {
    pub id: String,
    pub graph_id: String,
    pub current_task_id: String,
    pub status_message: Option<String>,
    pub context: Context,
    pub version: u64,
}

Session information

Sessions carry an optimistic-locking version: storage backends reject a save whose version does not match the stored one (see GraphError::SessionConflict), so concurrent runs of the same session fail loudly instead of silently losing updates.

Fields

id: String

graph_id: String

current_task_id: String

status_message: Option<String>

Optional status message from the last executed task

context: Context

version: u64

Optimistic-locking version, incremented by storage on every successful save. Defaults to 0 for new / pre-0.6 sessions.

Implementations

impl Session

pub fn new_from_task(sid: String, task_name: &str) -> Self

Create a new session positioned at the given task.

graph_id defaults to "default"; use Session::with_graph_id if you store multiple graphs.

pub fn with_graph_id(self, graph_id: impl Into<String>) -> Self

Set the graph this session belongs to.

Trait Implementations

impl Clone for Session

fn clone(&self) -> Session

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Session

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Session

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Session

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.