MCPcopy Create free account

hub / github.com/calebwin/pgclaw / functions

Functions109 in github.com/calebwin/pgclaw

↓ 16 callersFunctionextract_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 callersFunctionbuild_system_prompt
Build system prompt from agent fields (mirroring OpenClaw's session-start ritual).
src/worker.rs:481
↓ 6 callersFunctioncall_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 callersFunctionget_api_key
()
src/lib.rs:877
↓ 5 callersFunctionmark_done
(item: &QueueItem, error: &str)
src/process.rs:312
↓ 2 callersFunctionapply_row_updates
Apply column updates to the target row.
src/worker.rs:550
↓ 2 callersFunctioncall_anthropic
Convenience wrapper for simple one-shot Anthropic calls (used in tests).
src/http.rs:153
↓ 2 callersFunctioncall_anthropic_simple
Call the Anthropic API with a simple user message (convenience wrapper).
src/http.rs:165
↓ 2 callersFunctionget_api_url
Resolve the configured API URL, or None to use the provider's default.
src/lib.rs:56
↓ 2 callersFunctionget_provider
Resolve the configured API provider from the GUC.
src/lib.rs:37
↓ 2 callersFunctionruntime
()
src/http.rs:18
↓ 1 callersMethodagent_id
(&self)
src/claw_type.rs:64
↓ 1 callersFunctionapply_updates
( item: &QueueItem, updates: &serde_json::Map<String, Value>, )
src/process.rs:236
↓ 1 callersFunctioncall_llm_async
( provider: &str, api_key: &str, api_url: Option<&str>, model: &str, system_prompt: &str,
src/http.rs:73
↓ 1 callersFunctionget_workspace_dir
Resolve the workspace base directory.
src/lib.rs:45
↓ 1 callersFunctionload_full_agent_config
Load full agent config from the database for a queue item.
src/worker.rs:350
↓ 1 callersFunctionload_history
(item: &QueueItem)
src/process.rs:205
↓ 1 callersFunctionload_row_history
Load conversation history for a row-agent instance.
src/worker.rs:518
↓ 1 callersMethodmodel
(&self)
src/claw_type.rs:57
↓ 1 callersFunctionprepare_messages
Convert our internal messages to rig messages and split into history + prompt.
src/http.rs:55
↓ 1 callersFunctionprocess_claudecode_queue_item
Process a single claudecode-type queue item: set up workspace, spawn Claude Code agent.
src/worker.rs:237
↓ 1 callersFunctionprocess_heartbeats
Check and fire due heartbeats.
src/worker.rs:761
↓ 1 callersFunctionprocess_inbox_item
Process one item from the channel inbox.
src/worker.rs:641
↓ 1 callersFunctionprocess_model_queue_item
Process a single model-type queue item: build prompt, call LLM, update row.
src/worker.rs:169
↓ 1 callersFunctionprocess_queue_item
Claim and process one item from claw.queue. Returns true if an item was processed.
src/worker.rs:88
↓ 1 callersMethodprompt
(&self)
src/claw_type.rs:50
↓ 1 callersFunctionregister_bgworker
Register the background worker. Called from _PG_init.
src/worker.rs:15
↓ 1 callersFunctionresolve_agent_config
Resolve model and system prompt from a claw value.
src/worker.rs:422
↓ 1 callersFunctionresolve_config
(item: &QueueItem)
src/process.rs:135
↓ 1 callersFunctionresolve_workspace_path
Resolve workspace directory path from agent config and queue item.
src/worker.rs:385
Function_PG_init
()
src/lib.rs:70
Methodagent_ref
(agent_id: String, model_override: Option<String>)
src/claw_type.rs:41
Functionclaw_agent_id
(c: Claw)
src/claw_type.rs:174
Functionclaw_constructor
( prompt: default!(Option<String>, "NULL"), model: default!(Option<String>, "NULL"), agent: defaul
src/claw_type.rs:146
Functionclaw_model
(c: Claw)
src/claw_type.rs:162
Functionclaw_process_one
( api_key: String, provider: default!(Option<String>, "NULL"), api_url: default!(Option<String>, "
src/process.rs:15
Functionclaw_prompt
(c: Claw)
src/claw_type.rs:168
Functionclaw_unwatch
(table: pgrx::pg_sys::Oid)
src/trigger.rs:127
Functionclaw_watch
(table: pgrx::pg_sys::Oid)
src/trigger.rs:7
Methodinline
(prompt: String, model: Option<String>)
src/claw_type.rs:35
Methodinput
Parse text representation into a Claw value.
src/claw_type.rs:74
Methodoutput
Convert Claw value to text representation.
src/claw_type.rs:103
Functionpgclaw_worker_main
(_arg: pg_sys::Datum)
src/worker.rs:29
Functionpostgresql_conf_options
()
src/lib.rs:141
Functionsetup
(_options: Vec<&str>)
src/lib.rs:139
Functiontest_agent_ref_resolves_type
()
src/lib.rs:578
Functiontest_agents_crud
()
src/lib.rs:546
Functiontest_build_system_prompt_all_fields
()
src/worker.rs:806
Functiontest_build_system_prompt_empty
()
src/worker.rs:821
Functiontest_build_system_prompt_instructions_only
()
src/worker.rs:861
Functiontest_build_system_prompt_parts_joined_with_double_newline
()
src/worker.rs:872
Functiontest_build_system_prompt_skips_empty_memory
()
src/worker.rs:849
Functiontest_build_system_prompt_skips_empty_strings
()
src/worker.rs:838
Functiontest_build_system_prompt_soul_only
()
src/worker.rs:827
Functiontest_call_anthropic_live
run with: cargo test -- --ignored
src/http.rs:306
Functiontest_call_anthropic_multi_column_update
()
src/http.rs:342
Functiontest_call_anthropic_with_memory_update
()
src/http.rs:373
Functiontest_claude_agent_sdk_live
()
src/http.rs:411
Functiontest_claw_agent_id_accessor_agent
()
src/lib.rs:289
Functiontest_claw_agent_id_accessor_inline_returns_null
()
src/lib.rs:299
Functiontest_claw_agent_ref_roundtrip
()
src/lib.rs:166
Functiontest_claw_agent_ref_with_model_roundtrip
()
src/lib.rs:183
Functiontest_claw_column_default_value
()
src/lib.rs:780
Functiontest_claw_column_nullable
()
src/lib.rs:800
Functiontest_claw_constructor_agent
()
src/lib.rs:233
Functiontest_claw_constructor_agent_with_model
()
src/lib.rs:242
Functiontest_claw_constructor_inline
()
src/lib.rs:214
Functiontest_claw_constructor_inline_with_model
()
src/lib.rs:223
Functiontest_claw_inline_roundtrip
()
src/lib.rs:158
Functiontest_claw_inline_with_model_roundtrip
()
src/lib.rs:174
Functiontest_claw_model_accessor_no_model_returns_null
()
src/lib.rs:281
Functiontest_claw_model_accessor_with_model
()
src/lib.rs:271
Functiontest_claw_prompt_accessor_agent_returns_null
()
src/lib.rs:263
Functiontest_claw_prompt_accessor_inline
()
src/lib.rs:254
Functiontest_claw_prompt_with_colon_no_space_before
()
src/lib.rs:193
Functiontest_claw_prompt_with_colon_space_before
()
src/lib.rs:202
Functiontest_claw_unwatch_removes_trigger
()
src/lib.rs:409
Functiontest_claw_watch_creates_trigger
()
src/lib.rs:369
Functiontest_context_function
()
src/lib.rs:744
Functiontest_e2e_agent_ref_with_soul
()
src/lib.rs:956
Functiontest_e2e_channel_route_and_respond
()
src/lib.rs:1023
Functiontest_e2e_cron_table_structure
()
src/lib.rs:1246
Functiontest_e2e_heartbeat_full_cycle
()
src/lib.rs:1147
Functiontest_e2e_inline_agent_sets_priority
()
src/lib.rs:888
Functiontest_e2e_memory_update_via_agent
()
src/lib.rs:1281
Functiontest_extract_deeply_nested
()
src/http.rs:295
Functiontest_extract_empty_object
()
src/http.rs:244
Functiontest_extract_first_object_only
()
src/http.rs:287
Functiontest_extract_malformed_json
()
src/http.rs:281
Functiontest_extract_multiple_columns
()
src/http.rs:223
Functiontest_extract_nested_json
()
src/http.rs:251
Functiontest_extract_no_json
()
src/http.rs:238
Functiontest_extract_null_value
()
src/http.rs:266
Functiontest_extract_numeric_value
()
src/http.rs:274
Functiontest_extract_simple_json
()
src/http.rs:216
Functiontest_extract_with_code_fence
()
src/http.rs:259
Functiontest_extract_with_surrounding_text
()
src/http.rs:231
Functiontest_heartbeat_tick
()
src/lib.rs:713
Functiontest_multiple_claw_columns
()
src/lib.rs:852
Functiontest_queue_row_data_excludes_claw_columns
()
src/lib.rs:821
next →1–100 of 109, ranked by callers