Struct Observation 

pub struct Observation {
    pub schema: String,
    pub deployment: String,
    pub url: String,
    pub expected: String,
    pub served: Option<BuildIdentity>,
    pub judgement: Judgement,
    pub at: String,
}

One observation of one deployment, as recorded: what was asked, what was served, what was judged and when. Everything needed to judge it again later is in the record, which is what lets Observation::rejudge answer without probing.

use majordomus_cli::served::{observe, Fetch, Fetched, GitAncestry, Observation, OBSERVATION_SCHEMA};
use std::{path::Path, time::SystemTime};
struct None_;
impl Fetch for None_ {
    fn fetch(&self, _: &str) -> Fetched { Fetched::Unreachable("no route".into()) }
}
let git = GitAncestry { root: Path::new(env!("CARGO_MANIFEST_DIR")) };
let o: Observation = observe("pages", "https://s", "build.json", &"a".repeat(40), &None_,
                              &git, SystemTime::UNIX_EPOCH);
assert_eq!(o.schema, OBSERVATION_SCHEMA);
assert_eq!(o.url, "https://s/build.json");
assert_eq!(o.at, "1970-01-01T00:00:00Z");

Fields

schema: String

Always OBSERVATION_SCHEMA.

deployment: String

Which deployment: the name the caller observed it under (pages, or a deployment object’s id).

url: String

The identity URL probed.

expected: String

The commit that was expected, full.

served: Option<BuildIdentity>

What was served, when a build identity was received.

judgement: Judgement

The judgement at the time of the observation.

at: String

When, RFC 3339 UTC.

Implementations

impl Observation

pub fn rejudge(&self, expected: &str, git: &dyn Ancestry) -> Judgement

Re-judges this record against expected now. A served commit keeps proving what it contains; a record that received nothing keeps proving nothing. This is where a proof goes stale: nothing about the record changes, the commit asked about does.

use majordomus_cli::served::{observe, Ancestry, Fetch, Fetched, ServedVerdict};
use std::time::SystemTime;
struct Linear;  // a <- b
impl Ancestry for Linear {
    fn has(&self, c: &str) -> Option<bool> { Some(c.starts_with('a') || c.starts_with('b')) }
    fn contains(&self, d: &str, a: &str) -> Option<bool> { Some(d >= a) }
}
let (a, b) = ("a".repeat(40), "b".repeat(40));
struct ServesA(String);
impl Fetch for ServesA {
    fn fetch(&self, _: &str) -> Fetched {
        Fetched::Body(format!(r#"{{"commit":"{}","dirty":false}}"#, self.0).into_bytes())
    }
}
let o = observe("pages", "https://s", "build.json", &a, &ServesA(a.clone()), &Linear,
                SystemTime::UNIX_EPOCH);
assert_eq!(o.judgement.verdict, ServedVerdict::Served);
// the same record, asked about a commit the served build does not contain
assert_eq!(o.rejudge(&b, &Linear).verdict, ServedVerdict::Stale);

Trait Implementations

impl Clone for Observation

fn clone(&self) -> Observation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Observation

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Observation

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Observation

impl JsonSchema for Observation

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for Observation

fn eq(&self, other: &Observation) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Observation

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Observation