Commit cfbcc6d
committed
Merge origin/main into platform: adopt ADR-0011 JSON-RPC-over-NATS binding
Bring platform current with two weeks of main so the divergent branches stop drifting; the ACP-over-NATS surface now speaks the shared jsonrpc-nats wire binding.
Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>1,374 files changed
Lines changed: 149940 additions & 63852 deletions
File tree
- .agents/skills/type-safe-error-handling
- .config/mise/tasks
- .github
- actions/setup-rust
- workflows
- devops/docker/compose
- services/trogon-gateway
- docs/adr
- otel/semconv
- policies
- registry
- templates/registry/rust
- proto/trogonai/scheduler/schedules
- projections/v1
- v1
- rsworkspace
- .cargo
- cli/trogon-decider-test
- src
- codec
- crates
- a2a-auth-callout
- src
- account_resolver
- caller_jwt_header
- credentials
- api_key
- mtls
- oidc
- denial_category
- denial_claims
- denial_reason
- dispatcher
- error
- jwt
- nats_user_jwt
- user_jwt_subject
- permissions
- signing_key_source
- loader
- wire
- bridge_adapter
- callout_auth_response_claims
- nkey_public
- nkey_seed
- server_auth_request_claims
- server_auth_request_envelope
- wire_codec
- xkey_public
- tests
- a2a-bridge
- src
- auth
- callout_mint
- error
- identity
- inbound
- nats_transport_harness
- outbound
- a2a-gateway
- src
- aauth
- agent_card_surface
- audit_ingress
- config
- gw_ingress_stream
- gw_pull_backpressure
- jwt_caller_identity
- policy
- error
- per_skill
- spicedb_tier1
- tier1_declarative
- evaluator
- loader
- time_predicate
- tier2_cel
- tier2
- tier3_redaction
- json_path
- wasmtime_substrate
- push_dlq_mirror
- runtime
- audit_publish
- env
- policy_stack
- reply
- streaming
- tier1_denial
- tier1
- tests
- a2a-identity-types/src
- caller
- error
- jwt
- principal
- a2a-nats-http
- src
- handlers
- headers
- tests
- a2a-nats-server
- src
- noop_handler
- runtime
- a2a-nats-stdio
- src
- dispatch
- io_loop
- runtime
- wire
- a2a-nats
- src
- a2a_prefix
- agent_id
- audit
- emitter
- envelope
- catalog
- agent_view
- import_gate
- error
- principal
- spicedb
- client
- nats_kv
- registrar
- spicedb_permission
- store
- watch
- client
- error
- event_stream
- gateway_headers
- handle
- tests
- resubscribe
- streaming
- unary
- wire
- config
- constants
- context_id
- error
- gateway_ingress
- jetstream
- consumers
- provision
- stream_options
- streams
- jsonrpc
- nats/subjects
- agents
- card
- message_send
- message_stream
- push
- delete
- get
- list
- set
- tasks
- cancel
- get
- list
- resubscribe
- stream
- subscriptions
- agent_all
- task_all_events
- task_one_events
- tasks
- events
- push
- authentication_header
- caller_id
- delivery_semantics
- dispatch_error
- dispatcher
- composite
- http
- jetstream
- nats
- dlq_dedup
- dlq
- idempotency_key_header
- nats_push_subject
- push_delivery_semantics_registry
- push_idempotency_key
- push_notification_config_id
- push_notification_config
- push_notification_target
- push_payload
- status_transition_id
- target
- terminal_push_task_state
- req_id
- server
- agent_card
- bridge
- dispatch
- handler
- message_send
- message_stream
- push_delete
- push_get
- push_list
- push_set
- tasks_cancel
- tasks_get
- tasks_list
- tasks_resubscribe
- wire
- task_id
- wire
- a2a-pack
- policies
- src
- agent_card_read
- agent_card_schema
- resource_tuples
- a2a-redaction
- src
- a2a_method
- bin
- error
- noop
- redactor
- signed_bundle
- digest
- manifest
- public_key
- signature
- verify
- skill_id
- skill_manifest
- tier3_sentinel
- wasm_bundle_path
- wasm
- engine
- tests
- fixtures
- acp-nats-agent
- src
- connection
- tests
- acp-nats-server/src
- acp_connection_id
- config
- connection
- transport
- acp-nats-stdio/src
- config
- acp-nats-ws/src
- acp-nats
- src
- acp_prefix
- agent
- authenticate
- cancel
- close_session
- ext_method
- ext_notification
- fork_session
- initialize
- js_request
- list_sessions
- load_session
- logout
- new_session
- prompt
- resume_session
- set_session_config_option
- set_session_model
- set_session_mode
- test_support
- client_proxy
- client
- ext_session_prompt_response
- ext
- fs_read_text_file
- fs_write_text_file
- request_permission
- rpc_reply
- session_elicitation
- session_update
- terminal_create
- terminal_kill
- terminal_output
- terminal_release
- terminal_wait_for_exit
- config
- error
- ext_method_name
- in_flight_slot_guard
- jetstream
- consumers
- ext_policy
- provision
- streams
- nats
- parsing
- subjects
- responses
- prompt_response
- update
- pending_prompt_waiters
- req_id
- session_id
- telemetry
- metrics
- wire
- tests
- ard-catalog
- schemas
- src
- ard_identifier
- ard_storage_key
- catalog_entry_wire
- catalog_entry
- catalog_host_wire
- catalog_host
- catalog_manifest_schema
- catalog_manifest_wire
- catalog_manifest
- display_name
- federation_mode
- media_type
- metadata
- representative_queries
- trust_manifest
- url_or_data
- ard-nats
- src
- catalog_event
- catalog_index
- catalog_subject
- memory_catalog_store
- ard-registry
- src
- bin/ard-registry-demo
- explore_request
- facet_field
- filters
- http_error
- lexical_rank
- list_agents_request
- page_token
- registry
- router
- search_filters
- search_request
- source_url
- jsonrpc-nats
- proptest-regressions/tests
- src
- codec
- tests
- mcp-nats-server/src
- allowed_host
- config
- runtime
- mcp-nats-stdio/src
- config
- mcp-nats
- src
- client
- config
- jsonrpc
- mcp_peer_id
- mcp_prefix
- nats
- parsing
- subjects
- server
- telemetry
- transport
- tests
- trogon-aauth-verify
- src
- challenge
- jkt
- jwks_cache
- nats_pop
- replay
- token
- tests
- trogon-acp-runner
- src
- tests
- trogon-acp/src
- trogon-cli/src
- trogon-compactor/src/telemetry
- trogon-decider-guest-macros
- src
- tests
- ui
- trogon-decider-guest-sdk
- src
- snapshot
- trogon-decider-nats/src
- snapshot_store
- tests
- store
- stream_store
- trogon-decider-runtime/src
- event
- codec
- event_decode
- event_payload_error
- execution
- headers
- snapshot
- codec
- encoded_snapshot
- snapshot_decode_error
- snapshot_encode_error
- snapshot_envelope_decode_error
- snapshot_envelope_encode_error
- read_snapshot
- snapshot_type
- stream
- trogon-decider-sim
- src
- import_check
- scenario
- tests
- trogon-decider-wasm-runtime
- src
- command_type
- domain_error_detail
- engine
- execution
- module_name
- module_version
- module
- opaque_snapshot
- registry
- snapshot_id
- tests
- support
- trogon-decider-wit
- src
- tests
- wit
- trogon-decider
- src
- event
- codec
- event_decode
- event_payload_error
- testing
- trogon-e2e/src/bin
- trogon-gateway
- src
- config
- http
- source_integration_id
- source_status
- source
- datadog
- datadog_event_type
- datadog_webhook_token
- server
- signature
- discord
- config
- gateway
- github
- config
- server
- tests
- signature
- gitlab
- gitlab_signing_token
- server
- tests
- signature
- incidentio
- config
- incidentio_event_type
- incidentio_signing_secret
- server
- signature
- linear
- config
- server
- signature
- microsoft_graph
- client_state
- server
- notion
- notion_event_type
- notion_verification_token
- server
- signature
- verification_token
- sentry
- sentry_client_secret
- server
- signature
- slack
- config
- server
- tests
- signature
- socket_mode
- telegram
- config
- registration
- server
- tests
- signature
- twitter
- config
- server
- tests
- signature
- streams
- trogon-identity-types
- src
- aauth
- act_chain
- trogon-nats
- src
- auth
- connect
- jetstream
- claim_check
- create_conflicts
- mocks
- publish
- tests
- stream_max_age
- traits
- lease
- provision
- renew_interval
- renew
- ttl
- messaging
- mocks
- nats_token
- server_info
- subject_token_violation
- telemetry
- messaging
- trogon-scheduler-domain
- src
- commands
- create_schedule
- domain
- message
- tests
- schedule_event_delivery
- schedule_event_sampling_source
- schedule_event_schedule
- schedule_event_status
- schedule_id
- tests
- schedule
- tests
- pause_schedule
- proto_wire
- remove_schedule
- resume_schedule
- state
- snapshot_policy
- subject
- trogon-scheduler
- migrations/postgres
- src
- commands
- domain
- recurrence
- schedule_occurrence_sequence
- record_schedule_occurrence
- schedule_next_occurrence
- snapshot
- config
- error
- kv
- mocks
- nats
- processor/execution
- checkpoints
- codec
- failure
- store
- execution_schedules
- reconciliation
- go_duration
- reconcile
- recorded_events
- request
- rrule_wakeup_payload
- schedule_key
- schedule_subject
- wakeup
- worker
- consumer
- dispatcher
- processor
- testkit
- projections
- postgres
- schedules
- storage
- queries
- decode
- projection
- read_model
- message
- schedule
- schedule_id
- store
- telemetry
- metrics
- trace
- tests
- trogon-semconv
- src
- gen
- trogon-service-config/src
- trogon-std
- src
- args
- dirs
- fixed
- system
- duration
- env
- in_memory
- system
- fs
- mem
- system
- http
- json
- secret_string
- signal
- telemetry
- http
- time
- mock
- system
- uuid
- trogon-telemetry
- src
- log
- metric
- resource_attribute
- service_name
- trace
- trogon-wasm-runtime
- trogonai-proto
- src
- convert
- gen
- scheduler/schedules
- codec
- dylints/trogon_lints
- .cargo
- examples
- src
- ui
- auxiliary
- owner
- wasm-components/trogon-schedules-decider
- src
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
46 | 46 | | |
47 | 47 | | |
48 | 48 | | |
49 | | - | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
50 | 64 | | |
51 | 65 | | |
52 | 66 | | |
53 | 67 | | |
54 | | - | |
| 68 | + | |
55 | 69 | | |
56 | 70 | | |
57 | | - | |
| 71 | + | |
58 | 72 | | |
59 | 73 | | |
60 | | - | |
| 74 | + | |
61 | 75 | | |
62 | 76 | | |
63 | 77 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | | - | |
6 | | - | |
| 5 | + | |
| 6 | + | |
7 | 7 | | |
8 | 8 | | |
9 | 9 | | |
| |||
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
15 | | - | |
| 15 | + | |
16 | 16 | | |
17 | | - | |
18 | | - | |
19 | | - | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
28 | | - | |
| 28 | + | |
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
| |||
56 | 56 | | |
57 | 57 | | |
58 | 58 | | |
59 | | - | |
| 59 | + | |
60 | 60 | | |
61 | 61 | | |
62 | 62 | | |
| |||
0 commit comments