Skip to content

Commit

Permalink
chore(deps): update dependencies
Browse files Browse the repository at this point in the history
  • Loading branch information
rustatian committed Jan 21, 2023
1 parent 9898513 commit 864a68c
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
</p>
<p align="center">
<a href="https://packagist.org/packages/spiral/roadrunner"><img src="https://poser.pugx.org/spiral/roadrunner/version"></a>
<a href="https://pkg.go.dev/github.com/roadrunner-server/api/v2?tab=doc"><img src="https://godoc.org/github.com/roadrunner-server/api/v2?status.svg"></a>
<a href="https://pkg.go.dev/github.com/roadrunner-server/api/v4?tab=doc"><img src="https://godoc.org/github.com/roadrunner-server/api/v4?status.svg"></a>
<a href="https://github.com/roadrunner-server/api/actions"><img src="https://github.com/roadrunner-server/api/workflows/Linters/badge.svg" alt=""></a>
<a href="https://goreportcard.com/report/github.com/roadrunner-server/api"><img src="https://goreportcard.com/badge/github.com/roadrunner-server/api"></a>
<a href="https://discord.gg/TFeEmCs"><img src="https://img.shields.io/badge/discord-chat-magenta.svg"></a>
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/roadrunner-server/api/v3
module github.com/roadrunner-server/api/v4

go 1.19

Expand Down
10 changes: 5 additions & 5 deletions plugins/v1/jobs/interface.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package jobs
import (
"context"

pq "github.com/roadrunner-server/api/v3/plugins/v1/priority_queue"
pq "github.com/roadrunner-server/api/v4/plugins/v1/priority_queue"
)

// constant keys to pack/unpack messages from different drivers
Expand Down Expand Up @@ -131,8 +131,8 @@ type Acknowledger interface {
Respond(payload []byte, queue string) error
}

// Commanders provides the ability to send a command to the Jobs plugin
type Commanders interface {
// Commander provides the ability to send a command to the Jobs plugin
type Commander interface {
// Command returns the command name
Command() Command
// Pipeline returns the associated command pipeline
Expand All @@ -144,7 +144,7 @@ type Constructor interface {
// Name returns the name of the driver
Name() string
// DriverFromConfig constructs a driver (e.g. kafka, amqp) from the configuration using the provided configKey
DriverFromConfig(configKey string, queue pq.Queue, pipeline Pipeline, cmder chan<- Commanders) (Driver, error)
DriverFromConfig(configKey string, queue pq.Queue, pipeline Pipeline, cmder chan<- Commander) (Driver, error)
// DriverFromPipeline constructs a driver (e.g. kafka, amqp) from the pipeline. All configuration is provided by the pipeline
DriverFromPipeline(pipe Pipeline, queue pq.Queue, cmder chan<- Commanders) (Driver, error)
DriverFromPipeline(pipe Pipeline, queue pq.Queue, cmder chan<- Commander) (Driver, error)
}

0 comments on commit 864a68c

Please sign in to comment.