KosmoKrator

data

Google Pub/Sub MCP Gateway for AI Agents

Expose Google Pub/Sub tools to Claude Code, Cursor, Codex, and other MCP clients through the local KosmoKrator MCP gateway.

Google Pub/Sub MCP Gateway

Expose Google Pub/Sub to MCP clients with `kosmokrator mcp:serve --integration=google-pubsub`.

If the client has never used KosmoKrator before, install it first, then register this integration as a stdio MCP server.

Install KosmoKrator 
curl -fsSL https://raw.githubusercontent.com/OpenCompanyApp/kosmokrator/main/install.sh | bash
Install gateway entry 
kosmokrator mcp:gateway:install --integration=google-pubsub --write=deny --json
MCP configuration 
{
  "mcpServers": {
    "kosmokrator-google-pubsub": {
      "type": "stdio",
      "command": "kosmo",
      "args": [
        "mcp:serve",
        "--integration=google-pubsub",
        "--write=deny"
      ]
    }
  }
}
Serve manually 
kosmokrator mcp:serve --integration=google-pubsub --write=deny

Client Notes

Use one scoped MCP gateway entry, then adapt the config location to the client or framework.

Claude Code Connect local KosmoKrator integrations to Claude Code through one scoped MCP gateway entry. Claude Code can launch the local kosmo binary directly from the project MCP config.
Cursor Expose selected local integrations to Cursor through KosmoKrator without configuring each service as its own MCP server. Use the same KosmoKrator install and integration credentials that power terminal and headless runs.
Codex Use KosmoKrator as a local MCP proxy for Codex so coding sessions can reach selected integrations with explicit write policy. Keep write access denied or ask-based unless the workspace is trusted.
OpenAI Agents SDK Attach KosmoKrator integration tools to OpenAI Agents SDK workflows through a local MCP gateway. Use headless JSON commands for CI-style execution and MCP for agent tool discovery.
Claude Agent SDK Give Claude Agent SDK workflows access to KosmoKrator integrations through a local MCP server. Use a narrow integration list so the agent does not load unrelated tools.
Vercel AI SDK Use KosmoKrator as a local integration gateway for Vercel AI SDK agents and scripts. Prefer CLI JSON calls when a workflow only needs one deterministic integration operation.
LangChain Bridge LangChain agents to local KosmoKrator integration tools through MCP or headless CLI calls. Keep the gateway scoped to the integration and operation class needed by the chain.
LangGraph Run KosmoKrator integration calls from LangGraph nodes while preserving local credentials and permissions. Headless CLI calls fit repeatable graph edges; MCP fits exploratory agent nodes.
CrewAI Expose KosmoKrator integrations to CrewAI workers as scoped local tools. Use per-worker integration scopes to avoid giving every worker every tool.
Generic MCP Clients Connect any stdio-compatible MCP client to local KosmoKrator integration tools. Start with read-only write policy and expand only for trusted projects.

MCP Tool Names

KosmoKrator exposes integration tools through the gateway with stable names.

