package proto
Import Path
github.com/hibiken/asynq/internal/proto (on go.dev)
Dependency Relation
imports 6 packages, and imported by one package
Involved Source Files
asynq.pb.go
Package-Level Type Names (total 5)
SchedulerEnqueueEvent holds information about an enqueue event
by a scheduler.
Time the task was enqueued.
ID of the task that was enqueued.
Deprecated: Use SchedulerEnqueueEvent.ProtoReflect.Descriptor instead.
(*SchedulerEnqueueEvent) GetEnqueueTime() *timestamppb.Timestamp
(*SchedulerEnqueueEvent) GetTaskId() string
(*SchedulerEnqueueEvent) ProtoMessage()
(*SchedulerEnqueueEvent) ProtoReflect() protoreflect.Message
(*SchedulerEnqueueEvent) Reset()
(*SchedulerEnqueueEvent) String() string
*SchedulerEnqueueEvent : github.com/gogo/protobuf/proto.Message
*SchedulerEnqueueEvent : expvar.Var
*SchedulerEnqueueEvent : fmt.Stringer
*SchedulerEnqueueEvent : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage
*SchedulerEnqueueEvent : google.golang.org/protobuf/runtime/protoiface.MessageV1
SchedulerEntry holds information about a periodic task registered
with a scheduler.
Options used to enqueue the periodic task.
Identifier of the scheduler entry.
Next time the task will be enqueued.
Last time the task was enqueued.
Zero time if task was never enqueued.
Periodic schedule spec of the entry.
Task payload of the periodic task.
Task type of the periodic task.
Deprecated: Use SchedulerEntry.ProtoReflect.Descriptor instead.
(*SchedulerEntry) GetEnqueueOptions() []string
(*SchedulerEntry) GetId() string
(*SchedulerEntry) GetNextEnqueueTime() *timestamppb.Timestamp
(*SchedulerEntry) GetPrevEnqueueTime() *timestamppb.Timestamp
(*SchedulerEntry) GetSpec() string
(*SchedulerEntry) GetTaskPayload() []byte
(*SchedulerEntry) GetTaskType() string
(*SchedulerEntry) ProtoMessage()
(*SchedulerEntry) ProtoReflect() protoreflect.Message
(*SchedulerEntry) Reset()
(*SchedulerEntry) String() string
*SchedulerEntry : github.com/gogo/protobuf/proto.Message
*SchedulerEntry : expvar.Var
*SchedulerEntry : fmt.Stringer
*SchedulerEntry : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage
*SchedulerEntry : google.golang.org/protobuf/runtime/protoiface.MessageV1
ServerInfo holds information about a running server.
Number of workers currently processing tasks.
Maximum number of concurrency this server will use.
Host machine the server is running on.
PID of the server process.
List of queue names with their priorities.
The server will consume tasks from the queues and prioritize
queues with higher priority numbers.
Unique identifier for this server.
Time this server was started.
Status indicates the status of the server.
If set, the server will always consume tasks from a queue with higher
priority.
Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.
(*ServerInfo) GetActiveWorkerCount() int32
(*ServerInfo) GetConcurrency() int32
(*ServerInfo) GetHost() string
(*ServerInfo) GetPid() int32
(*ServerInfo) GetQueues() map[string]int32
(*ServerInfo) GetServerId() string
(*ServerInfo) GetStartTime() *timestamppb.Timestamp
(*ServerInfo) GetStatus() string
(*ServerInfo) GetStrictPriority() bool
(*ServerInfo) ProtoMessage()
(*ServerInfo) ProtoReflect() protoreflect.Message
(*ServerInfo) Reset()
(*ServerInfo) String() string
*ServerInfo : github.com/gogo/protobuf/proto.Message
*ServerInfo : expvar.Var
*ServerInfo : fmt.Stringer
*ServerInfo : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage
*ServerInfo : google.golang.org/protobuf/runtime/protoiface.MessageV1
TaskMessage is the internal representation of a task with additional
metadata fields.
Next ID: 15
Time when the task completed in success in Unix time,
the number of seconds elapsed since January 1, 1970 UTC.
This field is populated if result_ttl > 0 upon completion.
Deadline specifies the deadline for the task in Unix time,
the number of seconds elapsed since January 1, 1970 UTC.
Use zero to indicate no deadline.
Error message from the last failure.
GroupKey is a name of the group used for task aggregation.
This field is optional and empty value means no aggregation for the task.
Unique identifier for the task.
Time of last failure in Unix time,
the number of seconds elapsed since January 1, 1970 UTC.
Use zero to indicate no last failure.
Payload holds data needed to process the task.
Name of the queue to which this task belongs.
Retention period specified in a number of seconds.
The task will be stored in redis as a completed task until the TTL
expires.
Number of times this task has been retried so far.
Max number of retries for this task.
Timeout specifies timeout in seconds.
Use zero to indicate no timeout.
Type indicates the kind of the task to be performed.
UniqueKey holds the redis key used for uniqueness lock for this task.
Empty string indicates that no uniqueness lock was used.
Deprecated: Use TaskMessage.ProtoReflect.Descriptor instead.
(*TaskMessage) GetCompletedAt() int64
(*TaskMessage) GetDeadline() int64
(*TaskMessage) GetErrorMsg() string
(*TaskMessage) GetGroupKey() string
(*TaskMessage) GetId() string
(*TaskMessage) GetLastFailedAt() int64
(*TaskMessage) GetPayload() []byte
(*TaskMessage) GetQueue() string
(*TaskMessage) GetRetention() int64
(*TaskMessage) GetRetried() int32
(*TaskMessage) GetRetry() int32
(*TaskMessage) GetTimeout() int64
(*TaskMessage) GetType() string
(*TaskMessage) GetUniqueKey() string
(*TaskMessage) ProtoMessage()
(*TaskMessage) ProtoReflect() protoreflect.Message
(*TaskMessage) Reset()
(*TaskMessage) String() string
*TaskMessage : github.com/gogo/protobuf/proto.Message
*TaskMessage : expvar.Var
*TaskMessage : fmt.Stringer
*TaskMessage : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage
*TaskMessage : google.golang.org/protobuf/runtime/protoiface.MessageV1
WorkerInfo holds information about a running worker.
Deadline by which the worker needs to complete processing
the task. If worker exceeds the deadline, the task will fail.
Host matchine this worker is running on.
PID of the process in which this worker is running.
Name of the queue the task the worker is processing belongs.
ID of the server in which this worker is running.
Time this worker started processing the task.
ID of the task this worker is processing.
Payload of the task this worker is processing.
Type of the task this worker is processing.
Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.
(*WorkerInfo) GetDeadline() *timestamppb.Timestamp
(*WorkerInfo) GetHost() string
(*WorkerInfo) GetPid() int32
(*WorkerInfo) GetQueue() string
(*WorkerInfo) GetServerId() string
(*WorkerInfo) GetStartTime() *timestamppb.Timestamp
(*WorkerInfo) GetTaskId() string
(*WorkerInfo) GetTaskPayload() []byte
(*WorkerInfo) GetTaskType() string
(*WorkerInfo) ProtoMessage()
(*WorkerInfo) ProtoReflect() protoreflect.Message
(*WorkerInfo) Reset()
(*WorkerInfo) String() string
*WorkerInfo : github.com/gogo/protobuf/proto.Message
*WorkerInfo : expvar.Var
*WorkerInfo : fmt.Stringer
*WorkerInfo : google.golang.org/protobuf/reflect/protoreflect.ProtoMessage
*WorkerInfo : google.golang.org/protobuf/runtime/protoiface.MessageV1
Package-Level Variables (only one)
 |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |