Versions in this module Expand all Collapse all v0 v0.25.2 Dec 16, 2024 v0.25.1 Dec 16, 2024 Changes in this version + var File_asynq_proto protoreflect.FileDescriptor + type SchedulerEnqueueEvent struct + EnqueueTime *timestamppb.Timestamp + TaskId string + func (*SchedulerEnqueueEvent) Descriptor() ([]byte, []int) + func (*SchedulerEnqueueEvent) ProtoMessage() + func (x *SchedulerEnqueueEvent) GetEnqueueTime() *timestamppb.Timestamp + func (x *SchedulerEnqueueEvent) GetTaskId() string + func (x *SchedulerEnqueueEvent) ProtoReflect() protoreflect.Message + func (x *SchedulerEnqueueEvent) Reset() + func (x *SchedulerEnqueueEvent) String() string + type SchedulerEntry struct + EnqueueOptions []string + Id string + NextEnqueueTime *timestamppb.Timestamp + PrevEnqueueTime *timestamppb.Timestamp + Spec string + TaskPayload []byte + TaskType string + func (*SchedulerEntry) Descriptor() ([]byte, []int) + func (*SchedulerEntry) ProtoMessage() + func (x *SchedulerEntry) GetEnqueueOptions() []string + func (x *SchedulerEntry) GetId() string + func (x *SchedulerEntry) GetNextEnqueueTime() *timestamppb.Timestamp + func (x *SchedulerEntry) GetPrevEnqueueTime() *timestamppb.Timestamp + func (x *SchedulerEntry) GetSpec() string + func (x *SchedulerEntry) GetTaskPayload() []byte + func (x *SchedulerEntry) GetTaskType() string + func (x *SchedulerEntry) ProtoReflect() protoreflect.Message + func (x *SchedulerEntry) Reset() + func (x *SchedulerEntry) String() string + type ServerInfo struct + ActiveWorkerCount int32 + Concurrency int32 + Host string + Pid int32 + Queues map[string]int32 + ServerId string + StartTime *timestamppb.Timestamp + Status string + StrictPriority bool + func (*ServerInfo) Descriptor() ([]byte, []int) + func (*ServerInfo) ProtoMessage() + func (x *ServerInfo) GetActiveWorkerCount() int32 + func (x *ServerInfo) GetConcurrency() int32 + func (x *ServerInfo) GetHost() string + func (x *ServerInfo) GetPid() int32 + func (x *ServerInfo) GetQueues() map[string]int32 + func (x *ServerInfo) GetServerId() string + func (x *ServerInfo) GetStartTime() *timestamppb.Timestamp + func (x *ServerInfo) GetStatus() string + func (x *ServerInfo) GetStrictPriority() bool + func (x *ServerInfo) ProtoReflect() protoreflect.Message + func (x *ServerInfo) Reset() + func (x *ServerInfo) String() string + type TaskMessage struct + CompletedAt int64 + Deadline int64 + ErrorMsg string + GroupKey string + Id string + LastFailedAt int64 + Payload []byte + Queue string + Retention int64 + Retried int32 + Retry int32 + Timeout int64 + Type string + UniqueKey string + func (*TaskMessage) Descriptor() ([]byte, []int) + func (*TaskMessage) ProtoMessage() + func (x *TaskMessage) GetCompletedAt() int64 + func (x *TaskMessage) GetDeadline() int64 + func (x *TaskMessage) GetErrorMsg() string + func (x *TaskMessage) GetGroupKey() string + func (x *TaskMessage) GetId() string + func (x *TaskMessage) GetLastFailedAt() int64 + func (x *TaskMessage) GetPayload() []byte + func (x *TaskMessage) GetQueue() string + func (x *TaskMessage) GetRetention() int64 + func (x *TaskMessage) GetRetried() int32 + func (x *TaskMessage) GetRetry() int32 + func (x *TaskMessage) GetTimeout() int64 + func (x *TaskMessage) GetType() string + func (x *TaskMessage) GetUniqueKey() string + func (x *TaskMessage) ProtoReflect() protoreflect.Message + func (x *TaskMessage) Reset() + func (x *TaskMessage) String() string + type WorkerInfo struct + Deadline *timestamppb.Timestamp + Host string + Pid int32 + Queue string + ServerId string + StartTime *timestamppb.Timestamp + TaskId string + TaskPayload []byte + TaskType string + func (*WorkerInfo) Descriptor() ([]byte, []int) + func (*WorkerInfo) ProtoMessage() + func (x *WorkerInfo) GetDeadline() *timestamppb.Timestamp + func (x *WorkerInfo) GetHost() string + func (x *WorkerInfo) GetPid() int32 + func (x *WorkerInfo) GetQueue() string + func (x *WorkerInfo) GetServerId() string + func (x *WorkerInfo) GetStartTime() *timestamppb.Timestamp + func (x *WorkerInfo) GetTaskId() string + func (x *WorkerInfo) GetTaskPayload() []byte + func (x *WorkerInfo) GetTaskType() string + func (x *WorkerInfo) ProtoReflect() protoreflect.Message + func (x *WorkerInfo) Reset() + func (x *WorkerInfo) String() string
Go to main page