58 lines
2.0 KiB
Go
58 lines
2.0 KiB
Go
|
package repository
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"app-cloudep-tweeting-service/gen_result/pb/tweeting"
|
|||
|
|
"context"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
----------------------------------------
|
|||
|
|
｜ ｜ ｜ ｜ ｜
|
|||
|
|
｜ data A｜ data B ｜NO Data ｜ .... ｜
|
|||
|
|
｜ ｜ ｜ ｜ ｜
|
|||
|
|
----------------------------------------
|
|||
|
|
|
|||
|
|
動態時報在發現這個 Queue 有 No Data 的 Flag 時
|
|||
|
|
就不再去 Query 資料庫，防止被狂刷。
|
|||
|
|
只是要注意在業務上何時要 加入/刪除 這個 Flag
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
// TimelineRepository 定義時間線的存儲接口，可以根據不同的排序策略實現。
|
|||
|
|
type TimelineRepository interface {
|
|||
|
|
// AddPost 將貼文添加到動態時報，並根據排序策略進行排序。
|
|||
|
|
AddPost(ctx context.Context, req AddPostRequest) error
|
|||
|
|
// FetchTimeline 獲取指定用戶的動態時報。
|
|||
|
|
FetchTimeline(ctx context.Context, req FetchTimelineRequest) (FetchTimelineResponse, error)
|
|||
|
|
// SetNoMoreDataFlag 標記時間線已完整，避免繼續查詢資料庫。
|
|||
|
|
SetNoMoreDataFlag(ctx context.Context, uid string) error
|
|||
|
|
// HasNoMoreData 檢查時間線是否已完整，決定是否需要查詢資料庫。
|
|||
|
|
HasNoMoreData(ctx context.Context, uid string) (bool, error)
|
|||
|
|
// ClearNoMoreDataFlag 清除時間線的 "NoMoreData" 標誌。
|
|||
|
|
ClearNoMoreDataFlag(ctx context.Context, uid string) error
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// AddPostRequest 用於將貼文添加到時間線的請求結構體。
|
|||
|
|
type AddPostRequest struct {
|
|||
|
|
UID string
|
|||
|
|
PostItems []TimelineItem
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// TimelineItem 表示時間線中的一個元素，排序依據取決於 Score。
|
|||
|
|
type TimelineItem struct {
|
|||
|
|
PostID string // 貼文ID
|
|||
|
|
Score int64 // 排序使用的分數，根據具體實現可能代表時間、優先級等
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// FetchTimelineRequest 用於獲取時間線的請求結構體。
|
|||
|
|
type FetchTimelineRequest struct {
|
|||
|
|
UID string
|
|||
|
|
PageSize int64
|
|||
|
|
PageIndex int64
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// FetchTimelineResponse 表示獲取時間線的回應結構體。
|
|||
|
|
type FetchTimelineResponse struct {
|
|||
|
|
Items []TimelineItem
|
|||
|
|
Page tweeting.Pager
|
|||
|
|
}
|