MCP toolSource functionType
integration__google_pubsub__google_pubsub_projects_topics_publish google-pubsub.google_pubsub_projects_topics_publish Write write
integration__google_pubsub__google_pubsub_projects_topics_delete google-pubsub.google_pubsub_projects_topics_delete Write write
integration__google_pubsub__google_pubsub_projects_topics_set_iam_policy google-pubsub.google_pubsub_projects_topics_set_iam_policy Write write
integration__google_pubsub__google_pubsub_projects_topics_get_iam_policy google-pubsub.google_pubsub_projects_topics_get_iam_policy Read read
integration__google_pubsub__google_pubsub_projects_topics_test_iam_permissions google-pubsub.google_pubsub_projects_topics_test_iam_permissions Write write
integration__google_pubsub__google_pubsub_projects_topics_create google-pubsub.google_pubsub_projects_topics_create Write write
integration__google_pubsub__google_pubsub_projects_topics_list google-pubsub.google_pubsub_projects_topics_list Read read
integration__google_pubsub__google_pubsub_projects_topics_patch google-pubsub.google_pubsub_projects_topics_patch Write write
integration__google_pubsub__google_pubsub_projects_topics_get google-pubsub.google_pubsub_projects_topics_get Read read
integration__google_pubsub__google_pubsub_projects_topics_subscriptions_list google-pubsub.google_pubsub_projects_topics_subscriptions_list Read read
integration__google_pubsub__google_pubsub_projects_topics_snapshots_list google-pubsub.google_pubsub_projects_topics_snapshots_list Read read
integration__google_pubsub__google_pubsub_projects_subscriptions_acknowledge google-pubsub.google_pubsub_projects_subscriptions_acknowledge Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_test_iam_permissions google-pubsub.google_pubsub_projects_subscriptions_test_iam_permissions Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_get google-pubsub.google_pubsub_projects_subscriptions_get Read read
integration__google_pubsub__google_pubsub_projects_subscriptions_patch google-pubsub.google_pubsub_projects_subscriptions_patch Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_set_iam_policy google-pubsub.google_pubsub_projects_subscriptions_set_iam_policy Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_detach google-pubsub.google_pubsub_projects_subscriptions_detach Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_pull google-pubsub.google_pubsub_projects_subscriptions_pull Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_list google-pubsub.google_pubsub_projects_subscriptions_list Read read
integration__google_pubsub__google_pubsub_projects_subscriptions_create google-pubsub.google_pubsub_projects_subscriptions_create Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_modify_push_config google-pubsub.google_pubsub_projects_subscriptions_modify_push_config Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_modify_ack_deadline google-pubsub.google_pubsub_projects_subscriptions_modify_ack_deadline Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_delete google-pubsub.google_pubsub_projects_subscriptions_delete Write write
integration__google_pubsub__google_pubsub_projects_subscriptions_get_iam_policy google-pubsub.google_pubsub_projects_subscriptions_get_iam_policy Read read
integration__google_pubsub__google_pubsub_projects_subscriptions_seek google-pubsub.google_pubsub_projects_subscriptions_seek Write write
integration__google_pubsub__google_pubsub_projects_snapshots_set_iam_policy google-pubsub.google_pubsub_projects_snapshots_set_iam_policy Write write
integration__google_pubsub__google_pubsub_projects_snapshots_get_iam_policy google-pubsub.google_pubsub_projects_snapshots_get_iam_policy Read read
integration__google_pubsub__google_pubsub_projects_snapshots_get google-pubsub.google_pubsub_projects_snapshots_get Read read
integration__google_pubsub__google_pubsub_projects_snapshots_patch google-pubsub.google_pubsub_projects_snapshots_patch Write write
integration__google_pubsub__google_pubsub_projects_snapshots_test_iam_permissions google-pubsub.google_pubsub_projects_snapshots_test_iam_permissions Write write
integration__google_pubsub__google_pubsub_projects_snapshots_create google-pubsub.google_pubsub_projects_snapshots_create Write write
integration__google_pubsub__google_pubsub_projects_snapshots_list google-pubsub.google_pubsub_projects_snapshots_list Read read
integration__google_pubsub__google_pubsub_projects_snapshots_delete google-pubsub.google_pubsub_projects_snapshots_delete Write write
integration__google_pubsub__google_pubsub_projects_schemas_test_iam_permissions google-pubsub.google_pubsub_projects_schemas_test_iam_permissions Write write
integration__google_pubsub__google_pubsub_projects_schemas_validate google-pubsub.google_pubsub_projects_schemas_validate Write write
integration__google_pubsub__google_pubsub_projects_schemas_rollback google-pubsub.google_pubsub_projects_schemas_rollback Write write
integration__google_pubsub__google_pubsub_projects_schemas_get google-pubsub.google_pubsub_projects_schemas_get Read read
integration__google_pubsub__google_pubsub_projects_schemas_set_iam_policy google-pubsub.google_pubsub_projects_schemas_set_iam_policy Write write
integration__google_pubsub__google_pubsub_projects_schemas_create google-pubsub.google_pubsub_projects_schemas_create Write write
integration__google_pubsub__google_pubsub_projects_schemas_list google-pubsub.google_pubsub_projects_schemas_list Read read
integration__google_pubsub__google_pubsub_projects_schemas_validate_message google-pubsub.google_pubsub_projects_schemas_validate_message Write write
integration__google_pubsub__google_pubsub_projects_schemas_commit google-pubsub.google_pubsub_projects_schemas_commit Write write
integration__google_pubsub__google_pubsub_projects_schemas_delete google-pubsub.google_pubsub_projects_schemas_delete Write write
integration__google_pubsub__google_pubsub_projects_schemas_get_iam_policy google-pubsub.google_pubsub_projects_schemas_get_iam_policy Read read
integration__google_pubsub__google_pubsub_projects_schemas_list_revisions google-pubsub.google_pubsub_projects_schemas_list_revisions Read read
integration__google_pubsub__google_pubsub_projects_schemas_delete_revision google-pubsub.google_pubsub_projects_schemas_delete_revision Write write

Write Access

Start with --write=deny for read-only MCP clients. Use --write=ask or --write=allow only when the client and workspace are trusted.