balex74/post-hub-platform-k7m2xq9wnp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

kafka rag

Browse Source
This commit is contained in:
balex
2026-02-22 12:15:11 +01:00
parent 28d59afdbb
commit dda0773ad1
2 changed files with 2 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
rag-service/src/main/java/com/balex/rag/model/kafka/UserEvent.java
View File

@@ -1,31 +0,0 @@
package com.balex.rag.model.kafka;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.Instant;
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class UserEvent {
private EventType type;
private String userId;
private String chatId;
private Integer tokensUsed;
private Integer documentsFound;
@Builder.Default
private Instant timestamp = Instant.now();
public enum EventType {
USER_CREATED,
CHAT_CREATED,
CHAT_DELETED,
QUERY_SENT
}
}

4
rag-service/src/main/java/com/balex/rag/service/impl/EventPublisherImpl.java
View File

@@ -1,7 +1,7 @@
package com.balex.rag.service.impl; package com.balex.rag.service.impl;
import com.balex.rag.model.kafka.UserEvent; import com.balex.rag.model.dto.UserEvent;
import com.balex.rag.model.kafka.UserEvent.EventType; import com.balex.rag.model.dto.UserEvent.EventType;
import com.balex.rag.service.EventPublisher; import com.balex.rag.service.EventPublisher;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;