bankai - v0.2.0

bankai/sync_peer

Signed TCP replication of Bankai’s authoritative immutable task history.

The transport moves a signed snapshot payload. Mnesia remains the only receiver-side task authority: envelope verification happens before the transactional import boundary, and a verified conflict is recorded rather than silently choosing a remote head.

Types

ConflictRecord

</> 
pub type ConflictRecord {
  ConflictRecord(
    id: String,
    timestamp: Int,
    author: String,
    detail: String,
  )
}

Constructors 

  • ConflictRecord(
  id: String,
  timestamp: Int,
  author: String,
  detail: String,
)

Snapshot

</> 
pub type Snapshot {
  Snapshot(
    versions: List(types.Task),
    heads: List(types.Task),
    author: String,
  )
}

Constructors

Values

adversarial_envelope_checks_for_test

</> 
pub fn adversarial_envelope_checks_for_test() -> Result(
  Nil,
  String,
)

clear_conflicts

</> 
pub fn clear_conflicts(workspace: String) -> Result(Nil, String)

decode_signed_snapshot_for_test

</> 
pub fn decode_signed_snapshot_for_test(
  workspace: String,
  line: String,
) -> Result(Snapshot, String)

Test and diagnostic seam. Production callers use fetch; this exposes the same verifier so trust/revocation/replay assertions do not need a socket.

default_port

</> 
pub const default_port: Int

fetch

</> 
pub fn fetch(
  host: String,
  port: Int,
  workspace: String,
) -> Result(Snapshot, String)

list_conflicts

</> 
pub fn list_conflicts(
  workspace: String,
) -> Result(List(ConflictRecord), String)

parse_port

</> 
pub fn parse_port(args: List(String), default: Int) -> Int

public_key

</> 
pub fn public_key(workspace: String) -> Result(String, String)

record_conflict

</> 
pub fn record_conflict(
  workspace: String,
  author: String,
  detail: String,
) -> Result(Nil, String)

Domain conflicts are never silently imported. The conflict record is a durable audit artifact outside the task-head tables, so causal evidence is preserved even when the current materialization cannot advance.

reset_identity_for_test

</> 
pub fn reset_identity_for_test(
  workspace: String,
) -> Result(Nil, String)

resolve_conflict

</> 
pub fn resolve_conflict(
  workspace: String,
  conflict_id: String,
) -> Result(Nil, String)

revoke_peer

</> 
pub fn revoke_peer(
  workspace: String,
  public_key: String,
) -> Result(Nil, String)

serve

</> 
pub fn serve(workspace: String, port: Int) -> Nil

signed_snapshot_for_test

</> 
pub fn signed_snapshot_for_test(
  workspace: String,
) -> Result(String, String)

Test and local tooling seam: produce the exact signed envelope that sync-serve sends, without starting a TCP listener.

trust_peer

</> 
pub fn trust_peer(
  workspace: String,
  public_key: String,
) -> Result(Nil, String)

Trust provisioning is explicit. Receiving an unknown signer never creates a trust entry as a side effect of replication.

✨ Search Document