(state: &SharedState, identity: &AuthenticatedIdentity)
| 92 | } |
| 93 | |
| 94 | pub fn pg_class(state: &SharedState, identity: &AuthenticatedIdentity) -> PgWireResult<VTable> { |
| 95 | let mut t = VTable::new(vec![ |
| 96 | VColumn::new("oid", VType::Int8), |
| 97 | VColumn::new("relname", VType::Text), |
| 98 | VColumn::new("relnamespace", VType::Int8), |
| 99 | VColumn::new("relkind", VType::Text), |
| 100 | VColumn::new("relowner", VType::Int8), |
| 101 | ]); |
| 102 | for coll in load_collections(state, identity) { |
| 103 | let oid = stable_collection_oid(coll.tenant_id, &coll.name); |
| 104 | t.push(vec![ |
| 105 | VValue::Int8(oid), |
| 106 | VValue::Text(coll.name.clone()), |
| 107 | VValue::Int8(2200), |
| 108 | VValue::Text("r".into()), |
| 109 | VValue::Int8(10), |
| 110 | ]); |
| 111 | } |
| 112 | Ok(t) |
| 113 | } |
| 114 | |
| 115 | pub fn pg_attribute(state: &SharedState, identity: &AuthenticatedIdentity) -> PgWireResult<VTable> { |
| 116 | let mut t = VTable::new(vec![ |
no test coverage detected