Skip to content

Commit 3c1f0b7

Browse files
committed
chore: int64,uint64 -> int,uint
Signed-off-by: Valery Piashchynski <piashchynski.valery@gmail.com>
1 parent 6252f1d commit 3c1f0b7

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

plugins/v4/jobs/job.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ type Queue interface {
1313
// ExtractMin returns the item with the highest priority (less value is the highest priority)
1414
ExtractMin() Job
1515
// Len returns the number of items in the queue
16-
Len() uint64
16+
Len() uint
1717
}
1818

1919
// Job represents a binary heap item
@@ -44,22 +44,22 @@ type Message interface {
4444
// Payload returns the data associated with the job
4545
Payload() []byte
4646
// Delay returns the delay time for the Job (not supported by all drivers)
47-
Delay() int64
47+
Delay() int
4848
// AutoAck returns the autocommit status for the Job
4949
AutoAck() bool
5050
// UpdatePriority sets the priority of the Job. Priority is optional but cannot be set to 0.
5151
// The default priority is 10
52-
UpdatePriority(int64)
52+
UpdatePriority(int)
5353
// Headers returns the metadata for the item
5454
Headers() map[string][]string
5555
}
5656

5757
// KAFKA options (leave them empty for other drivers)
5858
type KafkaOptions interface {
5959
// Offset returns the offset associated with the Job
60-
Offset() int64
60+
Offset() int
6161
// Partition returns the partition associated with the Job
62-
Partition() int32
62+
Partition() int
6363
// Topic returns the topic associated with the Job
6464
Topic() string
6565
// Metadata returns the metadata associated with the Job
@@ -85,7 +85,7 @@ type Pipeline interface {
8585
// This might be used for SQS attributes or tags, for example
8686
Map(name string, out map[string]string) error
8787
// Priority returns the default pipeline priority
88-
Priority() int64
88+
Priority() int
8989
// Get is used to retrieve the data associated with a key
9090
Get(key string) interface{}
9191
}

0 commit comments

Comments
 (0)