retention

func Migrate ¶

func Migrate(req router.Request, _ router.Response) error

Migrate sets the last used time of the thread to the current time if it is not set.

func RunRetention ¶

func RunRetention(policy time.Duration) func(req router.Request, resp router.Response) error

func SetLastUsedTime ¶

func SetLastUsedTime(ctx context.Context, c kclient.Client, thread *v1.Thread) error

SetLastUsedTime sets the last used time for a thread and its parent thread if it has one. It does not call Update() on the thread, so the caller is responsible for calling Update() if needed.