(data *data.Data)
| 49 | type Service queue.Service[*Task] |
| 50 | |
| 51 | func NewService(data *data.Data) Service { |
| 52 | q := queue.New[*Task]("vector_sync", 128) |
| 53 | q.RegisterHandler(func(ctx context.Context, msg *Task) error { |
| 54 | return handle(ctx, data, msg) |
| 55 | }) |
| 56 | return q |
| 57 | } |
| 58 | |
| 59 | func handle(ctx context.Context, data *data.Data, msg *Task) error { |
| 60 | if msg == nil || msg.ObjectID == "" { |
no test coverage detected