Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto

package

Go to main page

Versions in this module

v0

v0.0.3

Apr 15, 2024

v0.0.2

Aug 29, 2023

v0.0.1

Apr 21, 2023

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