workerpb

package

Go to main page

Versions in this module

v0

v0.2.4

Feb 13, 2026

v0.2.3

Feb 13, 2026

v0.2.2

Feb 10, 2026

Changes in this version

+ const AdminService_CreateSchedule_FullMethodName

+ const AdminService_DeleteJob_FullMethodName

+ const AdminService_DeleteSchedule_FullMethodName

+ const AdminService_GetDLQEntry_FullMethodName

+ const AdminService_GetHealth_FullMethodName

+ const AdminService_GetJob_FullMethodName

+ const AdminService_GetOverview_FullMethodName

+ const AdminService_GetQueue_FullMethodName

+ const AdminService_ListAuditEvents_FullMethodName

+ const AdminService_ListDLQ_FullMethodName

+ const AdminService_ListJobEvents_FullMethodName

+ const AdminService_ListJobs_FullMethodName

+ const AdminService_ListQueues_FullMethodName

+ const AdminService_ListScheduleEvents_FullMethodName

+ const AdminService_ListScheduleFactories_FullMethodName

+ const AdminService_ListSchedules_FullMethodName

+ const AdminService_PauseDequeue_FullMethodName

+ const AdminService_PauseQueue_FullMethodName

+ const AdminService_PauseSchedule_FullMethodName

+ const AdminService_PauseSchedules_FullMethodName

+ const AdminService_ReplayDLQByID_FullMethodName

+ const AdminService_ReplayDLQ_FullMethodName

+ const AdminService_ResetQueueWeight_FullMethodName

+ const AdminService_ResumeDequeue_FullMethodName

+ const AdminService_RunJob_FullMethodName

+ const AdminService_RunSchedule_FullMethodName

+ const AdminService_UpdateQueueWeight_FullMethodName

+ const AdminService_UpsertJob_FullMethodName

+ var AdminService_ServiceDesc = grpc.ServiceDesc

+ var File_worker_v1_admin_proto protoreflect.FileDescriptor

+ func RegisterAdminServiceServer(s grpc.ServiceRegistrar, srv AdminServiceServer)

+ type AdminActionCounters struct

+ Pause int64

+ Replay int64

+ Resume int64

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

+ func (*AdminActionCounters) ProtoMessage()

+ func (x *AdminActionCounters) GetPause() int64

+ func (x *AdminActionCounters) GetReplay() int64

+ func (x *AdminActionCounters) GetResume() int64

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

+ func (x *AdminActionCounters) Reset()

+ func (x *AdminActionCounters) String() string

+ type AdminServiceClient interface

+ CreateSchedule func(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreateScheduleResponse, error)

+ DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)

+ DeleteSchedule func(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error)

+ GetDLQEntry func(ctx context.Context, in *GetDLQEntryRequest, opts ...grpc.CallOption) (*GetDLQEntryResponse, error)

+ GetHealth func(ctx context.Context, in *GetHealthRequest, opts ...grpc.CallOption) (*GetHealthResponse, error)

+ GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)

+ GetOverview func(ctx context.Context, in *GetOverviewRequest, opts ...grpc.CallOption) (*GetOverviewResponse, error)

+ GetQueue func(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*GetQueueResponse, error)

+ ListAuditEvents func(ctx context.Context, in *ListAuditEventsRequest, opts ...grpc.CallOption) (*ListAuditEventsResponse, error)

+ ListDLQ func(ctx context.Context, in *ListDLQRequest, opts ...grpc.CallOption) (*ListDLQResponse, error)

+ ListJobEvents func(ctx context.Context, in *ListJobEventsRequest, opts ...grpc.CallOption) (*ListJobEventsResponse, error)

+ ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)

+ ListQueues func(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error)

+ ListScheduleEvents func(ctx context.Context, in *ListScheduleEventsRequest, opts ...grpc.CallOption) (*ListScheduleEventsResponse, error)

+ ListScheduleFactories func(ctx context.Context, in *ListScheduleFactoriesRequest, opts ...grpc.CallOption) (*ListScheduleFactoriesResponse, error)

+ ListSchedules func(ctx context.Context, in *ListSchedulesRequest, opts ...grpc.CallOption) (*ListSchedulesResponse, error)

+ PauseDequeue func(ctx context.Context, in *PauseDequeueRequest, opts ...grpc.CallOption) (*PauseDequeueResponse, error)

+ PauseQueue func(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*PauseQueueResponse, error)

+ PauseSchedule func(ctx context.Context, in *PauseScheduleRequest, opts ...grpc.CallOption) (*PauseScheduleResponse, error)

+ PauseSchedules func(ctx context.Context, in *PauseSchedulesRequest, opts ...grpc.CallOption) (*PauseSchedulesResponse, error)

+ ReplayDLQ func(ctx context.Context, in *ReplayDLQRequest, opts ...grpc.CallOption) (*ReplayDLQResponse, error)

+ ReplayDLQByID func(ctx context.Context, in *ReplayDLQByIDRequest, opts ...grpc.CallOption) (*ReplayDLQByIDResponse, error)

+ ResetQueueWeight func(ctx context.Context, in *ResetQueueWeightRequest, opts ...grpc.CallOption) (*ResetQueueWeightResponse, error)

+ ResumeDequeue func(ctx context.Context, in *ResumeDequeueRequest, opts ...grpc.CallOption) (*ResumeDequeueResponse, error)

+ RunJob func(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*RunJobResponse, error)

+ RunSchedule func(ctx context.Context, in *RunScheduleRequest, opts ...grpc.CallOption) (*RunScheduleResponse, error)

+ UpdateQueueWeight func(ctx context.Context, in *UpdateQueueWeightRequest, opts ...grpc.CallOption) (*UpdateQueueWeightResponse, error)

+ UpsertJob func(ctx context.Context, in *UpsertJobRequest, opts ...grpc.CallOption) (*UpsertJobResponse, error)

+ func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient

+ type AdminServiceServer interface

+ CreateSchedule func(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)

+ DeleteJob func(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)

