# IRC receives the message i posted right to the topic which contains payload of Inventory v1beta2 create request INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-consumer service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=processing message: operation=created DEBUG ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-consumer service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=processed message={"schema":{"type":"struct","fields":[{"type":"string","optional":true,"field":"type"},{"type":"string","optional":true,"field":"reporter_type"},{"type":"string","optional":true,"field":"reporter_instance_id"},{"type":"struct","fields":[{"type":"struct","fields":[{"type":"string","optional":true,"field":"local_resource_id"},{"type":"string","optional":true,"field":"api_href"},{"type":"string","optional":true,"field":"console_href"},{"type":"string","optional":true,"field":"reporter_version"}],"optional":true,"name":"metadata"},{"type":"struct","fields":[{"type":"string","optional":true,"field":"workspace_id"}],"optional":true,"name":"common"},{"type":"struct","fields":[{"type":"string","optional":true,"field":"satellite_id"},{"type":"string","optional":true,"field":"subscription_manager_id"},{"type":"string","optional":true,"field":"insights_inventory_id"},{"type":"string","optional":true,"field":"ansible_host"}],"optional":true,"name":"reporter"}],"optional":true,"name":"representations"}],"optional":true,"name":"payload"},"payload":{"type":"host","reporter_type":"hbi","reporter_instance_id":"3088be62-1c60-4884-b133-9200542d0b3f","representations":{"metadata":{"local_resource_id":"dd1b73b9-3e33-4264-968c-e3ce55b9afec","api_href":"https://apiHref.com/","console_href":"https://www.console.com/","reporter_version":"2.7.16"},"common":{"workspace_id":"a64d17d0-aec3-410a-acd0-e0b85b22c076"},"reporter":{"satellite_id":"2c4196f1-0371-4f4c-8913-e113cfaa6e67","subscription_manager_id":"af94f92b-0b65-4cac-b449-6b77e665a08f","insights_inventory_id":"05707922-7b0a-4fe6-982d-6adbc7695b8f","ansible_host":"host-1"}}}} INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-consumer service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=response: INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-consumer service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=offsets committed ([partition:offset]): [0:0] INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-consumer service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=consumed event from topic hbi.replication.events, partition 0 at offset 0 DEBUG ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-consumer service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=consumed event data: key = {"schema":{"type":"string","optional":false},"payload":"dd1b73b9-3e33-4264-968c-e3ce55b9afec"} value = {"schema":{"type":"struct","fields":[{"type":"string","optional":true,"field":"type"},{"type":"string","optional":true,"field":"reporter_type"},{"type":"string","optional":true,"field":"reporter_instance_id"},{"type":"struct","fields":[{"type":"struct","fields":[{"type":"string","optional":true,"field":"local_resource_id"},{"type":"string","optional":true,"field":"api_href"},{"type":"string","optional":true,"field":"console_href"},{"type":"string","optional":true,"field":"reporter_version"}],"optional":true,"name":"metadata"},{"type":"struct","fields":[{"type":"string","optional":true,"field":"workspace_id"}],"optional":true,"name":"common"},{"type":"struct","fields":[{"type":"string","optional":true,"field":"satellite_id"},{"type":"string","optional":true,"field":"subscription_manager_id"},{"type":"string","optional":true,"field":"insights_inventory_id"},{"type":"string","optional":true,"field":"ansible_host"}],"optional":true,"name":"reporter"}],"optional":true,"name":"representations"}],"optional":true,"name":"payload"},"payload":{"type":"host","reporter_type":"hbi","reporter_instance_id":"3088be62-1c60-4884-b133-9200542d0b3f","representations":{"metadata":{"local_resource_id":"dd1b73b9-3e33-4264-968c-e3ce55b9afec","api_href":"https://apiHref.com/","console_href":"https://www.console.com/","reporter_version":"2.7.16"},"common":{"workspace_id":"a64d17d0-aec3-410a-acd0-e0b85b22c076"},"reporter":{"satellite_id":"2c4196f1-0371-4f4c-8913-e113cfaa6e67","subscription_manager_id":"af94f92b-0b65-4cac-b449-6b77e665a08f","insights_inventory_id":"05707922-7b0a-4fe6-982d-6adbc7695b8f","ansible_host":"host-1"}}}} # Inventory API gets it, creates it, then consumer picks up change to replication to relations INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= service.id=kessel-inventory-api-6cbfdb9c9-z8pv5 msg=Report Resource Request: type:"host" reporter_type:"hbi" reporter_instance_id:"3088be62-1c60-4884-b133-9200542d0b3f" representations:{metadata:{local_resource_id:"dd1b73b9-3e33-4264-968c-e3ce55b9afec" api_href:"https://apiHref.com/" console_href:"https://www.console.com/" reporter_version:"2.7.16"} common:{fields:{key:"workspace_id" value:{string_value:"a64d17d0-aec3-410a-acd0-e0b85b22c076"}}} reporter:{fields:{key:"ansible_host" value:{string_value:"host-1"}} fields:{key:"insights_inventory_id" value:{string_value:"05707922-7b0a-4fe6-982d-6adbc7695b8f"}} fields:{key:"satellite_id" value:{string_value:"2c4196f1-0371-4f4c-8913-e113cfaa6e67"}} fields:{key:"subscription_manager_id" value:{string_value:"af94f92b-0b65-4cac-b449-6b77e665a08f"}}}} INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= service.id=kessel-inventory-api-6cbfdb9c9-z8pv5 msg=upserting resource: &{00000000-0000-0000-0000-000000000000 map[reporter_instance_id:3088be62-1c60-4884-b133-9200542d0b3f reporter_type:hbi representations:map[common:map[workspace_id:a64d17d0-aec3-410a-acd0-e0b85b22c076] metadata:map[api_href:https://apiHref.com/ console_href:https://www.console.com/ local_resource_id:dd1b73b9-3e33-4264-968c-e3ce55b9afec reporter_version:2.7.16] reporter:map[ansible_host:host-1 insights_inventory_id:05707922-7b0a-4fe6-982d-6adbc7695b8f satellite_id:2c4196f1-0371-4f4c-8913-e113cfaa6e67 subscription_manager_id:af94f92b-0b65-4cac-b449-6b77e665a08f]] type:host] host a64d17d0-aec3-410a-acd0-e0b85b22c076 https://www.console.com/ https://apiHref.com/ [] dd1b73b9-3e33-4264-968c-e3ce55b9afec hbi 3088be62-1c60-4884-b133-9200542d0b3f 2.7.16 { } grpc-go/1.73.0 {{ } }} 2025/06/27 19:46:16 /workspace/internal/data/resources/resourcerepository.go:271 record not found [2.634ms] [rows:0] SELECT * FROM "resources" WHERE "resources"."resource_type" = 'host' AND "resources"."reporter_resource_id" = 'dd1b73b9-3e33-4264-968c-e3ce55b9afec' AND "resources"."reporter_type" = 'hbi' AND "resources"."reporter_instance_id" = '3088be62-1c60-4884-b133-9200542d0b3f' ORDER BY "resources"."id" LIMIT 1 INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= service.id=kessel-inventory-api-6cbfdb9c9-z8pv5 msg=found existing resource: INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= service.id=kessel-inventory-api-6cbfdb9c9-z8pv5 msg=Creating resource: &{00000000-0000-0000-0000-000000000000 map[reporter_instance_id:3088be62-1c60-4884-b133-9200542d0b3f reporter_type:hbi representations:map[common:map[workspace_id:a64d17d0-aec3-410a-acd0-e0b85b22c076] metadata:map[api_href:https://apiHref.com/ console_href:https://www.console.com/ local_resource_id:dd1b73b9-3e33-4264-968c-e3ce55b9afec reporter_version:2.7.16] reporter:map[ansible_host:host-1 insights_inventory_id:05707922-7b0a-4fe6-982d-6adbc7695b8f satellite_id:2c4196f1-0371-4f4c-8913-e113cfaa6e67 subscription_manager_id:af94f92b-0b65-4cac-b449-6b77e665a08f]] type:host] host a64d17d0-aec3-410a-acd0-e0b85b22c076 https://www.console.com/ https://apiHref.com/ [] dd1b73b9-3e33-4264-968c-e3ce55b9afec hbi 3088be62-1c60-4884-b133-9200542d0b3f 2.7.16 { } grpc-go/1.73.0 {{ } }} INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= subsystem=notificationsintegrations_controller msg=Upserted Resource: 00000000-0000-0000-0000-000000000000(host) INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= service.id=kessel-inventory-api-6cbfdb9c9-z8pv5 msg= INFO ts=2025-06-27T19:46:16Z caller=log/helper.go:85 service.name=inventory-api service.version=0.1.0 trace.id= span.id= kind=server component=grpc operation=/kessel.inventory.v1beta2.KesselInventoryService/ReportResource args=type:"host" reporter_type:"hbi" reporter_instance_id:"3088be62-1c60-4884-b133-9200542d0b3f" representations:{metadata:{local_resource_id:"dd1b73b9-3e33-4264-968c-e3ce55b9afec" api_href:"https://apiHref.com/" console_href:"https://www.console.com/" reporter_version:"2.7.16"} common:{fields:{key:"workspace_id" value:{string_value:"a64d17d0-aec3-410a-acd0-e0b85b22c076"}}} reporter:{fields:{key:"ansible_host" value:{string_value:"host-1"}} fields:{key:"insights_inventory_id" value:{string_value:"05707922-7b0a-4fe6-982d-6adbc7695b8f"}} fields:{key:"satellite_id" value:{string_value:"2c4196f1-0371-4f4c-8913-e113cfaa6e67"}} fields:{key:"subscription_manager_id" value:{string_value:"af94f92b-0b65-4cac-b449-6b77e665a08f"}}}} code=200 reason= stack= latency=0.021656464 INFO ts=2025-06-27T19:46:16Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=processing message: operation=created, txid= INFO ts=2025-06-27T19:51:03Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=offsets committed ([partition:offset]): [0:0] INFO ts=2025-06-27T19:51:03Z caller=log/log.go:30 service.name=inventory-api service.version=0.1.0 trace.id= span.id= subsystem=inventoryConsumer msg=consumed event from topic outbox.event.kessel.tuples, partition 0 at offset 0 # Relations API logs to show the tuple creation INFO ts=2025-06-27T19:51:03Z caller=log/helper.go:85 service.id=kessel-relations-api-588cc468f9-7ngqh service.name= service.version= trace.id= span.id= kind=server component=grpc operation=/kessel.relations.v1beta1.KesselTupleService/CreateTuples args=tuples:{resource:{type:{namespace:"hbi" name:"host"} id:"dd1b73b9-3e33-4264-968c-e3ce55b9afec"} relation:"t_workspace" subject:{subject:{type:{namespace:"rbac" name:"workspace"} id:"a64d17d0-aec3-410a-acd0-e0b85b22c076"}}} code=200 reason= stack= latency=2.174962056