diff --git a/go.mod b/go.mod index 4a29467..f6868cb 100644 --- a/go.mod +++ b/go.mod @@ -2,6 +2,9 @@ module github.com/roadrunner-server/api/v4 go 1.22.4 +// Removed cmder API +retract v4.13.0 + require ( go.temporal.io/api v1.34.0 go.uber.org/zap v1.27.0 diff --git a/plugins/v4/jobs/driver.go b/plugins/v4/jobs/driver.go index d2dff24..bef0b1b 100644 --- a/plugins/v4/jobs/driver.go +++ b/plugins/v4/jobs/driver.go @@ -20,20 +20,12 @@ type Driver interface { State(ctx context.Context) (*State, error) } -// 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 - Pipeline() string -} - // Constructor constructs Consumer interface. Endure abstraction. 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 Queue, pipeline Pipeline, cmder chan<- Commander) (Driver, error) + DriverFromConfig(configKey string, queue Queue, pipeline Pipeline) (Driver, error) // DriverFromPipeline constructs a driver (e.g. kafka, amqp) from the pipeline. All configuration is provided by the pipeline - DriverFromPipeline(pipe Pipeline, queue Queue, cmder chan<- Commander) (Driver, error) + DriverFromPipeline(pipe Pipeline, queue Queue) (Driver, error) } diff --git a/plugins/v4/jobs/state.go b/plugins/v4/jobs/state.go index 1da72ef..608fdd6 100644 --- a/plugins/v4/jobs/state.go +++ b/plugins/v4/jobs/state.go @@ -11,12 +11,6 @@ const ( RRAutoAck string = "rr_auto_ack" ) -type Command string - -const ( - Stop Command = "stop" -) - // State represents job's state type State struct { // Pipeline name