Versions in this module Expand all Collapse all v0 v0.4.4 Mar 11, 2022 v0.4.3 Mar 11, 2022 v0.4.2 Nov 6, 2021 v0.4.1 Aug 3, 2021 v0.4.0 Jun 15, 2021 Changes in this version type Queue + Blocked bool + Paused bool + Unpaused bool + func (x *Queue) GetBlocked() bool + func (x *Queue) GetPaused() bool + func (x *Queue) GetUnpaused() bool v0.3.0 May 17, 2021 v0.2.2 Mar 9, 2021 Changes in this version + const StatusCancelled + const StatusComplete + const StatusDead + const StatusFailed + const StatusInvalid + const StatusQueued + const StatusRunning + const StatusUnknown + var File_job_v1_ack_proto protoreflect.FileDescriptor + var File_job_v1_backoff_proto protoreflect.FileDescriptor + var File_job_v1_checkin_proto protoreflect.FileDescriptor + var File_job_v1_data_proto protoreflect.FileDescriptor + var File_job_v1_job_proto protoreflect.FileDescriptor + var File_job_v1_queue_proto protoreflect.FileDescriptor + var File_job_v1_result_proto protoreflect.FileDescriptor + var File_job_v1_status_proto protoreflect.FileDescriptor + var Status_name = map[int32]string + var Status_value = map[string]int32 + func AckFromProto(msg *Ack) *resource.Ack + func HasStatus(job *Job, statuses []Status) bool + func IsComplete(status Status) bool + func JobStatusFromProto(status Status) *resource.Status + func JobStatusesFromProto(statuses []Status) []*resource.Status + func MarshalJob(jb *resource.Job) ([]byte, error) + func MarshalQueue(q *resource.Queue) ([]byte, error) + func NewID() string + func NewJobFromProto(msg *Job, claims label.Claims) *resource.Job + func NewJobsFromProto(msgs []*Job) ([]*resource.Job, error) + func NewQueueFromProto(msg *Queue) *resource.Queue + func NewQueuesFromProto(msgs []*Queue) []*resource.Queue + func ParseSchema(q *Queue) (*schema.Schema, error) + func UnmarshalJob(b []byte, qmsg *Job) (*resource.Job, error) + func UnmarshalQueue(b []byte, qmsg *Queue) (*resource.Queue, error) + type Ack struct + Data *_struct.Value + Error string + Id string + Status Status + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (x *Ack) GetData() *_struct.Value + func (x *Ack) GetError() string + func (x *Ack) GetId() string + func (x *Ack) GetStatus() Status + func (x *Ack) ProtoReflect() protoreflect.Message + func (x *Ack) Reset() + func (x *Ack) String() string + type Acks struct + Acks []*Ack + func (*Acks) Descriptor() ([]byte, []int) + func (*Acks) ProtoMessage() + func (x *Acks) GetAcks() []*Ack + func (x *Acks) ProtoReflect() protoreflect.Message + func (x *Acks) Reset() + func (x *Acks) String() string + type Backoff struct + Factor float32 + Initial *duration.Duration + Max *duration.Duration + func (*Backoff) Descriptor() ([]byte, []int) + func (*Backoff) ProtoMessage() + func (x *Backoff) GetFactor() float32 + func (x *Backoff) GetInitial() *duration.Duration + func (x *Backoff) GetMax() *duration.Duration + func (x *Backoff) ProtoReflect() protoreflect.Message + func (x *Backoff) Reset() + func (x *Backoff) String() string + type Checkin struct + CreatedAt *timestamp.Timestamp + Data *_struct.Value + func (*Checkin) Descriptor() ([]byte, []int) + func (*Checkin) ProtoMessage() + func (x *Checkin) GetCreatedAt() *timestamp.Timestamp + func (x *Checkin) GetData() *_struct.Value + func (x *Checkin) ProtoReflect() protoreflect.Message + func (x *Checkin) Reset() + func (x *Checkin) String() string + type Data struct + Claims []string + Data *_struct.Value + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (x *Data) GetClaims() []string + func (x *Data) GetData() *_struct.Value + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type Job struct + Args []*_struct.Value + Attempt int32 + Checkins []*Checkin + Data *Data + Duration *duration.Duration + EnqueuedAt *timestamp.Timestamp + Id string + Name string + QueueV int32 + Results []*Result + Status Status + V int32 + func NewJobFromResource(jb *resource.Job) (*Job, error) + func NewJobsFromResources(jbs []*resource.Job) ([]*Job, error) + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetArgs() []*_struct.Value + func (x *Job) GetAttempt() int32 + func (x *Job) GetCheckins() []*Checkin + func (x *Job) GetData() *Data + func (x *Job) GetDuration() *duration.Duration + func (x *Job) GetEnqueuedAt() *timestamp.Timestamp + func (x *Job) GetId() string + func (x *Job) GetName() string + func (x *Job) GetQueueV() int32 + func (x *Job) GetResults() []*Result + func (x *Job) GetStatus() Status + func (x *Job) GetV() int32 + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobListParams struct + CreatedSince *timestamp.Timestamp + CreatedUntil *timestamp.Timestamp + Names []string + Selectors []string + Statuses []Status + func (*JobListParams) Descriptor() ([]byte, []int) + func (*JobListParams) ProtoMessage() + func (x *JobListParams) GetCreatedSince() *timestamp.Timestamp + func (x *JobListParams) GetCreatedUntil() *timestamp.Timestamp + func (x *JobListParams) GetNames() []string + func (x *JobListParams) GetSelectors() []string + func (x *JobListParams) GetStatuses() []Status + func (x *JobListParams) ProtoReflect() protoreflect.Message + func (x *JobListParams) Reset() + func (x *JobListParams) String() string + type Jobs struct + Jobs []*Job + func (*Jobs) Descriptor() ([]byte, []int) + func (*Jobs) ProtoMessage() + func (x *Jobs) GetJobs() []*Job + func (x *Jobs) ProtoReflect() protoreflect.Message + func (x *Jobs) Reset() + func (x *Jobs) String() string + type Queue struct + BackoffFactor float32 + BackoffInitialDuration *duration.Duration + BackoffMaxDuration *duration.Duration + CheckinDuration *duration.Duration + ClaimDuration *duration.Duration + CreatedAt *timestamp.Timestamp + DeletedAt *timestamp.Timestamp + Duration *duration.Duration + Id string + Labels map[string]string + Retries int32 + Schema []byte + Unique bool + UpdatedAt *timestamp.Timestamp + V int32 + func NewQueueFromResource(res *resource.Queue) *Queue + func NewQueuesFromResources(resources []*resource.Queue) []*Queue + func (*Queue) Descriptor() ([]byte, []int) + func (*Queue) ProtoMessage() + func (x *Queue) GetBackoffFactor() float32 + func (x *Queue) GetBackoffInitialDuration() *duration.Duration + func (x *Queue) GetBackoffMaxDuration() *duration.Duration + func (x *Queue) GetCheckinDuration() *duration.Duration + func (x *Queue) GetClaimDuration() *duration.Duration + func (x *Queue) GetCreatedAt() *timestamp.Timestamp + func (x *Queue) GetDeletedAt() *timestamp.Timestamp + func (x *Queue) GetDuration() *duration.Duration + func (x *Queue) GetId() string + func (x *Queue) GetLabels() map[string]string + func (x *Queue) GetRetries() int32 + func (x *Queue) GetSchema() []byte + func (x *Queue) GetUnique() bool + func (x *Queue) GetUpdatedAt() *timestamp.Timestamp + func (x *Queue) GetV() int32 + func (x *Queue) ProtoReflect() protoreflect.Message + func (x *Queue) Reset() + func (x *Queue) String() string + type QueueListParams struct + Names []string + Selectors []string + func (*QueueListParams) Descriptor() ([]byte, []int) + func (*QueueListParams) ProtoMessage() + func (x *QueueListParams) GetNames() []string + func (x *QueueListParams) GetSelectors() []string + func (x *QueueListParams) ProtoReflect() protoreflect.Message + func (x *QueueListParams) Reset() + func (x *QueueListParams) String() string + type Queues struct + Queues []*Queue + func (*Queues) Descriptor() ([]byte, []int) + func (*Queues) ProtoMessage() + func (x *Queues) GetQueues() []*Queue + func (x *Queues) ProtoReflect() protoreflect.Message + func (x *Queues) Reset() + func (x *Queues) String() string + type Result struct + Attempt int32 + CompletedAt *timestamp.Timestamp + Data *_struct.Value + StartedAt *timestamp.Timestamp + Status Status + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (x *Result) GetAttempt() int32 + func (x *Result) GetCompletedAt() *timestamp.Timestamp + func (x *Result) GetData() *_struct.Value + func (x *Result) GetStartedAt() *timestamp.Timestamp + func (x *Result) GetStatus() Status + func (x *Result) ProtoReflect() protoreflect.Message + func (x *Result) Reset() + func (x *Result) String() string + type Status int32 + const Status_STATUS_CANCELLED + const Status_STATUS_COMPLETE + const Status_STATUS_DEAD + const Status_STATUS_FAILED + const Status_STATUS_INVALID + const Status_STATUS_QUEUED + const Status_STATUS_RUNNING + const Status_STATUS_UNSPECIFIED + func JobStatusToProto(status *resource.Status) Status + func (Status) Descriptor() protoreflect.EnumDescriptor + func (Status) EnumDescriptor() ([]byte, []int) + func (Status) Type() protoreflect.EnumType + func (x Status) Enum() *Status + func (x Status) Number() protoreflect.EnumNumber + func (x Status) String() string v0.2.1 Mar 8, 2021 v0.2.0 Mar 7, 2021 v0.1.11 Mar 7, 2021
Go to main page