+ DeleteSchedule func(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

+ GetDLQEntry func(context.Context, *GetDLQEntryRequest) (*GetDLQEntryResponse, error)

+ GetHealth func(context.Context, *GetHealthRequest) (*GetHealthResponse, error)

+ GetJob func(context.Context, *GetJobRequest) (*GetJobResponse, error)

+ GetOverview func(context.Context, *GetOverviewRequest) (*GetOverviewResponse, error)

+ GetQueue func(context.Context, *GetQueueRequest) (*GetQueueResponse, error)

+ ListAuditEvents func(context.Context, *ListAuditEventsRequest) (*ListAuditEventsResponse, error)

+ ListDLQ func(context.Context, *ListDLQRequest) (*ListDLQResponse, error)

+ ListJobEvents func(context.Context, *ListJobEventsRequest) (*ListJobEventsResponse, error)

+ ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

+ ListQueues func(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)

+ ListScheduleEvents func(context.Context, *ListScheduleEventsRequest) (*ListScheduleEventsResponse, error)

+ ListScheduleFactories func(context.Context, *ListScheduleFactoriesRequest) (*ListScheduleFactoriesResponse, error)

+ ListSchedules func(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)

+ PauseDequeue func(context.Context, *PauseDequeueRequest) (*PauseDequeueResponse, error)

+ PauseQueue func(context.Context, *PauseQueueRequest) (*PauseQueueResponse, error)

+ PauseSchedule func(context.Context, *PauseScheduleRequest) (*PauseScheduleResponse, error)

+ PauseSchedules func(context.Context, *PauseSchedulesRequest) (*PauseSchedulesResponse, error)

+ ReplayDLQ func(context.Context, *ReplayDLQRequest) (*ReplayDLQResponse, error)

+ ReplayDLQByID func(context.Context, *ReplayDLQByIDRequest) (*ReplayDLQByIDResponse, error)

+ ResetQueueWeight func(context.Context, *ResetQueueWeightRequest) (*ResetQueueWeightResponse, error)

+ ResumeDequeue func(context.Context, *ResumeDequeueRequest) (*ResumeDequeueResponse, error)

+ RunJob func(context.Context, *RunJobRequest) (*RunJobResponse, error)

+ RunSchedule func(context.Context, *RunScheduleRequest) (*RunScheduleResponse, error)

+ UpdateQueueWeight func(context.Context, *UpdateQueueWeightRequest) (*UpdateQueueWeightResponse, error)

+ UpsertJob func(context.Context, *UpsertJobRequest) (*UpsertJobResponse, error)

+ type AuditEvent struct

+ Action string

+ Actor string

+ AtMs int64

+ Detail string

+ Metadata map[string]string

+ PayloadHash string

+ RequestId string

+ Status string

+ Target string

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

+ func (*AuditEvent) ProtoMessage()

+ func (x *AuditEvent) GetAction() string

+ func (x *AuditEvent) GetActor() string

+ func (x *AuditEvent) GetAtMs() int64

+ func (x *AuditEvent) GetDetail() string

+ func (x *AuditEvent) GetMetadata() map[string]string

+ func (x *AuditEvent) GetPayloadHash() string

+ func (x *AuditEvent) GetRequestId() string

+ func (x *AuditEvent) GetStatus() string

+ func (x *AuditEvent) GetTarget() string

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

+ func (x *AuditEvent) Reset()

+ func (x *AuditEvent) String() string

+ type CoordinationStatus struct

+ GlobalRateLimit string

+ LeaderLock string

+ Lease string

+ Paused bool

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

+ func (*CoordinationStatus) ProtoMessage()

+ func (x *CoordinationStatus) GetGlobalRateLimit() string

+ func (x *CoordinationStatus) GetLeaderLock() string

+ func (x *CoordinationStatus) GetLease() string

+ func (x *CoordinationStatus) GetPaused() bool

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

+ func (x *CoordinationStatus) Reset()

+ func (x *CoordinationStatus) String() string

+ type CreateScheduleRequest struct

+ Durable bool

+ Name string

+ Spec string

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

+ func (*CreateScheduleRequest) ProtoMessage()

+ func (x *CreateScheduleRequest) GetDurable() bool

+ func (x *CreateScheduleRequest) GetName() string

+ func (x *CreateScheduleRequest) GetSpec() string

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

+ func (x *CreateScheduleRequest) Reset()

+ func (x *CreateScheduleRequest) String() string

+ type CreateScheduleResponse struct

+ Schedule *ScheduleEntry

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

+ func (*CreateScheduleResponse) ProtoMessage()

+ func (x *CreateScheduleResponse) GetSchedule() *ScheduleEntry

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

+ func (x *CreateScheduleResponse) Reset()

+ func (x *CreateScheduleResponse) String() string

+ type DLQEntry struct

+ AgeMs int64

+ Attempts int32

+ Handler string

+ Id string

+ Queue string

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

+ func (*DLQEntry) ProtoMessage()

+ func (x *DLQEntry) GetAgeMs() int64

+ func (x *DLQEntry) GetAttempts() int32

+ func (x *DLQEntry) GetHandler() string

+ func (x *DLQEntry) GetId() string

+ func (x *DLQEntry) GetQueue() string

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

+ func (x *DLQEntry) Reset()

+ func (x *DLQEntry) String() string

+ type DLQEntryDetail struct

+ AgeMs int64

+ Attempts int32

+ FailedAtMs int64

+ Handler string

+ Id string

+ LastError string

+ Metadata map[string]string

+ PayloadSize int64

+ Queue string

+ UpdatedAtMs int64

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

+ func (*DLQEntryDetail) ProtoMessage()

+ func (x *DLQEntryDetail) GetAgeMs() int64

+ func (x *DLQEntryDetail) GetAttempts() int32

+ func (x *DLQEntryDetail) GetFailedAtMs() int64

+ func (x *DLQEntryDetail) GetHandler() string

+ func (x *DLQEntryDetail) GetId() string

+ func (x *DLQEntryDetail) GetLastError() string

+ func (x *DLQEntryDetail) GetMetadata() map[string]string

+ func (x *DLQEntryDetail) GetPayloadSize() int64

+ func (x *DLQEntryDetail) GetQueue() string

+ func (x *DLQEntryDetail) GetUpdatedAtMs() int64

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

+ func (x *DLQEntryDetail) Reset()

+ func (x *DLQEntryDetail) String() string

+ type DeleteJobRequest struct

+ Name string

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

+ func (*DeleteJobRequest) ProtoMessage()

+ func (x *DeleteJobRequest) GetName() string

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

+ func (x *DeleteJobRequest) Reset()

+ func (x *DeleteJobRequest) String() string

+ type DeleteJobResponse struct

+ Deleted bool

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

+ func (*DeleteJobResponse) ProtoMessage()

+ func (x *DeleteJobResponse) GetDeleted() bool

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

+ func (x *DeleteJobResponse) Reset()

+ func (x *DeleteJobResponse) String() string

+ type DeleteScheduleRequest struct

+ Name string

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

+ func (*DeleteScheduleRequest) ProtoMessage()

+ func (x *DeleteScheduleRequest) GetName() string

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

+ func (x *DeleteScheduleRequest) Reset()

+ func (x *DeleteScheduleRequest) String() string

+ type DeleteScheduleResponse struct

+ Deleted bool

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

+ func (*DeleteScheduleResponse) ProtoMessage()

+ func (x *DeleteScheduleResponse) GetDeleted() bool

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

+ func (x *DeleteScheduleResponse) Reset()

+ func (x *DeleteScheduleResponse) String() string

+ type GetDLQEntryRequest struct

+ Id string

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

+ func (*GetDLQEntryRequest) ProtoMessage()

+ func (x *GetDLQEntryRequest) GetId() string

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

+ func (x *GetDLQEntryRequest) Reset()

+ func (x *GetDLQEntryRequest) String() string

+ type GetDLQEntryResponse struct

+ Entry *DLQEntryDetail

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

+ func (*GetDLQEntryResponse) ProtoMessage()

+ func (x *GetDLQEntryResponse) GetEntry() *DLQEntryDetail

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

+ func (x *GetDLQEntryResponse) Reset()

+ func (x *GetDLQEntryResponse) String() string

+ type GetHealthRequest struct

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

+ func (*GetHealthRequest) ProtoMessage()

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

+ func (x *GetHealthRequest) Reset()

+ func (x *GetHealthRequest) String() string

+ type GetHealthResponse struct

+ BuildTime string

+ Commit string

+ GoVersion string

+ Status string

+ Version string

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

+ func (*GetHealthResponse) ProtoMessage()

+ func (x *GetHealthResponse) GetBuildTime() string

+ func (x *GetHealthResponse) GetCommit() string

+ func (x *GetHealthResponse) GetGoVersion() string

+ func (x *GetHealthResponse) GetStatus() string

+ func (x *GetHealthResponse) GetVersion() string

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

+ func (x *GetHealthResponse) Reset()

+ func (x *GetHealthResponse) String() string

+ type GetJobRequest struct

+ Name string

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

+ func (*GetJobRequest) ProtoMessage()

+ func (x *GetJobRequest) GetName() string

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

+ func (x *GetJobRequest) Reset()

+ func (x *GetJobRequest) String() string

+ type GetJobResponse struct

+ Job *Job

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

+ func (*GetJobResponse) ProtoMessage()

+ func (x *GetJobResponse) GetJob() *Job

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

+ func (x *GetJobResponse) Reset()

+ func (x *GetJobResponse) String() string

+ type GetOverviewRequest struct

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

+ func (*GetOverviewRequest) ProtoMessage()

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

+ func (x *GetOverviewRequest) Reset()

+ func (x *GetOverviewRequest) String() string

+ type GetOverviewResponse struct

+ Actions *AdminActionCounters

+ Coordination *CoordinationStatus

+ Stats *OverviewStats

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

+ func (*GetOverviewResponse) ProtoMessage()

+ func (x *GetOverviewResponse) GetActions() *AdminActionCounters

+ func (x *GetOverviewResponse) GetCoordination() *CoordinationStatus

+ func (x *GetOverviewResponse) GetStats() *OverviewStats

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

+ func (x *GetOverviewResponse) Reset()

+ func (x *GetOverviewResponse) String() string

+ type GetQueueRequest struct

+ Name string

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

+ func (*GetQueueRequest) ProtoMessage()

+ func (x *GetQueueRequest) GetName() string

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

+ func (x *GetQueueRequest) Reset()

+ func (x *GetQueueRequest) String() string

+ type GetQueueResponse struct

+ Queue *QueueSummary

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

+ func (*GetQueueResponse) ProtoMessage()

+ func (x *GetQueueResponse) GetQueue() *QueueSummary

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

+ func (x *GetQueueResponse) Reset()

+ func (x *GetQueueResponse) String() string

+ type Job struct

+ CreatedAtMs int64

+ Spec *JobSpec

+ UpdatedAtMs int64

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

+ func (*Job) ProtoMessage()

+ func (x *Job) GetCreatedAtMs() int64

+ func (x *Job) GetSpec() *JobSpec

+ func (x *Job) GetUpdatedAtMs() int64

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

+ func (x *Job) Reset()

+ func (x *Job) String() string

+ type JobEvent struct

+ Command string

+ Dockerfile string

+ DurationMs int64

+ Error string

+ FinishedAtMs int64

+ Metadata map[string]string

+ Name string

+ Path string

+ Queue string

+ Repo string

+ Result string

+ ScheduleName string

+ ScheduleSpec string

+ StartedAtMs int64

+ Status string

+ Tag string

+ TaskId string

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

+ func (*JobEvent) ProtoMessage()

+ func (x *JobEvent) GetCommand() string

+ func (x *JobEvent) GetDockerfile() string

+ func (x *JobEvent) GetDurationMs() int64

+ func (x *JobEvent) GetError() string

+ func (x *JobEvent) GetFinishedAtMs() int64

+ func (x *JobEvent) GetMetadata() map[string]string

+ func (x *JobEvent) GetName() string

+ func (x *JobEvent) GetPath() string

+ func (x *JobEvent) GetQueue() string

+ func (x *JobEvent) GetRepo() string

+ func (x *JobEvent) GetResult() string

+ func (x *JobEvent) GetScheduleName() string

+ func (x *JobEvent) GetScheduleSpec() string

+ func (x *JobEvent) GetStartedAtMs() int64

+ func (x *JobEvent) GetStatus() string

+ func (x *JobEvent) GetTag() string

+ func (x *JobEvent) GetTaskId() string

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

+ func (x *JobEvent) Reset()

+ func (x *JobEvent) String() string

+ type JobSpec struct

+ Command []string

+ Description string

+ Dockerfile string

+ Env []string

+ Name string

+ Path string

+ Queue string

+ Repo string

+ Retries int32

+ Source string

+ Tag string

+ TarballPath string

+ TarballSha256 string

+ TarballUrl string

+ TimeoutSeconds int32

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

+ func (*JobSpec) ProtoMessage()

+ func (x *JobSpec) GetCommand() []string

+ func (x *JobSpec) GetDescription() string

+ func (x *JobSpec) GetDockerfile() string

+ func (x *JobSpec) GetEnv() []string

+ func (x *JobSpec) GetName() string

+ func (x *JobSpec) GetPath() string

+ func (x *JobSpec) GetQueue() string

+ func (x *JobSpec) GetRepo() string

+ func (x *JobSpec) GetRetries() int32

+ func (x *JobSpec) GetSource() string

+ func (x *JobSpec) GetTag() string

+ func (x *JobSpec) GetTarballPath() string

+ func (x *JobSpec) GetTarballSha256() string

+ func (x *JobSpec) GetTarballUrl() string

+ func (x *JobSpec) GetTimeoutSeconds() int32

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

+ func (x *JobSpec) Reset()

+ func (x *JobSpec) String() string

+ type ListAuditEventsRequest struct

+ Action string

+ Limit int32

+ Target string

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

+ func (*ListAuditEventsRequest) ProtoMessage()

+ func (x *ListAuditEventsRequest) GetAction() string

+ func (x *ListAuditEventsRequest) GetLimit() int32

+ func (x *ListAuditEventsRequest) GetTarget() string

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

+ func (x *ListAuditEventsRequest) Reset()

+ func (x *ListAuditEventsRequest) String() string

+ type ListAuditEventsResponse struct

+ Events []*AuditEvent

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

+ func (*ListAuditEventsResponse) ProtoMessage()

+ func (x *ListAuditEventsResponse) GetEvents() []*AuditEvent

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

+ func (x *ListAuditEventsResponse) Reset()

+ func (x *ListAuditEventsResponse) String() string

+ type ListDLQRequest struct

+ Handler string

+ Limit int32

+ Offset int32

+ Query string

+ Queue string

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

+ func (*ListDLQRequest) ProtoMessage()

+ func (x *ListDLQRequest) GetHandler() string

+ func (x *ListDLQRequest) GetLimit() int32

+ func (x *ListDLQRequest) GetOffset() int32

+ func (x *ListDLQRequest) GetQuery() string

+ func (x *ListDLQRequest) GetQueue() string

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

+ func (x *ListDLQRequest) Reset()

+ func (x *ListDLQRequest) String() string

+ type ListDLQResponse struct

+ Entries []*DLQEntry

+ Total int64

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

+ func (*ListDLQResponse) ProtoMessage()

+ func (x *ListDLQResponse) GetEntries() []*DLQEntry

+ func (x *ListDLQResponse) GetTotal() int64

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

+ func (x *ListDLQResponse) Reset()

+ func (x *ListDLQResponse) String() string

+ type ListJobEventsRequest struct

+ Limit int32

+ Name string

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

+ func (*ListJobEventsRequest) ProtoMessage()

+ func (x *ListJobEventsRequest) GetLimit() int32

+ func (x *ListJobEventsRequest) GetName() string

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

+ func (x *ListJobEventsRequest) Reset()

+ func (x *ListJobEventsRequest) String() string

+ type ListJobEventsResponse struct

+ Events []*JobEvent

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

+ func (*ListJobEventsResponse) ProtoMessage()

+ func (x *ListJobEventsResponse) GetEvents() []*JobEvent

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

+ func (x *ListJobEventsResponse) Reset()

+ func (x *ListJobEventsResponse) String() string

+ type ListJobsRequest struct

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

+ func (*ListJobsRequest) ProtoMessage()

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

+ func (x *ListJobsRequest) Reset()

+ func (x *ListJobsRequest) String() string

+ type ListJobsResponse struct

+ Jobs []*Job

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

+ func (*ListJobsResponse) ProtoMessage()

+ func (x *ListJobsResponse) GetJobs() []*Job

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

+ func (x *ListJobsResponse) Reset()

+ func (x *ListJobsResponse) String() string

+ type ListQueuesRequest struct

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

+ func (*ListQueuesRequest) ProtoMessage()

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

+ func (x *ListQueuesRequest) Reset()

+ func (x *ListQueuesRequest) String() string

+ type ListQueuesResponse struct

+ Queues []*QueueSummary

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

+ func (*ListQueuesResponse) ProtoMessage()

+ func (x *ListQueuesResponse) GetQueues() []*QueueSummary

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

+ func (x *ListQueuesResponse) Reset()

+ func (x *ListQueuesResponse) String() string

+ type ListScheduleEventsRequest struct

+ Limit int32

+ Name string

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

+ func (*ListScheduleEventsRequest) ProtoMessage()

+ func (x *ListScheduleEventsRequest) GetLimit() int32

+ func (x *ListScheduleEventsRequest) GetName() string

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

+ func (x *ListScheduleEventsRequest) Reset()

+ func (x *ListScheduleEventsRequest) String() string

+ type ListScheduleEventsResponse struct

+ Events []*ScheduleEvent

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

+ func (*ListScheduleEventsResponse) ProtoMessage()

+ func (x *ListScheduleEventsResponse) GetEvents() []*ScheduleEvent

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

+ func (x *ListScheduleEventsResponse) Reset()

+ func (x *ListScheduleEventsResponse) String() string

+ type ListScheduleFactoriesRequest struct

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

+ func (*ListScheduleFactoriesRequest) ProtoMessage()

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

+ func (x *ListScheduleFactoriesRequest) Reset()

+ func (x *ListScheduleFactoriesRequest) String() string

+ type ListScheduleFactoriesResponse struct

+ Factories []*ScheduleFactory

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

+ func (*ListScheduleFactoriesResponse) ProtoMessage()

+ func (x *ListScheduleFactoriesResponse) GetFactories() []*ScheduleFactory

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

+ func (x *ListScheduleFactoriesResponse) Reset()

+ func (x *ListScheduleFactoriesResponse) String() string

+ type ListSchedulesRequest struct

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

+ func (*ListSchedulesRequest) ProtoMessage()

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

+ func (x *ListSchedulesRequest) Reset()

+ func (x *ListSchedulesRequest) String() string

+ type ListSchedulesResponse struct

+ Schedules []*ScheduleEntry

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

+ func (*ListSchedulesResponse) ProtoMessage()

+ func (x *ListSchedulesResponse) GetSchedules() []*ScheduleEntry

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

+ func (x *ListSchedulesResponse) Reset()

+ func (x *ListSchedulesResponse) String() string

+ type OverviewStats struct

+ ActiveWorkers int32

+ AvgLatencyMs int64

+ P95LatencyMs int64

+ QueuedTasks int64

+ Queues int32

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

+ func (*OverviewStats) ProtoMessage()

+ func (x *OverviewStats) GetActiveWorkers() int32

+ func (x *OverviewStats) GetAvgLatencyMs() int64

+ func (x *OverviewStats) GetP95LatencyMs() int64

+ func (x *OverviewStats) GetQueuedTasks() int64

+ func (x *OverviewStats) GetQueues() int32

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

+ func (x *OverviewStats) Reset()

+ func (x *OverviewStats) String() string

+ type PauseDequeueRequest struct

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

+ func (*PauseDequeueRequest) ProtoMessage()

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

+ func (x *PauseDequeueRequest) Reset()

+ func (x *PauseDequeueRequest) String() string

+ type PauseDequeueResponse struct

+ Paused bool

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

+ func (*PauseDequeueResponse) ProtoMessage()

+ func (x *PauseDequeueResponse) GetPaused() bool

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

+ func (x *PauseDequeueResponse) Reset()

+ func (x *PauseDequeueResponse) String() string

+ type PauseQueueRequest struct

+ Name string

+ Paused bool

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

+ func (*PauseQueueRequest) ProtoMessage()

+ func (x *PauseQueueRequest) GetName() string

+ func (x *PauseQueueRequest) GetPaused() bool

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

+ func (x *PauseQueueRequest) Reset()

+ func (x *PauseQueueRequest) String() string

+ type PauseQueueResponse struct

+ Queue *QueueSummary

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

+ func (*PauseQueueResponse) ProtoMessage()

+ func (x *PauseQueueResponse) GetQueue() *QueueSummary

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

+ func (x *PauseQueueResponse) Reset()

+ func (x *PauseQueueResponse) String() string

+ type PauseScheduleRequest struct

+ Name string

+ Paused bool

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

+ func (*PauseScheduleRequest) ProtoMessage()

+ func (x *PauseScheduleRequest) GetName() string

+ func (x *PauseScheduleRequest) GetPaused() bool

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

+ func (x *PauseScheduleRequest) Reset()

+ func (x *PauseScheduleRequest) String() string

+ type PauseScheduleResponse struct

+ Schedule *ScheduleEntry

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

+ func (*PauseScheduleResponse) ProtoMessage()

+ func (x *PauseScheduleResponse) GetSchedule() *ScheduleEntry

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

+ func (x *PauseScheduleResponse) Reset()

+ func (x *PauseScheduleResponse) String() string

+ type PauseSchedulesRequest struct

+ Paused bool

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

+ func (*PauseSchedulesRequest) ProtoMessage()

+ func (x *PauseSchedulesRequest) GetPaused() bool

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

+ func (x *PauseSchedulesRequest) Reset()

+ func (x *PauseSchedulesRequest) String() string

+ type PauseSchedulesResponse struct

+ Paused bool

+ Updated int32

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

+ func (*PauseSchedulesResponse) ProtoMessage()

+ func (x *PauseSchedulesResponse) GetPaused() bool

+ func (x *PauseSchedulesResponse) GetUpdated() int32

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

+ func (x *PauseSchedulesResponse) Reset()

+ func (x *PauseSchedulesResponse) String() string

+ type QueueSummary struct

+ Dead int64

+ Name string

+ Paused bool

+ Processing int64

+ Ready int64

+ Weight int32

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

+ func (*QueueSummary) ProtoMessage()

+ func (x *QueueSummary) GetDead() int64

+ func (x *QueueSummary) GetName() string

+ func (x *QueueSummary) GetPaused() bool

+ func (x *QueueSummary) GetProcessing() int64

+ func (x *QueueSummary) GetReady() int64

+ func (x *QueueSummary) GetWeight() int32

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

+ func (x *QueueSummary) Reset()

+ func (x *QueueSummary) String() string

+ type ReplayDLQByIDRequest struct

+ Ids []string

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

+ func (*ReplayDLQByIDRequest) ProtoMessage()

+ func (x *ReplayDLQByIDRequest) GetIds() []string

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

+ func (x *ReplayDLQByIDRequest) Reset()

+ func (x *ReplayDLQByIDRequest) String() string

+ type ReplayDLQByIDResponse struct

+ Moved int32

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

+ func (*ReplayDLQByIDResponse) ProtoMessage()

+ func (x *ReplayDLQByIDResponse) GetMoved() int32

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

+ func (x *ReplayDLQByIDResponse) Reset()

+ func (x *ReplayDLQByIDResponse) String() string

+ type ReplayDLQRequest struct

+ Limit int32

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

+ func (*ReplayDLQRequest) ProtoMessage()

+ func (x *ReplayDLQRequest) GetLimit() int32

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

+ func (x *ReplayDLQRequest) Reset()

+ func (x *ReplayDLQRequest) String() string

+ type ReplayDLQResponse struct

+ Moved int32

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

+ func (*ReplayDLQResponse) ProtoMessage()

+ func (x *ReplayDLQResponse) GetMoved() int32

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

+ func (x *ReplayDLQResponse) Reset()

+ func (x *ReplayDLQResponse) String() string

+ type ResetQueueWeightRequest struct

+ Name string

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

+ func (*ResetQueueWeightRequest) ProtoMessage()

+ func (x *ResetQueueWeightRequest) GetName() string

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

+ func (x *ResetQueueWeightRequest) Reset()

+ func (x *ResetQueueWeightRequest) String() string

+ type ResetQueueWeightResponse struct

+ Queue *QueueSummary

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

+ func (*ResetQueueWeightResponse) ProtoMessage()

+ func (x *ResetQueueWeightResponse) GetQueue() *QueueSummary

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

+ func (x *ResetQueueWeightResponse) Reset()

+ func (x *ResetQueueWeightResponse) String() string

+ type ResumeDequeueRequest struct

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

+ func (*ResumeDequeueRequest) ProtoMessage()

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

+ func (x *ResumeDequeueRequest) Reset()

+ func (x *ResumeDequeueRequest) String() string

+ type ResumeDequeueResponse struct

+ Paused bool

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

+ func (*ResumeDequeueResponse) ProtoMessage()

+ func (x *ResumeDequeueResponse) GetPaused() bool

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

+ func (x *ResumeDequeueResponse) Reset()

+ func (x *ResumeDequeueResponse) String() string

+ type RunJobRequest struct

+ Name string

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

+ func (*RunJobRequest) ProtoMessage()

+ func (x *RunJobRequest) GetName() string

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

+ func (x *RunJobRequest) Reset()

+ func (x *RunJobRequest) String() string

+ type RunJobResponse struct

+ TaskId string

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

+ func (*RunJobResponse) ProtoMessage()

+ func (x *RunJobResponse) GetTaskId() string

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

+ func (x *RunJobResponse) Reset()

+ func (x *RunJobResponse) String() string

+ type RunScheduleRequest struct

+ Name string

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

+ func (*RunScheduleRequest) ProtoMessage()

+ func (x *RunScheduleRequest) GetName() string

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

+ func (x *RunScheduleRequest) Reset()

+ func (x *RunScheduleRequest) String() string

+ type RunScheduleResponse struct

+ TaskId string

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

+ func (*RunScheduleResponse) ProtoMessage()

+ func (x *RunScheduleResponse) GetTaskId() string

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

+ func (x *RunScheduleResponse) Reset()

+ func (x *RunScheduleResponse) String() string

+ type ScheduleEntry struct

+ Durable bool

+ LastRunMs int64

+ Name string

+ NextRunMs int64

+ Paused bool

+ Spec string

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

+ func (*ScheduleEntry) ProtoMessage()

+ func (x *ScheduleEntry) GetDurable() bool

+ func (x *ScheduleEntry) GetLastRunMs() int64

+ func (x *ScheduleEntry) GetName() string

+ func (x *ScheduleEntry) GetNextRunMs() int64

+ func (x *ScheduleEntry) GetPaused() bool

+ func (x *ScheduleEntry) GetSpec() string

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

+ func (x *ScheduleEntry) Reset()

+ func (x *ScheduleEntry) String() string

+ type ScheduleEvent struct

+ Durable bool

+ DurationMs int64

+ Error string

+ FinishedAtMs int64

+ Metadata map[string]string

+ Name string

+ Queue string

+ Result string

+ Spec string

+ StartedAtMs int64

+ Status string

+ TaskId string

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

+ func (*ScheduleEvent) ProtoMessage()

+ func (x *ScheduleEvent) GetDurable() bool

+ func (x *ScheduleEvent) GetDurationMs() int64

+ func (x *ScheduleEvent) GetError() string

+ func (x *ScheduleEvent) GetFinishedAtMs() int64

+ func (x *ScheduleEvent) GetMetadata() map[string]string

+ func (x *ScheduleEvent) GetName() string

+ func (x *ScheduleEvent) GetQueue() string

+ func (x *ScheduleEvent) GetResult() string

+ func (x *ScheduleEvent) GetSpec() string

+ func (x *ScheduleEvent) GetStartedAtMs() int64

+ func (x *ScheduleEvent) GetStatus() string

+ func (x *ScheduleEvent) GetTaskId() string

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

+ func (x *ScheduleEvent) Reset()

+ func (x *ScheduleEvent) String() string

+ type ScheduleFactory struct

+ Durable bool

+ Name string

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

+ func (*ScheduleFactory) ProtoMessage()

+ func (x *ScheduleFactory) GetDurable() bool

+ func (x *ScheduleFactory) GetName() string

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

+ func (x *ScheduleFactory) Reset()

+ func (x *ScheduleFactory) String() string

+ type UnimplementedAdminServiceServer struct

+ func (UnimplementedAdminServiceServer) CreateSchedule(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)

+ func (UnimplementedAdminServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)

+ func (UnimplementedAdminServiceServer) DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

+ func (UnimplementedAdminServiceServer) GetDLQEntry(context.Context, *GetDLQEntryRequest) (*GetDLQEntryResponse, error)

+ func (UnimplementedAdminServiceServer) GetHealth(context.Context, *GetHealthRequest) (*GetHealthResponse, error)

+ func (UnimplementedAdminServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)

+ func (UnimplementedAdminServiceServer) GetOverview(context.Context, *GetOverviewRequest) (*GetOverviewResponse, error)

+ func (UnimplementedAdminServiceServer) GetQueue(context.Context, *GetQueueRequest) (*GetQueueResponse, error)

+ func (UnimplementedAdminServiceServer) ListAuditEvents(context.Context, *ListAuditEventsRequest) (*ListAuditEventsResponse, error)

+ func (UnimplementedAdminServiceServer) ListDLQ(context.Context, *ListDLQRequest) (*ListDLQResponse, error)

+ func (UnimplementedAdminServiceServer) ListJobEvents(context.Context, *ListJobEventsRequest) (*ListJobEventsResponse, error)

+ func (UnimplementedAdminServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

+ func (UnimplementedAdminServiceServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)

+ func (UnimplementedAdminServiceServer) ListScheduleEvents(context.Context, *ListScheduleEventsRequest) (*ListScheduleEventsResponse, error)

+ func (UnimplementedAdminServiceServer) ListScheduleFactories(context.Context, *ListScheduleFactoriesRequest) (*ListScheduleFactoriesResponse, error)

+ func (UnimplementedAdminServiceServer) ListSchedules(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)

+ func (UnimplementedAdminServiceServer) PauseDequeue(context.Context, *PauseDequeueRequest) (*PauseDequeueResponse, error)

+ func (UnimplementedAdminServiceServer) PauseQueue(context.Context, *PauseQueueRequest) (*PauseQueueResponse, error)

+ func (UnimplementedAdminServiceServer) PauseSchedule(context.Context, *PauseScheduleRequest) (*PauseScheduleResponse, error)

+ func (UnimplementedAdminServiceServer) PauseSchedules(context.Context, *PauseSchedulesRequest) (*PauseSchedulesResponse, error)

+ func (UnimplementedAdminServiceServer) ReplayDLQ(context.Context, *ReplayDLQRequest) (*ReplayDLQResponse, error)

+ func (UnimplementedAdminServiceServer) ReplayDLQByID(context.Context, *ReplayDLQByIDRequest) (*ReplayDLQByIDResponse, error)

+ func (UnimplementedAdminServiceServer) ResetQueueWeight(context.Context, *ResetQueueWeightRequest) (*ResetQueueWeightResponse, error)

+ func (UnimplementedAdminServiceServer) ResumeDequeue(context.Context, *ResumeDequeueRequest) (*ResumeDequeueResponse, error)

+ func (UnimplementedAdminServiceServer) RunJob(context.Context, *RunJobRequest) (*RunJobResponse, error)

+ func (UnimplementedAdminServiceServer) RunSchedule(context.Context, *RunScheduleRequest) (*RunScheduleResponse, error)

+ func (UnimplementedAdminServiceServer) UpdateQueueWeight(context.Context, *UpdateQueueWeightRequest) (*UpdateQueueWeightResponse, error)

+ func (UnimplementedAdminServiceServer) UpsertJob(context.Context, *UpsertJobRequest) (*UpsertJobResponse, error)

+ type UnsafeAdminServiceServer interface

+ type UpdateQueueWeightRequest struct

+ Name string

+ Weight int32

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

+ func (*UpdateQueueWeightRequest) ProtoMessage()

+ func (x *UpdateQueueWeightRequest) GetName() string

+ func (x *UpdateQueueWeightRequest) GetWeight() int32

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

+ func (x *UpdateQueueWeightRequest) Reset()

+ func (x *UpdateQueueWeightRequest) String() string

+ type UpdateQueueWeightResponse struct

+ Queue *QueueSummary

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

+ func (*UpdateQueueWeightResponse) ProtoMessage()

+ func (x *UpdateQueueWeightResponse) GetQueue() *QueueSummary

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

+ func (x *UpdateQueueWeightResponse) Reset()

+ func (x *UpdateQueueWeightResponse) String() string

+ type UpsertJobRequest struct

+ Spec *JobSpec

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

+ func (*UpsertJobRequest) ProtoMessage()

+ func (x *UpsertJobRequest) GetSpec() *JobSpec

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

+ func (x *UpsertJobRequest) Reset()

+ func (x *UpsertJobRequest) String() string

+ type UpsertJobResponse struct

+ Job *Job

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

+ func (*UpsertJobResponse) ProtoMessage()

+ func (x *UpsertJobResponse) GetJob() *Job

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

+ func (x *UpsertJobResponse) Reset()

+ func (x *UpsertJobResponse) String() string

v0.2.1

Feb 3, 2026

v0.2.0

Feb 2, 2026

v0.1.9

Jan 31, 2026

v0.1.8

Jan 31, 2026

Changes in this version

+ const WorkerService_RegisterDurableTasks_FullMethodName

+ type DurableTask struct

+ Description string

+ IdempotencyKey string

+ Metadata map[string]string

+ Name string

+ Payload *anypb.Any

+ Priority int32

+ Retries int32

+ RetryDelay *durationpb.Duration

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

+ func (*DurableTask) ProtoMessage()

+ func (x *DurableTask) GetDescription() string

+ func (x *DurableTask) GetIdempotencyKey() string

+ func (x *DurableTask) GetMetadata() map[string]string

+ func (x *DurableTask) GetName() string

+ func (x *DurableTask) GetPayload() *anypb.Any

+ func (x *DurableTask) GetPriority() int32

+ func (x *DurableTask) GetRetries() int32

+ func (x *DurableTask) GetRetryDelay() *durationpb.Duration

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

+ func (x *DurableTask) Reset()

+ func (x *DurableTask) String() string

+ type RegisterDurableTasksRequest struct

+ Tasks []*DurableTask

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

+ func (*RegisterDurableTasksRequest) ProtoMessage()

+ func (x *RegisterDurableTasksRequest) GetTasks() []*DurableTask

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

+ func (x *RegisterDurableTasksRequest) Reset()

+ func (x *RegisterDurableTasksRequest) String() string

+ type RegisterDurableTasksResponse struct

+ Ids []string

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

+ func (*RegisterDurableTasksResponse) ProtoMessage()

+ func (x *RegisterDurableTasksResponse) GetIds() []string

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

+ func (x *RegisterDurableTasksResponse) Reset()

+ func (x *RegisterDurableTasksResponse) String() string

type UnimplementedWorkerServiceServer

+ func (UnimplementedWorkerServiceServer) RegisterDurableTasks(context.Context, *RegisterDurableTasksRequest) (*RegisterDurableTasksResponse, error)

type WorkerServiceClient

+ RegisterDurableTasks func(ctx context.Context, in *RegisterDurableTasksRequest, opts ...grpc.CallOption) (*RegisterDurableTasksResponse, error)

type WorkerServiceServer

+ RegisterDurableTasks func(context.Context, *RegisterDurableTasksRequest) (*RegisterDurableTasksResponse, error)

v0.1.7

Jan 29, 2026

v0.1.6

Jan 28, 2026

v0.1.5

Jan 24, 2026

v0.1.4

Jan 23, 2026

v0.1.3

Jan 22, 2026

v0.1.2

Jan 3, 2026

v0.1.1

Aug 18, 2025

Changes in this version

+ const WorkerService_CancelTask_FullMethodName

+ const WorkerService_GetTask_FullMethodName

+ const WorkerService_RegisterTasks_FullMethodName

+ const WorkerService_StreamResults_FullMethodName

+ var File_worker_v1_payload_proto protoreflect.FileDescriptor

+ var File_worker_v1_worker_proto protoreflect.FileDescriptor

+ var WorkerService_ServiceDesc = grpc.ServiceDesc

+ func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

+ type CancelTaskRequest struct

+ Id string

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

+ func (*CancelTaskRequest) ProtoMessage()

+ func (x *CancelTaskRequest) GetId() string

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

+ func (x *CancelTaskRequest) Reset()

+ func (x *CancelTaskRequest) String() string

+ type CancelTaskResponse struct

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

+ func (*CancelTaskResponse) ProtoMessage()

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

+ func (x *CancelTaskResponse) Reset()

+ func (x *CancelTaskResponse) String() string

+ type GetTaskRequest struct

+ Id string

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

+ func (*GetTaskRequest) ProtoMessage()

+ func (x *GetTaskRequest) GetId() string

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

+ func (x *GetTaskRequest) Reset()

+ func (x *GetTaskRequest) String() string

+ type GetTaskResponse struct

+ Error string

+ Id string

+ Name string

+ Output string

+ Status string

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

+ func (*GetTaskResponse) ProtoMessage()

+ func (x *GetTaskResponse) GetError() string

+ func (x *GetTaskResponse) GetId() string

+ func (x *GetTaskResponse) GetName() string

+ func (x *GetTaskResponse) GetOutput() string

+ func (x *GetTaskResponse) GetStatus() string

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

+ func (x *GetTaskResponse) Reset()

+ func (x *GetTaskResponse) String() string

+ type RegisterTasksRequest struct

+ Tasks []*Task

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

+ func (*RegisterTasksRequest) ProtoMessage()

+ func (x *RegisterTasksRequest) GetTasks() []*Task

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

+ func (x *RegisterTasksRequest) Reset()

+ func (x *RegisterTasksRequest) String() string

+ type RegisterTasksResponse struct

+ Ids []string

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

+ func (*RegisterTasksResponse) ProtoMessage()

+ func (x *RegisterTasksResponse) GetIds() []string

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

+ func (x *RegisterTasksResponse) Reset()

+ func (x *RegisterTasksResponse) String() string

+ type SendEmailPayload struct

+ Body string

+ Subject string

+ To string

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

+ func (*SendEmailPayload) ProtoMessage()

+ func (x *SendEmailPayload) GetBody() string

+ func (x *SendEmailPayload) GetSubject() string

+ func (x *SendEmailPayload) GetTo() string

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

+ func (x *SendEmailPayload) Reset()

+ func (x *SendEmailPayload) String() string

+ type StreamResultsRequest struct

+ CloseOnCompletion bool

+ Ids []string

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

+ func (*StreamResultsRequest) ProtoMessage()

+ func (x *StreamResultsRequest) GetCloseOnCompletion() bool

+ func (x *StreamResultsRequest) GetIds() []string

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

+ func (x *StreamResultsRequest) Reset()

+ func (x *StreamResultsRequest) String() string

+ type StreamResultsResponse struct

+ Error string

+ Id string

+ Output string

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

+ func (*StreamResultsResponse) ProtoMessage()

+ func (x *StreamResultsResponse) GetError() string

+ func (x *StreamResultsResponse) GetId() string

+ func (x *StreamResultsResponse) GetOutput() string

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

+ func (x *StreamResultsResponse) Reset()

+ func (x *StreamResultsResponse) String() string

+ type Task struct

+ CorrelationId string

+ Description string

+ IdempotencyKey string

+ Metadata map[string]string

+ Name string

+ Payload *anypb.Any

+ Priority int32

+ Retries int32

+ RetryDelay *durationpb.Duration

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

+ func (*Task) ProtoMessage()

+ func (x *Task) GetCorrelationId() string

+ func (x *Task) GetDescription() string

+ func (x *Task) GetIdempotencyKey() string

+ func (x *Task) GetMetadata() map[string]string

+ func (x *Task) GetName() string

+ func (x *Task) GetPayload() *anypb.Any

+ func (x *Task) GetPriority() int32

+ func (x *Task) GetRetries() int32

+ func (x *Task) GetRetryDelay() *durationpb.Duration

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

+ func (x *Task) Reset()

+ func (x *Task) String() string

+ type UnimplementedWorkerServiceServer struct

+ func (UnimplementedWorkerServiceServer) CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)

+ func (UnimplementedWorkerServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)

+ func (UnimplementedWorkerServiceServer) RegisterTasks(context.Context, *RegisterTasksRequest) (*RegisterTasksResponse, error)

+ func (UnimplementedWorkerServiceServer) StreamResults(*StreamResultsRequest, grpc.ServerStreamingServer[StreamResultsResponse]) error

+ type UnsafeWorkerServiceServer interface

+ type WorkerServiceClient interface

+ CancelTask func(ctx context.Context, in *CancelTaskRequest, opts ...grpc.CallOption) (*CancelTaskResponse, error)

+ GetTask func(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error)

+ RegisterTasks func(ctx context.Context, in *RegisterTasksRequest, opts ...grpc.CallOption) (*RegisterTasksResponse, error)

+ StreamResults func(ctx context.Context, in *StreamResultsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamResultsResponse], error)

+ func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

+ type WorkerServiceServer interface

+ CancelTask func(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)

+ GetTask func(context.Context, *GetTaskRequest) (*GetTaskResponse, error)

+ RegisterTasks func(context.Context, *RegisterTasksRequest) (*RegisterTasksResponse, error)

+ StreamResults func(*StreamResultsRequest, grpc.ServerStreamingServer[StreamResultsResponse]) error

+ type WorkerService_StreamResultsClient = grpc.ServerStreamingClient[StreamResultsResponse]

+ type WorkerService_StreamResultsServer = grpc.ServerStreamingServer[StreamResultsResponse]

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL