Skip to content

Commit fff0480

Browse files
authored
[#63]: chore: retract 4.13, remove commander API
2 parents 35b1e26 + 34fae78 commit fff0480

File tree

3 files changed

+5
-16
lines changed

3 files changed

+5
-16
lines changed

go.mod

+3
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@ module github.com/roadrunner-server/api/v4
22

33
go 1.22.4
44

5+
// Removed cmder API
6+
retract v4.13.0
7+
58
require (
69
go.temporal.io/api v1.34.0
710
go.uber.org/zap v1.27.0

plugins/v4/jobs/driver.go

+2-10
Original file line numberDiff line numberDiff line change
@@ -20,20 +20,12 @@ type Driver interface {
2020
State(ctx context.Context) (*State, error)
2121
}
2222

23-
// Commander provides the ability to send a command to the Jobs plugin
24-
type Commander interface {
25-
// Command returns the command name
26-
Command() Command
27-
// Pipeline returns the associated command pipeline
28-
Pipeline() string
29-
}
30-
3123
// Constructor constructs Consumer interface. Endure abstraction.
3224
type Constructor interface {
3325
// Name returns the name of the driver
3426
Name() string
3527
// DriverFromConfig constructs a driver (e.g. kafka, amqp) from the configuration using the provided configKey
36-
DriverFromConfig(configKey string, queue Queue, pipeline Pipeline, cmder chan<- Commander) (Driver, error)
28+
DriverFromConfig(configKey string, queue Queue, pipeline Pipeline) (Driver, error)
3729
// DriverFromPipeline constructs a driver (e.g. kafka, amqp) from the pipeline. All configuration is provided by the pipeline
38-
DriverFromPipeline(pipe Pipeline, queue Queue, cmder chan<- Commander) (Driver, error)
30+
DriverFromPipeline(pipe Pipeline, queue Queue) (Driver, error)
3931
}

plugins/v4/jobs/state.go

-6
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,6 @@ const (
1111
RRAutoAck string = "rr_auto_ack"
1212
)
1313

14-
type Command string
15-
16-
const (
17-
Stop Command = "stop"
18-
)
19-
2014
// State represents job's state
2115
type State struct {
2216
// Pipeline name

0 commit comments

Comments
 (0)