Skip to content

Add Queue Publisher - #6

Merged
ngoyal16 merged 13 commits into
mainfrom
feature/queue-publisher-13572187248206151659
Jan 8, 2026
Merged

Add Queue Publisher#6
ngoyal16 merged 13 commits into
mainfrom
feature/queue-publisher-13572187248206151659

Conversation

@google-labs-jules

@google-labs-jules google-labs-jules Bot commented Jan 7, 2026

Copy link
Copy Markdown
Contributor

Added a Publisher struct to pkg/queue to enable dispatching Laravel-compatible jobs from Go. This includes generating the correct JSON payload and serializing job properties into a PHP-serialized string. Verified with unit tests.

PR created automatically by Jules for task 13572187248206151659 started by @ngoyal16

@google-labs-jules
Add Publisher to dispatch jobs to Laravel queues
e181b93 
Implemented a `Publisher` in `pkg/queue` that allows Go applications to dispatch jobs compatible with Laravel's queue system.
- Uses `php_serialize` to construct the PHP serialized command payload.
- Creates a `LaravelJob` JSON payload with correct structure.
- Supports dispatching to default or specific queues.
- Updated `go.mod` to include `github.com/google/uuid`.
@google-labs-jules

google-labs-jules Bot commented Jan 7, 2026

Copy link
Copy Markdown
Contributor Author

👋 Jules, reporting for duty! I'm here to lend a hand with this pull request.

When you start a review, I'll add a 👀 emoji to each comment to let you know I've read it. I'll focus on feedback directed at me and will do my best to stay out of conversations between you and other bots or reviewers to keep the noise down.

I'll push a commit with your requested changes shortly after. Please note there might be a delay between these steps, but rest assured I'm on the job!

For more direct control, you can switch me to Reactive Mode. When this mode is on, I will only act on comments where you specifically mention me with @jules. You can find this option in the Pull Request section of your global Jules UI settings. You can always switch back!

New to Jules? Learn more at jules.google/docs.

For security, I will only act on instructions from the user who triggered this task.

@google-labs-jules
Refactor worker command and add job publisher
461f8d4 
- Added `Publisher` in `pkg/queue` to dispatch Laravel-compatible jobs.
- Refactored `pkg/console` to allow injecting `Driver` and `FailedJobProvider` into `queue:work` command.
- Updated `cmd/worker/main.go` to demonstrate configuration injection.
- Ensured `LaravelJob` payload structure uses `json.RawMessage` for correct JSON embedding.
@google-labs-jules
Refactor worker command and add job publisher
e660037 
- Added `Publisher` in `pkg/queue` to dispatch Laravel-compatible jobs.
- Refactored `pkg/console` to allow injecting `Driver` and `FailedJobProvider` into `queue:work` command.
- Updated `cmd/worker/main.go` to demonstrate configuration injection and custom command registration.
- Ensured `LaravelJob` payload structure uses `json.RawMessage` for correct JSON embedding.
@google-labs-jules
Refactor worker command, add job publisher, and setup CI release
cb1dea4 
- Added `Publisher` in `pkg/queue` to dispatch Laravel-compatible jobs using `php_serialize`.
- Refactored `pkg/console` to allow injecting `Driver` and `FailedJobProvider` into `queue:work` command.
- Updated `cmd/worker/main.go` to demonstrate configuration injection and custom command registration.
- Added `.github/workflows/release.yml` using `release-please` for automated semantic versioning.
- Ensured `LaravelJob` payload structure uses `json.RawMessage`.
@google-labs-jules
Add configuration, adapters, and publishing support
fab4b26 
- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow.
@ngoyal16

ngoyal16 commented Jan 8, 2026

Copy link
Copy Markdown
Contributor

[DEPRECATED] Release Please Action - please use https://github.com/googleapis/release-please-action

@google-labs-jules

google-labs-jules Bot commented Jan 8, 2026

Copy link
Copy Markdown
Contributor Author

[DEPRECATED] Release Please Action - please use https://github.com/googleapis/release-please-action

Acknowledged. I will update the action to use googleapis/release-please-action as requested.

@google-labs-jules
Add configuration, adapters, and publishing support
0bfdcd4 
- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow.
- Updated database driver tests to match new config structure.
- Fixed Postgres compatibility in database cache store.
@google-labs-jules
Add configuration, adapters, and publishing support
c39e70c 
- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow.
- Updated database driver tests to match new config structure.
- Fixed Postgres compatibility in database cache store.
- Fixed linter errors in cache and worker packages.
@google-labs-jules
Add configuration, adapters, and publishing support
2467ae5 
- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow using `googleapis/release-please-action`.
- Updated database driver tests to match new config structure.
- Fixed linter errors in cache and worker packages.
- Added example usage in `cmd/worker/main.go`.
@google-labs-jules
Add configuration, adapters, publishing support, and documentation
f419c44 
- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow using `googleapis/release-please-action`.
- Updated database driver tests to match new config structure.
- Fixed linter errors in cache and worker packages.
- Added documentation for registering job handlers in `docs/register_jobs.md`.
- Updated README.md to reference new docs.
- Added example usage in `cmd/worker/main.go`.
@google-labs-jules
Add configuration, adapters, publishing support, and documentation
cbe75d4 
- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow using `googleapis/release-please-action`.
- Updated database driver tests to match new config structure.
- Fixed linter errors in cache and worker packages.
- Added documentation for registering job handlers in `docs/register_jobs.md` and logging in `docs/logging.md`.
- Updated README.md to reference new docs.
- Added example usage in `cmd/worker/main.go`.
@google-labs-jules
Add configuration, adapters, publishing support, and enhanced observa…
65ac4a9 
…bility

- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow using `googleapis/release-please-action`.
- Updated database driver tests to match new config structure.
- Fixed linter errors in cache and worker packages.
- Enhanced telemetry with `service` (application name) and `command` in structured logs.
- Added documentation for registering job handlers (`docs/register_jobs.md`) and logging (`docs/logging.md`).
- Added example usage in `cmd/worker/main.go`.
@ngoyal16

ngoyal16 commented Jan 8, 2026

Copy link
Copy Markdown
Contributor

not enough arguments in call to NewWorker

@google-labs-jules

google-labs-jules Bot commented Jan 8, 2026

Copy link
Copy Markdown
Contributor Author

not enough arguments in call to NewWorker

Fixed the NewWorker calls in documentation and tests to include the appName and tracer arguments.

@google-labs-jules
Add configuration, adapters, publishing support, and enhanced observa…
f311700 
…bility

- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow using `googleapis/release-please-action`.
- Updated database driver tests to match new config structure.
- Fixed linter errors in cache and worker packages.
- Enhanced telemetry with `service` (application name) and `command` in structured logs.
- Added documentation for registering job handlers (`docs/register_jobs.md`) and logging (`docs/logging.md`).
- Added example usage in `cmd/worker/main.go`.
- Fixed potential nil panic in worker config loading.
- Updated `NewWorker` calls in documentation and tests.
@ngoyal16

ngoyal16 commented Jan 8, 2026

Copy link
Copy Markdown
Contributor

in kernal schdule currently redis lock is supported. add database_lock also

if database is postgresql use postgresql lock.

also implment queue:work like for schedule:run and user can register command to be schdule to it (external apps). also add usees doc for it similar like queue doc.

@google-labs-jules

google-labs-jules Bot commented Jan 8, 2026

Copy link
Copy Markdown
Contributor Author

in kernal schdule currently redis lock is supported. add database_lock also

if database is postgresql use postgresql lock.

also implment queue:work like for schedule:run and user can register command to be schdule to it (external apps). also add usees doc for it similar like queue doc.

Implemented DatabaseLockProvider supporting MySQL (GET_LOCK) and PostgreSQL (pg_try_advisory_lock). Added schedule:run command and updated documentation.

@google-labs-jules
Add configuration, adapters, publishing support, scheduler, and enhan…
445c5d1 
…ced observability

- Implemented `pkg/config` to load Laravel-style `.env` configuration.
- Added `pkg/database` factory for MySQL and PostgreSQL connections.
- Added `pkg/cache` adapters for Redis, Memcached, and Database.
- Updated `pkg/console` to auto-configure `queue:work` driver based on config.
- Implemented `pkg/queue` Publisher for dispatching Laravel jobs.
- Added SQS driver support.
- Configured CI release workflow using `googleapis/release-please-action`.
- Updated database driver tests to match new config structure.
- Fixed linter errors in cache and worker packages.
- Enhanced telemetry with `service` (application name) and `command` in structured logs.
- Added documentation for registering job handlers (`docs/register_jobs.md`) and logging (`docs/logging.md`).
- Added scheduler with `schedule:run` command and database locking support (`pkg/schedule/database_lock.go`).
- Added scheduler documentation (`docs/scheduler.md`).
- Added example usage in `cmd/worker/main.go`.
- Fixed potential nil panic in worker config loading.
- Updated `NewWorker` calls in documentation and tests.
@ngoyal16
ngoyal16 marked this pull request as ready for review January 8, 2026 16:24
@ngoyal16
ngoyal16 merged commit c516633 into main Jan 8, 2026
2 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@ngoyal16