From 3c608b5a535db8f77d1d61d077097b3d5df1adad Mon Sep 17 00:00:00 2001 From: Aaron Harper Date: Tue, 18 Feb 2025 20:42:33 -0500 Subject: [PATCH] Delete default client Send and SendMany --- client.go | 18 ------------------ tests/invoke_test.go | 4 ++-- 2 files changed, 2 insertions(+), 20 deletions(-) diff --git a/client.go b/client.go index c9e2c592..349c1539 100644 --- a/client.go +++ b/client.go @@ -18,24 +18,6 @@ const ( defaultEndpoint = "https://inn.gs" ) -// Send uses the DefaultClient to send the given event. -func Send(ctx context.Context, e any) (string, error) { - client, ok := ctx.Value(clientCtxKey).(Client) - if !ok || client == nil { - return "", fmt.Errorf("client not found in context") - } - return client.Send(ctx, e) -} - -// SendMany uses the DefaultClient to send the given event batch. -func SendMany(ctx context.Context, e []any) ([]string, error) { - client, ok := ctx.Value(clientCtxKey).(Client) - if !ok || client == nil { - return nil, fmt.Errorf("client not found in context") - } - return client.SendMany(ctx, e) -} - // Client represents a client used to send events to Inngest. type Client interface { AppID() string diff --git a/tests/invoke_test.go b/tests/invoke_test.go index e2655965..68e4d97c 100644 --- a/tests/invoke_test.go +++ b/tests/invoke_test.go @@ -312,7 +312,7 @@ func TestInvoke(t *testing.T) { defer server.Close() r.NoError(sync()) - _, err = inngestgo.Send(ctx, inngestgo.Event{ + _, err = c.Send(ctx, inngestgo.Event{ Name: eventName, Data: map[string]any{"foo": "bar"}}, ) @@ -392,7 +392,7 @@ func TestInvoke(t *testing.T) { defer server.Close() r.NoError(sync()) - _, err = inngestgo.Send(ctx, inngestgo.Event{ + _, err = c.Send(ctx, inngestgo.Event{ Name: eventName, Data: map[string]any{"foo": "bar"}}, )