Connected equipment

Use the @bijection/connectors/iot entrypoint to declare Connected equipment resources.

Availability

This page describes the pinned source package. Published availability is unestablished for this artifact. Source build and package availability.

Resources and modes

Resource	Mode	Description
Equipment	`changeFeed`	changeFeed

Declare a resource in application code, then bind deployment-specific settings and credentials. See typed resources, connections and source inspection.

Equipment

changeFeed: changeFeed

The following example matches configuration standard.

import { iot } from "@bijection/connectors/iot";
import { v } from "bijection/values";
import { makeFunctionReference } from "bijection/server";

export const equipment = iot.equipment.changeFeed({
  configuration: v.object({ mode: v.string() }),
  access: {
    read: makeFunctionReference<"query", any, [null]>("permissions:equipment"),
    reads: [],
  },
  policy: makeFunctionReference<"query", any, [null]>("permissions:equipment"),
});

Inferred record types

{
  "device_id": string;
  "device_epoch": string;
  "installation_id": string;
  "observation_id": string;
  "order": string;
  "observed_at": string;
  "device_event_at": string | null;
  "configuration": { mode: string; };
  "configuration_revision": string | null;
  "application": "rejected" | "reported" | "applied" | "received";
  "call_id": string | null;
  "reason": string | null;
}

The function references identify application policy queries. Implement those policies in your application; the references alone grant no authority.

Configuration: standard

Case: iot/equipment/changeFeed/standard. Connection and resource configuration are declared by this exact case. Credential kind: http. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`endpoint`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {
      "records": {
        "read": {
          "query": "permissions:equipment"
        },
        "reads": []
      }
    },
    "defaults": {},
    "connector": "http",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "http",
    "connection_fields": [
      "endpoint"
    ],
    "address": {
      "kind": "setup",
      "field": "endpoint"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "endpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	No initial acquisition
Changes	Complete change feed under the declared contract
Deletions	Explicit deletion evidence
Resume	Provider source position
Gap	Explicit repair required after a gap
Retention	604800000 ms

Complete native profile

{
  "movement": {
    "exchanges": {
      "records": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange records",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "complete_feed",
  "deletions": "explicit_events",
  "resume": "source_position",
  "retentionMs": "604800000",
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {
    "applyConfiguration": {
      "target": "records",
      "delivery": "idempotent",
      "condition": "unconditional",
      "replayWindowMs": "604800000",
      "maxDeliveryHours": "1",
      "providerEnforcedExpiry": true
    }
  }
}

Commands

Command	Target	Condition	Delivery
`applyConfiguration`	records	Unconditional	Provider idempotency contract

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "change_feed",
      "coverage": "committed_prefix",
      "consistency": "observations",
      "atomicity": "record",
      "history": "complete_changes",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "records": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange records",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "complete_feed",
        "deletions": "explicit_events",
        "resume": "source_position",
        "retentionMs": "604800000",
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {
          "applyConfiguration": {
            "target": "records",
            "delivery": "idempotent",
            "condition": "unconditional",
            "replayWindowMs": "604800000",
            "maxDeliveryHours": "1",
            "providerEnforcedExpiry": true
          }
        }
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {
    "applyConfiguration": {
      "target": "records",
      "condition": {
        "kind": "unconditional"
      },
      "delivery": {
        "kind": "idempotent",
        "retention": {
          "kind": "stated",
          "unit": "days",
          "value": 7
        },
        "max_delivery_hours": 1,
        "request_expiry": "provider_enforced"
      }
    }
  }
}

Recorded checks

Requirement	Scope	Evidence	Result
change-history-gap	{“kind”:“collection”,“name”:“records”}	The IoT library exercises receiver process crash recovery and stale report refusal. Native source publication, retained command custody and feed continuity on a deployment remain unqualified.	Execution result unavailable
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	The IoT library exercises receiver process crash recovery and stale report refusal. Native source publication, retained command custody and feed continuity on a deployment remain unqualified.	Execution result unavailable
command-response-lost	{“kind”:“command”,“name”:“applyConfiguration”}	The IoT library exercises receiver process crash recovery and stale report refusal. Native source publication, retained command custody and feed continuity on a deployment remain unqualified.	Execution result unavailable
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/iot/fixtures/identity.json	passed (2026-10-24T21:36:12.066Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Provider guidance

iotGateway({ configuration, access, policy }) declares source-owned device observations and a typed applyConfiguration command. The gateway must serve /v1/identity, complete history at /v1/changes?after=..., and original-request receipts under /v1/devices/:key/requests/:request_id. Configuration send uses POST /v1/devices/:key/configuration. The native complete-prefix change feed enforces ordering. Device event time is separate from gateway observation and native acquisition time. Commands retain native request identity, destination-enforced arrival expiry, exact configuration revision and installation epoch. Only applied evidence confirms a command; receipt or timeout alone does not. The destination must retain receipts and complete source history for at least seven days. Compose this resource with @bijection/iot for installation, intention resolution, rollout and incident behavior. That repository owns the complete wire schema and a durable reference receiver. Credentials and endpoints remain deployment bindings; capability declarations are contracts, not remote attestation or hosted qualification.

Provider references

Provider references and prerequisites are maintained in the connector guidance above. No separate provider-documentation review date is recorded.

Source and evidence

Canonical connector source, native analysis and check receipts. Connector artifact: 905888ea276a2a28e36981a79e8142b2547ea451c3e63162cb6915ad4a7d1305. The resource declaration examples above are compiled and compared with exact catalog declarations. Recorded checks apply only to their source, declaration and runtime identities. Configure a connection and inspect its status to establish deployment-specific readiness.

Get Started

Use-case atlas

Platform

Data and Operations

Guides

Client Libraries

Tools

API Reference

Connected equipment

Availability

Resources and modes

Equipment

changeFeed: changeFeed

Configuration: standard

Provider guidance

Provider references

Source and evidence

​Availability

​Resources and modes

​Equipment

​changeFeed: changeFeed

​Configuration: standard

​Provider guidance

​Provider references

​Source and evidence

Availability

Resources and modes

Equipment

changeFeed: changeFeed

Configuration: standard

Provider guidance

Provider references

Source and evidence