Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/calebwin/pgclaw
/ functions
Functions
109 in github.com/calebwin/pgclaw
⨍
Functions
109
◇
Types & classes
8
↓ 16 callers
Function
extract_column_updates
Extract JSON column updates from an LLM response. The response should contain a JSON object like {"priority": "high", "summary": "..."}. We look for
src/http.rs:184
↓ 10 callers
Function
build_system_prompt
Build system prompt from agent fields (mirroring OpenClaw's session-start ritual).
src/worker.rs:481
↓ 6 callers
Function
call_llm
Call an LLM API via rig and return the assistant's text response. Supports Anthropic, OpenAI (and any OpenAI-compatible API), Ollama, and more. The `
src/http.rs:35
↓ 5 callers
Function
get_api_key
()
src/lib.rs:877
↓ 5 callers
Function
mark_done
(item: &QueueItem, error: &str)
src/process.rs:312
↓ 2 callers
Function
apply_row_updates
Apply column updates to the target row.
src/worker.rs:550
↓ 2 callers
Function
call_anthropic
Convenience wrapper for simple one-shot Anthropic calls (used in tests).
src/http.rs:153
↓ 2 callers
Function
call_anthropic_simple
Call the Anthropic API with a simple user message (convenience wrapper).
src/http.rs:165
↓ 2 callers
Function
get_api_url
Resolve the configured API URL, or None to use the provider's default.
src/lib.rs:56
↓ 2 callers
Function
get_provider
Resolve the configured API provider from the GUC.
src/lib.rs:37
↓ 2 callers
Function
runtime
()
src/http.rs:18
↓ 1 callers
Method
agent_id
(&self)
src/claw_type.rs:64
↓ 1 callers
Function
apply_updates
( item: &QueueItem, updates: &serde_json::Map<String, Value>, )
src/process.rs:236
↓ 1 callers
Function
call_llm_async
( provider: &str, api_key: &str, api_url: Option<&str>, model: &str, system_prompt: &str,
src/http.rs:73
↓ 1 callers
Function
get_workspace_dir
Resolve the workspace base directory.
src/lib.rs:45
↓ 1 callers
Function
load_full_agent_config
Load full agent config from the database for a queue item.
src/worker.rs:350
↓ 1 callers
Function
load_history
(item: &QueueItem)
src/process.rs:205
↓ 1 callers
Function
load_row_history
Load conversation history for a row-agent instance.
src/worker.rs:518
↓ 1 callers
Method
model
(&self)
src/claw_type.rs:57
↓ 1 callers
Function
prepare_messages
Convert our internal messages to rig messages and split into history + prompt.
src/http.rs:55
↓ 1 callers
Function
process_claudecode_queue_item
Process a single claudecode-type queue item: set up workspace, spawn Claude Code agent.
src/worker.rs:237
↓ 1 callers
Function
process_heartbeats
Check and fire due heartbeats.
src/worker.rs:761
↓ 1 callers
Function
process_inbox_item
Process one item from the channel inbox.
src/worker.rs:641
↓ 1 callers
Function
process_model_queue_item
Process a single model-type queue item: build prompt, call LLM, update row.
src/worker.rs:169
↓ 1 callers
Function
process_queue_item
Claim and process one item from claw.queue. Returns true if an item was processed.
src/worker.rs:88
↓ 1 callers
Method
prompt
(&self)
src/claw_type.rs:50
↓ 1 callers
Function
register_bgworker
Register the background worker. Called from _PG_init.
src/worker.rs:15
↓ 1 callers
Function
resolve_agent_config
Resolve model and system prompt from a claw value.
src/worker.rs:422
↓ 1 callers
Function
resolve_config
(item: &QueueItem)
src/process.rs:135
↓ 1 callers
Function
resolve_workspace_path
Resolve workspace directory path from agent config and queue item.
src/worker.rs:385
Function
_PG_init
()
src/lib.rs:70
Method
agent_ref
(agent_id: String, model_override: Option<String>)
src/claw_type.rs:41
Function
claw_agent_id
(c: Claw)
src/claw_type.rs:174
Function
claw_constructor
( prompt: default!(Option<String>, "NULL"), model: default!(Option<String>, "NULL"), agent: defaul
src/claw_type.rs:146
Function
claw_model
(c: Claw)
src/claw_type.rs:162
Function
claw_process_one
( api_key: String, provider: default!(Option<String>, "NULL"), api_url: default!(Option<String>, "
src/process.rs:15
Function
claw_prompt
(c: Claw)
src/claw_type.rs:168
Function
claw_unwatch
(table: pgrx::pg_sys::Oid)
src/trigger.rs:127
Function
claw_watch
(table: pgrx::pg_sys::Oid)
src/trigger.rs:7
Method
inline
(prompt: String, model: Option<String>)
src/claw_type.rs:35
Method
input
Parse text representation into a Claw value.
src/claw_type.rs:74
Method
output
Convert Claw value to text representation.
src/claw_type.rs:103
Function
pgclaw_worker_main
(_arg: pg_sys::Datum)
src/worker.rs:29
Function
postgresql_conf_options
()
src/lib.rs:141
Function
setup
(_options: Vec<&str>)
src/lib.rs:139
Function
test_agent_ref_resolves_type
()
src/lib.rs:578
Function
test_agents_crud
()
src/lib.rs:546
Function
test_build_system_prompt_all_fields
()
src/worker.rs:806
Function
test_build_system_prompt_empty
()
src/worker.rs:821
Function
test_build_system_prompt_instructions_only
()
src/worker.rs:861
Function
test_build_system_prompt_parts_joined_with_double_newline
()
src/worker.rs:872
Function
test_build_system_prompt_skips_empty_memory
()
src/worker.rs:849
Function
test_build_system_prompt_skips_empty_strings
()
src/worker.rs:838
Function
test_build_system_prompt_soul_only
()
src/worker.rs:827
Function
test_call_anthropic_live
run with: cargo test -- --ignored
src/http.rs:306
Function
test_call_anthropic_multi_column_update
()
src/http.rs:342
Function
test_call_anthropic_with_memory_update
()
src/http.rs:373
Function
test_claude_agent_sdk_live
()
src/http.rs:411
Function
test_claw_agent_id_accessor_agent
()
src/lib.rs:289
Function
test_claw_agent_id_accessor_inline_returns_null
()
src/lib.rs:299
Function
test_claw_agent_ref_roundtrip
()
src/lib.rs:166
Function
test_claw_agent_ref_with_model_roundtrip
()
src/lib.rs:183
Function
test_claw_column_default_value
()
src/lib.rs:780
Function
test_claw_column_nullable
()
src/lib.rs:800
Function
test_claw_constructor_agent
()
src/lib.rs:233
Function
test_claw_constructor_agent_with_model
()
src/lib.rs:242
Function
test_claw_constructor_inline
()
src/lib.rs:214
Function
test_claw_constructor_inline_with_model
()
src/lib.rs:223
Function
test_claw_inline_roundtrip
()
src/lib.rs:158
Function
test_claw_inline_with_model_roundtrip
()
src/lib.rs:174
Function
test_claw_model_accessor_no_model_returns_null
()
src/lib.rs:281
Function
test_claw_model_accessor_with_model
()
src/lib.rs:271
Function
test_claw_prompt_accessor_agent_returns_null
()
src/lib.rs:263
Function
test_claw_prompt_accessor_inline
()
src/lib.rs:254
Function
test_claw_prompt_with_colon_no_space_before
()
src/lib.rs:193
Function
test_claw_prompt_with_colon_space_before
()
src/lib.rs:202
Function
test_claw_unwatch_removes_trigger
()
src/lib.rs:409
Function
test_claw_watch_creates_trigger
()
src/lib.rs:369
Function
test_context_function
()
src/lib.rs:744
Function
test_e2e_agent_ref_with_soul
()
src/lib.rs:956
Function
test_e2e_channel_route_and_respond
()
src/lib.rs:1023
Function
test_e2e_cron_table_structure
()
src/lib.rs:1246
Function
test_e2e_heartbeat_full_cycle
()
src/lib.rs:1147
Function
test_e2e_inline_agent_sets_priority
()
src/lib.rs:888
Function
test_e2e_memory_update_via_agent
()
src/lib.rs:1281
Function
test_extract_deeply_nested
()
src/http.rs:295
Function
test_extract_empty_object
()
src/http.rs:244
Function
test_extract_first_object_only
()
src/http.rs:287
Function
test_extract_malformed_json
()
src/http.rs:281
Function
test_extract_multiple_columns
()
src/http.rs:223
Function
test_extract_nested_json
()
src/http.rs:251
Function
test_extract_no_json
()
src/http.rs:238
Function
test_extract_null_value
()
src/http.rs:266
Function
test_extract_numeric_value
()
src/http.rs:274
Function
test_extract_simple_json
()
src/http.rs:216
Function
test_extract_with_code_fence
()
src/http.rs:259
Function
test_extract_with_surrounding_text
()
src/http.rs:231
Function
test_heartbeat_tick
()
src/lib.rs:713
Function
test_multiple_claw_columns
()
src/lib.rs:852
Function
test_queue_row_data_excludes_claw_columns
()
src/lib.rs:821
next →
1–100 of 109, ranked by callers