File tree Expand file tree Collapse file tree 4 files changed +14
-14
lines changed
Expand file tree Collapse file tree 4 files changed +14
-14
lines changed Original file line number Diff line number Diff line change @@ -8,8 +8,8 @@ retract v4.13.0
88require (
99 go.temporal.io/api v1.35.0
1010 go.uber.org/zap v1.27.0
11- google.golang.org/genproto/googleapis/api v0.0.0-20240624140628-dc46fd24d27d
12- google.golang.org/grpc v1.64 .0
11+ google.golang.org/genproto/googleapis/api v0.0.0-20240701130421-f6361c86f094
12+ google.golang.org/grpc v1.65 .0
1313 google.golang.org/protobuf v1.34.2
1414)
1515
@@ -18,5 +18,5 @@ require (
1818 golang.org/x/net v0.26.0 // indirect
1919 golang.org/x/sys v0.21.0 // indirect
2020 golang.org/x/text v0.16.0 // indirect
21- google.golang.org/genproto/googleapis/rpc v0.0.0-20240624140628-dc46fd24d27d // indirect
21+ google.golang.org/genproto/googleapis/rpc v0.0.0-20240701130421-f6361c86f094 // indirect
2222)
Original file line number Diff line number Diff line change @@ -20,12 +20,12 @@ golang.org/x/sys v0.21.0 h1:rF+pYz3DAGSQAxAu1CbC7catZg4ebC4UIeIhKxBZvws=
2020golang.org/x/sys v0.21.0 /go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA =
2121golang.org/x/text v0.16.0 h1:a94ExnEXNtEwYLGJSIUxnWoxoRz/ZcCsV63ROupILh4 =
2222golang.org/x/text v0.16.0 /go.mod h1:GhwF1Be+LQoKShO3cGOHzqOgRrGaYc9AvblQOmPVHnI =
23- google.golang.org/genproto/googleapis/api v0.0.0-20240624140628-dc46fd24d27d h1:Aqf0fiIdUQEj0Gn9mKFFXoQfTTEaNopWpfVyYADxiSg =
24- google.golang.org/genproto/googleapis/api v0.0.0-20240624140628-dc46fd24d27d /go.mod h1:Od4k8V1LQSizPRUK4OzZ7TBE/20k+jPczUDAEyvn69Y =
25- google.golang.org/genproto/googleapis/rpc v0.0.0-20240624140628-dc46fd24d27d h1:k3zyW3BYYR30e8v3x0bTDdE9vpYFjZHK+HcyqkrppWk =
26- google.golang.org/genproto/googleapis/rpc v0.0.0-20240624140628-dc46fd24d27d /go.mod h1:Ue6ibwXGpU+dqIcODieyLOcgj7z8+IcskoNIgZxtrFY =
27- google.golang.org/grpc v1.64 .0 h1:KH3VH9y/MgNQg1dE7b3XfVK0GsPSIzJwdF617gUSbvY =
28- google.golang.org/grpc v1.64 .0 /go.mod h1:oxjF8E3FBnjp+/gVFYdWacaLDx9na1aqy9oovLpxQYg =
23+ google.golang.org/genproto/googleapis/api v0.0.0-20240701130421-f6361c86f094 h1:0+ozOGcrp+Y8Aq8TLNN2Aliibms5LEzsq99ZZmAGYm0 =
24+ google.golang.org/genproto/googleapis/api v0.0.0-20240701130421-f6361c86f094 /go.mod h1:fJ/e3If/Q67Mj99hin0hMhiNyCRmt6BQ2aWIJshUSJw =
25+ google.golang.org/genproto/googleapis/rpc v0.0.0-20240701130421-f6361c86f094 h1:BwIjyKYGsK9dMCBOorzRri8MQwmi7mT9rGHsCEinZkA =
26+ google.golang.org/genproto/googleapis/rpc v0.0.0-20240701130421-f6361c86f094 /go.mod h1:Ue6ibwXGpU+dqIcODieyLOcgj7z8+IcskoNIgZxtrFY =
27+ google.golang.org/grpc v1.65 .0 h1:bs/cUb4lp1G5iImFFd3u5ixQzweKizoZJAwBNLR42lc =
28+ google.golang.org/grpc v1.65 .0 /go.mod h1:WgYC2ypjlB0EiQi6wdKixMqukr6lBc0Vo+oOgjrM5ZQ =
2929google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg =
3030google.golang.org/protobuf v1.34.2 /go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw =
3131gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA =
Original file line number Diff line number Diff line change 66
77// Queue represents JOBS plugin queue with it's elements types inside
88type Queue interface {
9- // Remove removes element with provided ID (if exists) and returns that elements
9+ // Remove removes an element with provided ID (if exists) and returns that element
1010 Remove (id string ) []Job
1111 // Insert adds an item to the queue
1212 Insert (item Job )
@@ -31,7 +31,7 @@ type Job interface {
3131 Body () []byte
3232 // Context returns any meta-information associated with the item
3333 Context () ([]byte , error )
34- // Headers returns the metadata for the item
34+ // Headers return the metadata for the item
3535 Headers () map [string ][]string
3636}
3737
@@ -50,11 +50,11 @@ type Message interface {
5050 // UpdatePriority sets the priority of the Job. Priority is optional but cannot be set to 0.
5151 // The default priority is 10
5252 UpdatePriority (int64 )
53- // Headers returns the metadata for the item
53+ // Headers return the metadata for the item
5454 Headers () map [string ][]string
5555}
5656
57- // KAFKA options (leave them empty for other drivers)
57+ // KafkaOptions - options (leave them empty for other drivers)
5858type KafkaOptions interface {
5959 // Offset returns the offset associated with the Job
6060 Offset () int64
Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ type State struct {
1919 Driver string
2020 // Queue name (tube for the beanstalk)
2121 Queue string
22- // Active jobs which are consumed from the driver but not handled by the PHP worker yet
22+ // Active jobs which are consumed by the driver but not handled by the PHP worker yet
2323 Active int64
2424 // Delayed jobs
2525 Delayed int64
You can’t perform that action at this time.
0 commit comments