From f0b7b1fc6bb6e317a2c2a7ca864eef9daca23b8f Mon Sep 17 00:00:00 2001 From: Blake Gentry Date: Fri, 2 Aug 2024 17:33:46 -0500 Subject: [PATCH] expose Driver on Client --- client.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/client.go b/client.go index 09459471..e3682264 100644 --- a/client.go +++ b/client.go @@ -988,6 +988,13 @@ func (c *Client[TTx]) handleLeadershipChangeLoop(ctx context.Context, shouldStar return nil } +// Driver exposes the underlying driver used by the client. +// +// API is not stable. DO NOT USE. +func (c *Client[TTx]) Driver() riverdriver.Driver[TTx] { + return c.driver +} + // JobCancel cancels the job with the given ID. If possible, the job is // cancelled immediately and will not be retried. The provided context is used // for the underlying Postgres update and can be used to cancel the operation or