Function sendNotification

internal/notifier/notifier_test.go:702–711

(ctx context.Context, t *testing.T, exec riverdriver.Executor, schema, topic string, payload string)

}

func sendNotification(ctx context.Context, t *testing.T, exec riverdriver.Executor, schema, topic string, payload string) {
	t.Helper()

	t.Logf("Sending notification on %q: %s", topic, payload)
	require.NoError(t, exec.NotifyMany(ctx, &riverdriver.NotifyManyParams{
		Payload: []string{payload},
		Schema:  schema,
		Topic:   topic,
	}))
}