workqueue

Jan 13, 2026

Changes in this version

+ type DeadLetteredKey interface

+ GetAttempts func() int

+ GetFailedTime func() time.Time

Sep 4, 2025

Changes in this version

+ const WorkqueueService_GetKeyState_FullMethodName

+ var KeyState_Status_name = map[int32]string

+ var KeyState_Status_value = map[string]int32

+ type GetKeyStateRequest struct

+ Key string

+ func (*GetKeyStateRequest) Descriptor() ([]byte, []int)

+ func (*GetKeyStateRequest) ProtoMessage()

+ func (x *GetKeyStateRequest) GetKey() string

+ func (x *GetKeyStateRequest) ProtoReflect() protoreflect.Message

+ func (x *GetKeyStateRequest) Reset()

+ func (x *GetKeyStateRequest) String() string

type Interface

+ Get func(ctx context.Context, key string) (*KeyState, error)

+ type KeyState struct

+ Attempts int32

+ Key string

+ NotBeforeTime int64

+ Priority int64

+ QueuedTime int64

+ Status KeyState_Status

+ func (*KeyState) Descriptor() ([]byte, []int)

+ func (*KeyState) ProtoMessage()

+ func (x *KeyState) GetAttempts() int32

+ func (x *KeyState) GetKey() string

+ func (x *KeyState) GetNotBeforeTime() int64

+ func (x *KeyState) GetPriority() int64

+ func (x *KeyState) GetQueuedTime() int64

+ func (x *KeyState) GetStatus() KeyState_Status

+ func (x *KeyState) ProtoReflect() protoreflect.Message

+ func (x *KeyState) Reset()

+ func (x *KeyState) String() string

+ type KeyState_Status int32

+ const KeyState_DEAD_LETTER

+ const KeyState_IN_PROGRESS

+ const KeyState_QUEUED

+ const KeyState_UNKNOWN

+ func (KeyState_Status) Descriptor() protoreflect.EnumDescriptor

+ func (KeyState_Status) EnumDescriptor() ([]byte, []int)

+ func (KeyState_Status) Type() protoreflect.EnumType

+ func (x KeyState_Status) Enum() *KeyState_Status

+ func (x KeyState_Status) Number() protoreflect.EnumNumber

+ func (x KeyState_Status) String() string

type UnimplementedWorkqueueServiceServer

+ func (UnimplementedWorkqueueServiceServer) GetKeyState(context.Context, *GetKeyStateRequest) (*KeyState, error)

type WorkqueueServiceClient

+ GetKeyState func(ctx context.Context, in *GetKeyStateRequest, opts ...grpc.CallOption) (*KeyState, error)

type WorkqueueServiceServer

+ GetKeyState func(context.Context, *GetKeyStateRequest) (*KeyState, error)

Jul 17, 2025

Changes in this version

type ProcessRequest

+ func (x *ProcessRequest) LogAttrs() []any

Jun 25, 2025

Changes in this version

+ func GetRequeueDelay(err error) (time.Duration, bool)

+ func RequeueAfter(delay time.Duration) error

type InProgressKey

+ RequeueWithOptions func(context.Context, Options) error

type Options

+ Delay time.Duration

type ProcessResponse

+ RequeueAfterSeconds int64

+ func (x *ProcessResponse) GetRequeueAfterSeconds() int64

Jun 6, 2025

Changes in this version

+ const WorkqueueService_Process_FullMethodName

+ var BackoffPeriod = 30 * time.Second

+ var File_workqueue_proto protoreflect.FileDescriptor

+ var MaximumBackoffPeriod = 10 * time.Minute

+ var WorkqueueService_ServiceDesc = grpc.ServiceDesc

+ func NonRetriableError(err error, reason string) error

+ func RegisterWorkqueueServiceServer(s grpc.ServiceRegistrar, srv WorkqueueServiceServer)

+ type Client interface

+ Close func() error

+ func NewWorkqueueClient(ctx context.Context, endpoint string, addlOpts ...grpc.DialOption) (Client, error)

+ type InProgressKey interface

+ Requeue func(context.Context) error

+ type Interface interface

+ Enumerate func(ctx context.Context) ([]ObservedInProgressKey, []QueuedKey, error)

+ Queue func(ctx context.Context, key string, opts Options) error

+ type Key interface

+ Name func() string

+ Priority func() int64

+ type NoRetryDetails struct

+ Message string

+ func GetNonRetriableDetails(err error) *NoRetryDetails

+ func (*NoRetryDetails) Descriptor() ([]byte, []int)

+ func (*NoRetryDetails) ProtoMessage()

+ func (x *NoRetryDetails) GetMessage() string

+ func (x *NoRetryDetails) ProtoReflect() protoreflect.Message

+ func (x *NoRetryDetails) Reset()

+ func (x *NoRetryDetails) String() string

+ type ObservedInProgressKey interface

+ IsOrphaned func() bool

+ type Options struct

+ NotBefore time.Time

+ Priority int64

+ type OwnedInProgressKey interface

+ Complete func(context.Context) error

+ Context func() context.Context

+ Deadletter func(context.Context) error

+ GetAttempts func() int

+ type ProcessRequest struct

+ DelaySeconds int64

+ Key string

+ Priority int64

+ func (*ProcessRequest) Descriptor() ([]byte, []int)

+ func (*ProcessRequest) ProtoMessage()

+ func (x *ProcessRequest) GetDelaySeconds() int64

+ func (x *ProcessRequest) GetKey() string

+ func (x *ProcessRequest) GetPriority() int64

+ func (x *ProcessRequest) ProtoReflect() protoreflect.Message

+ func (x *ProcessRequest) Reset()

+ func (x *ProcessRequest) String() string

+ type ProcessResponse struct

+ func (*ProcessResponse) Descriptor() ([]byte, []int)

+ func (*ProcessResponse) ProtoMessage()

+ func (x *ProcessResponse) ProtoReflect() protoreflect.Message

+ func (x *ProcessResponse) Reset()

+ func (x *ProcessResponse) String() string

+ type QueuedKey interface

+ Start func(context.Context) (OwnedInProgressKey, error)

+ type UnimplementedWorkqueueServiceServer struct

+ func (UnimplementedWorkqueueServiceServer) Process(context.Context, *ProcessRequest) (*ProcessResponse, error)

+ type UnsafeWorkqueueServiceServer interface

+ type WorkqueueServiceClient interface

+ Process func(ctx context.Context, in *ProcessRequest, opts ...grpc.CallOption) (*ProcessResponse, error)

+ func NewWorkqueueServiceClient(cc grpc.ClientConnInterface) WorkqueueServiceClient

+ type WorkqueueServiceServer interface

+ Process func(context.Context, *ProcessRequest) (*ProcessResponse, error)