Delete deletes all events for a specific conversation ID.
(ctx context.Context, conversationID string)
| 261 | |
| 262 | // Delete deletes all events for a specific conversation ID. |
| 263 | func (d *Controller) Delete(ctx context.Context, conversationID string) error { |
| 264 | if conversationID == "" { |
| 265 | return fmt.Errorf("conversation_id is required") |
| 266 | } |
| 267 | |
| 268 | return d.eventLog.DeleteEvents(ctx, conversationID) |
| 269 | } |
| 270 | |
| 271 | // Fork forks an event log from a specific conversation up to a checkpoint. |
| 272 | func (d *Controller) Fork(ctx context.Context, srcConversationID string, srcSeq int32, destConversationID string) (string, error) { |
no test coverage detected