mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
8e88b08134
Added standalone activity Chasm tasks. Added handling of start activity and e2e implementation of standalone activity start execution with existing services. Updated protos related to standalone activities. The Chasm tasks are needed to kick off standalone activity execution via the existing services. Proto changes needed to so that the component ref can be passed and handled via service stack. - [X] built - [X] run locally and tested manually - [X] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) --------- Co-authored-by: Roey Berman <[email protected]> Co-authored-by: Dan Davison <[email protected]>
661 lines
24 KiB
Go
661 lines
24 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/api/persistence/v1/tasks.proto
|
|
|
|
package persistence
|
|
|
|
import (
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
|
|
v12 "go.temporal.io/api/common/v1"
|
|
v13 "go.temporal.io/api/enums/v1"
|
|
v1 "go.temporal.io/server/api/clock/v1"
|
|
v11 "go.temporal.io/server/api/taskqueue/v1"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
// task column
|
|
type AllocatedTaskInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Data *TaskInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
|
|
TaskPass int64 `protobuf:"varint,3,opt,name=task_pass,json=taskPass,proto3" json:"task_pass,omitempty"`
|
|
TaskId int64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AllocatedTaskInfo) Reset() {
|
|
*x = AllocatedTaskInfo{}
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AllocatedTaskInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AllocatedTaskInfo) ProtoMessage() {}
|
|
|
|
func (x *AllocatedTaskInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AllocatedTaskInfo.ProtoReflect.Descriptor instead.
|
|
func (*AllocatedTaskInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *AllocatedTaskInfo) GetData() *TaskInfo {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *AllocatedTaskInfo) GetTaskPass() int64 {
|
|
if x != nil {
|
|
return x.TaskPass
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *AllocatedTaskInfo) GetTaskId() int64 {
|
|
if x != nil {
|
|
return x.TaskId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type TaskInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
ScheduledEventId int64 `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
|
|
CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
|
|
ExpiryTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
|
|
Clock *v1.VectorClock `protobuf:"bytes,7,opt,name=clock,proto3" json:"clock,omitempty"`
|
|
// How this task should be directed. (Missing means the default for
|
|
// TaskVersionDirective, which is unversioned.)
|
|
VersionDirective *v11.TaskVersionDirective `protobuf:"bytes,8,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
|
|
// Stamp field allows to differentiate between different instances of the same task
|
|
Stamp int32 `protobuf:"varint,9,opt,name=stamp,proto3" json:"stamp,omitempty"`
|
|
Priority *v12.Priority `protobuf:"bytes,10,opt,name=priority,proto3" json:"priority,omitempty"`
|
|
// Reference to any chasm component associated with this task
|
|
ComponentRef []byte `protobuf:"bytes,11,opt,name=component_ref,json=componentRef,proto3" json:"component_ref,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TaskInfo) Reset() {
|
|
*x = TaskInfo{}
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TaskInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TaskInfo) ProtoMessage() {}
|
|
|
|
func (x *TaskInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.
|
|
func (*TaskInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *TaskInfo) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskInfo) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskInfo) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskInfo) GetScheduledEventId() int64 {
|
|
if x != nil {
|
|
return x.ScheduledEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TaskInfo) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskInfo) GetExpiryTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.ExpiryTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskInfo) GetClock() *v1.VectorClock {
|
|
if x != nil {
|
|
return x.Clock
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskInfo) GetVersionDirective() *v11.TaskVersionDirective {
|
|
if x != nil {
|
|
return x.VersionDirective
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskInfo) GetStamp() int32 {
|
|
if x != nil {
|
|
return x.Stamp
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TaskInfo) GetPriority() *v12.Priority {
|
|
if x != nil {
|
|
return x.Priority
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskInfo) GetComponentRef() []byte {
|
|
if x != nil {
|
|
return x.ComponentRef
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// task_queue column
|
|
type TaskQueueInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
|
|
TaskType v13.TaskQueueType `protobuf:"varint,3,opt,name=task_type,json=taskType,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"task_type,omitempty"`
|
|
Kind v13.TaskQueueKind `protobuf:"varint,4,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"`
|
|
// After data is migrated into subqueues, this contains a copy of the ack level for subqueue 0.
|
|
AckLevel int64 `protobuf:"varint,5,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
|
|
ExpiryTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
|
|
LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
|
|
// After data is migrated into subqueues, this contains a copy of the count for subqueue 0.
|
|
ApproximateBacklogCount int64 `protobuf:"varint,8,opt,name=approximate_backlog_count,json=approximateBacklogCount,proto3" json:"approximate_backlog_count,omitempty"`
|
|
// Subqueues contains one entry for each subqueue in this physical task queue.
|
|
// Tasks are split into subqueues to implement priority and fairness.
|
|
// Subqueues are indexed starting from 0, the zero subqueue is always present
|
|
// and corresponds to the "main" queue before subqueues were introduced.
|
|
//
|
|
// The message at index n describes the subqueue at index n.
|
|
//
|
|
// Each subqueue has its own ack level and approx backlog count, but they share
|
|
// the range id. For compatibility, ack level and backlog count for subqueue 0
|
|
// is copied into TaskQueueInfo.
|
|
Subqueues []*SubqueueInfo `protobuf:"bytes,9,rep,name=subqueues,proto3" json:"subqueues,omitempty"`
|
|
// For transitioning from tasks (v1) to tasks_v2 and back:
|
|
//
|
|
// If this TaskQueueInfo is in v1 and this is set, then v2 may have tasks.
|
|
// If this TaskQueueInfo is in v2 and this is set, then v1 may have tasks.
|
|
//
|
|
// New metadata starts with this flag set (we could skip this when useNewMatcher is off).
|
|
// Whenever locking any metadata as the inactive one (drain-only), this should be set.
|
|
// If the flag is true, no tasks should be written to the active table until the inactive
|
|
// table has also been locked (and the flag set there for a potential reverse transition).
|
|
// After determinining that the inactive table has no more tasks left, then this
|
|
// can be cleared on the active table.
|
|
OtherHasTasks bool `protobuf:"varint,10,opt,name=other_has_tasks,json=otherHasTasks,proto3" json:"other_has_tasks,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TaskQueueInfo) Reset() {
|
|
*x = TaskQueueInfo{}
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TaskQueueInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TaskQueueInfo) ProtoMessage() {}
|
|
|
|
func (x *TaskQueueInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TaskQueueInfo.ProtoReflect.Descriptor instead.
|
|
func (*TaskQueueInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetName() string {
|
|
if x != nil {
|
|
return x.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetTaskType() v13.TaskQueueType {
|
|
if x != nil {
|
|
return x.TaskType
|
|
}
|
|
return v13.TaskQueueType(0)
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetKind() v13.TaskQueueKind {
|
|
if x != nil {
|
|
return x.Kind
|
|
}
|
|
return v13.TaskQueueKind(0)
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetAckLevel() int64 {
|
|
if x != nil {
|
|
return x.AckLevel
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetExpiryTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.ExpiryTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetLastUpdateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastUpdateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetApproximateBacklogCount() int64 {
|
|
if x != nil {
|
|
return x.ApproximateBacklogCount
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetSubqueues() []*SubqueueInfo {
|
|
if x != nil {
|
|
return x.Subqueues
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskQueueInfo) GetOtherHasTasks() bool {
|
|
if x != nil {
|
|
return x.OtherHasTasks
|
|
}
|
|
return false
|
|
}
|
|
|
|
type SubqueueInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Key is the information used by a splitting algorithm to decide which tasks should go in
|
|
// this subqueue. It should not change after being registered in TaskQueueInfo.
|
|
Key *SubqueueKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
|
|
// The rest are mutable state for the subqueue:
|
|
AckLevel int64 `protobuf:"varint,2,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
|
|
FairAckLevel *v11.FairLevel `protobuf:"bytes,4,opt,name=fair_ack_level,json=fairAckLevel,proto3" json:"fair_ack_level,omitempty"`
|
|
ApproximateBacklogCount int64 `protobuf:"varint,3,opt,name=approximate_backlog_count,json=approximateBacklogCount,proto3" json:"approximate_backlog_count,omitempty"`
|
|
// Max read level keeps track of the highest task level ever written, but is only
|
|
// maintained best-effort. Do not trust these values.
|
|
FairMaxReadLevel *v11.FairLevel `protobuf:"bytes,5,opt,name=fair_max_read_level,json=fairMaxReadLevel,proto3" json:"fair_max_read_level,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SubqueueInfo) Reset() {
|
|
*x = SubqueueInfo{}
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SubqueueInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SubqueueInfo) ProtoMessage() {}
|
|
|
|
func (x *SubqueueInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SubqueueInfo.ProtoReflect.Descriptor instead.
|
|
func (*SubqueueInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *SubqueueInfo) GetKey() *SubqueueKey {
|
|
if x != nil {
|
|
return x.Key
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SubqueueInfo) GetAckLevel() int64 {
|
|
if x != nil {
|
|
return x.AckLevel
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SubqueueInfo) GetFairAckLevel() *v11.FairLevel {
|
|
if x != nil {
|
|
return x.FairAckLevel
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SubqueueInfo) GetApproximateBacklogCount() int64 {
|
|
if x != nil {
|
|
return x.ApproximateBacklogCount
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SubqueueInfo) GetFairMaxReadLevel() *v11.FairLevel {
|
|
if x != nil {
|
|
return x.FairMaxReadLevel
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SubqueueKey struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Each subqueue contains tasks from only one priority level.
|
|
Priority int32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SubqueueKey) Reset() {
|
|
*x = SubqueueKey{}
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SubqueueKey) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SubqueueKey) ProtoMessage() {}
|
|
|
|
func (x *SubqueueKey) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SubqueueKey.ProtoReflect.Descriptor instead.
|
|
func (*SubqueueKey) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *SubqueueKey) GetPriority() int32 {
|
|
if x != nil {
|
|
return x.Priority
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type TaskKey struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
FireTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fire_time,json=fireTime,proto3" json:"fire_time,omitempty"`
|
|
TaskId int64 `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TaskKey) Reset() {
|
|
*x = TaskKey{}
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TaskKey) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TaskKey) ProtoMessage() {}
|
|
|
|
func (x *TaskKey) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_tasks_proto_msgTypes[5]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TaskKey.ProtoReflect.Descriptor instead.
|
|
func (*TaskKey) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *TaskKey) GetFireTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.FireTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TaskKey) GetTaskId() int64 {
|
|
if x != nil {
|
|
return x.TaskId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
var File_temporal_server_api_persistence_v1_tasks_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_api_persistence_v1_tasks_proto_rawDesc = "" +
|
|
"\n" +
|
|
".temporal/server/api/persistence/v1/tasks.proto\x12\"temporal.server.api.persistence.v1\x1a\x1fgoogle/protobuf/timestamp.proto\x1a$temporal/api/common/v1/message.proto\x1a&temporal/api/enums/v1/task_queue.proto\x1a*temporal/server/api/clock/v1/message.proto\x1a.temporal/server/api/taskqueue/v1/message.proto\"\x8b\x01\n" +
|
|
"\x11AllocatedTaskInfo\x12@\n" +
|
|
"\x04data\x18\x01 \x01(\v2,.temporal.server.api.persistence.v1.TaskInfoR\x04data\x12\x1b\n" +
|
|
"\ttask_pass\x18\x03 \x01(\x03R\btaskPass\x12\x17\n" +
|
|
"\atask_id\x18\x02 \x01(\x03R\x06taskId\"\xac\x04\n" +
|
|
"\bTaskInfo\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x02 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12,\n" +
|
|
"\x12scheduled_event_id\x18\x04 \x01(\x03R\x10scheduledEventId\x12;\n" +
|
|
"\vcreate_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\x12;\n" +
|
|
"\vexpiry_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"expiryTime\x12?\n" +
|
|
"\x05clock\x18\a \x01(\v2).temporal.server.api.clock.v1.VectorClockR\x05clock\x12c\n" +
|
|
"\x11version_directive\x18\b \x01(\v26.temporal.server.api.taskqueue.v1.TaskVersionDirectiveR\x10versionDirective\x12\x14\n" +
|
|
"\x05stamp\x18\t \x01(\x05R\x05stamp\x12<\n" +
|
|
"\bpriority\x18\n" +
|
|
" \x01(\v2 .temporal.api.common.v1.PriorityR\bpriority\x12#\n" +
|
|
"\rcomponent_ref\x18\v \x01(\fR\fcomponentRef\"\x97\x04\n" +
|
|
"\rTaskQueueInfo\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x12\n" +
|
|
"\x04name\x18\x02 \x01(\tR\x04name\x12A\n" +
|
|
"\ttask_type\x18\x03 \x01(\x0e2$.temporal.api.enums.v1.TaskQueueTypeR\btaskType\x128\n" +
|
|
"\x04kind\x18\x04 \x01(\x0e2$.temporal.api.enums.v1.TaskQueueKindR\x04kind\x12\x1b\n" +
|
|
"\tack_level\x18\x05 \x01(\x03R\backLevel\x12;\n" +
|
|
"\vexpiry_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"expiryTime\x12D\n" +
|
|
"\x10last_update_time\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\x0elastUpdateTime\x12:\n" +
|
|
"\x19approximate_backlog_count\x18\b \x01(\x03R\x17approximateBacklogCount\x12N\n" +
|
|
"\tsubqueues\x18\t \x03(\v20.temporal.server.api.persistence.v1.SubqueueInfoR\tsubqueues\x12&\n" +
|
|
"\x0fother_has_tasks\x18\n" +
|
|
" \x01(\bR\rotherHasTasks\"\xd9\x02\n" +
|
|
"\fSubqueueInfo\x12A\n" +
|
|
"\x03key\x18\x01 \x01(\v2/.temporal.server.api.persistence.v1.SubqueueKeyR\x03key\x12\x1b\n" +
|
|
"\tack_level\x18\x02 \x01(\x03R\backLevel\x12Q\n" +
|
|
"\x0efair_ack_level\x18\x04 \x01(\v2+.temporal.server.api.taskqueue.v1.FairLevelR\ffairAckLevel\x12:\n" +
|
|
"\x19approximate_backlog_count\x18\x03 \x01(\x03R\x17approximateBacklogCount\x12Z\n" +
|
|
"\x13fair_max_read_level\x18\x05 \x01(\v2+.temporal.server.api.taskqueue.v1.FairLevelR\x10fairMaxReadLevel\")\n" +
|
|
"\vSubqueueKey\x12\x1a\n" +
|
|
"\bpriority\x18\x01 \x01(\x05R\bpriority\"[\n" +
|
|
"\aTaskKey\x127\n" +
|
|
"\tfire_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\bfireTime\x12\x17\n" +
|
|
"\atask_id\x18\x02 \x01(\x03R\x06taskIdB6Z4go.temporal.io/server/api/persistence/v1;persistenceb\x06proto3"
|
|
|
|
var (
|
|
file_temporal_server_api_persistence_v1_tasks_proto_rawDescOnce sync.Once
|
|
file_temporal_server_api_persistence_v1_tasks_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_temporal_server_api_persistence_v1_tasks_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_api_persistence_v1_tasks_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_api_persistence_v1_tasks_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc), len(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc)))
|
|
})
|
|
return file_temporal_server_api_persistence_v1_tasks_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_api_persistence_v1_tasks_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
|
|
var file_temporal_server_api_persistence_v1_tasks_proto_goTypes = []any{
|
|
(*AllocatedTaskInfo)(nil), // 0: temporal.server.api.persistence.v1.AllocatedTaskInfo
|
|
(*TaskInfo)(nil), // 1: temporal.server.api.persistence.v1.TaskInfo
|
|
(*TaskQueueInfo)(nil), // 2: temporal.server.api.persistence.v1.TaskQueueInfo
|
|
(*SubqueueInfo)(nil), // 3: temporal.server.api.persistence.v1.SubqueueInfo
|
|
(*SubqueueKey)(nil), // 4: temporal.server.api.persistence.v1.SubqueueKey
|
|
(*TaskKey)(nil), // 5: temporal.server.api.persistence.v1.TaskKey
|
|
(*timestamppb.Timestamp)(nil), // 6: google.protobuf.Timestamp
|
|
(*v1.VectorClock)(nil), // 7: temporal.server.api.clock.v1.VectorClock
|
|
(*v11.TaskVersionDirective)(nil), // 8: temporal.server.api.taskqueue.v1.TaskVersionDirective
|
|
(*v12.Priority)(nil), // 9: temporal.api.common.v1.Priority
|
|
(v13.TaskQueueType)(0), // 10: temporal.api.enums.v1.TaskQueueType
|
|
(v13.TaskQueueKind)(0), // 11: temporal.api.enums.v1.TaskQueueKind
|
|
(*v11.FairLevel)(nil), // 12: temporal.server.api.taskqueue.v1.FairLevel
|
|
}
|
|
var file_temporal_server_api_persistence_v1_tasks_proto_depIdxs = []int32{
|
|
1, // 0: temporal.server.api.persistence.v1.AllocatedTaskInfo.data:type_name -> temporal.server.api.persistence.v1.TaskInfo
|
|
6, // 1: temporal.server.api.persistence.v1.TaskInfo.create_time:type_name -> google.protobuf.Timestamp
|
|
6, // 2: temporal.server.api.persistence.v1.TaskInfo.expiry_time:type_name -> google.protobuf.Timestamp
|
|
7, // 3: temporal.server.api.persistence.v1.TaskInfo.clock:type_name -> temporal.server.api.clock.v1.VectorClock
|
|
8, // 4: temporal.server.api.persistence.v1.TaskInfo.version_directive:type_name -> temporal.server.api.taskqueue.v1.TaskVersionDirective
|
|
9, // 5: temporal.server.api.persistence.v1.TaskInfo.priority:type_name -> temporal.api.common.v1.Priority
|
|
10, // 6: temporal.server.api.persistence.v1.TaskQueueInfo.task_type:type_name -> temporal.api.enums.v1.TaskQueueType
|
|
11, // 7: temporal.server.api.persistence.v1.TaskQueueInfo.kind:type_name -> temporal.api.enums.v1.TaskQueueKind
|
|
6, // 8: temporal.server.api.persistence.v1.TaskQueueInfo.expiry_time:type_name -> google.protobuf.Timestamp
|
|
6, // 9: temporal.server.api.persistence.v1.TaskQueueInfo.last_update_time:type_name -> google.protobuf.Timestamp
|
|
3, // 10: temporal.server.api.persistence.v1.TaskQueueInfo.subqueues:type_name -> temporal.server.api.persistence.v1.SubqueueInfo
|
|
4, // 11: temporal.server.api.persistence.v1.SubqueueInfo.key:type_name -> temporal.server.api.persistence.v1.SubqueueKey
|
|
12, // 12: temporal.server.api.persistence.v1.SubqueueInfo.fair_ack_level:type_name -> temporal.server.api.taskqueue.v1.FairLevel
|
|
12, // 13: temporal.server.api.persistence.v1.SubqueueInfo.fair_max_read_level:type_name -> temporal.server.api.taskqueue.v1.FairLevel
|
|
6, // 14: temporal.server.api.persistence.v1.TaskKey.fire_time:type_name -> google.protobuf.Timestamp
|
|
15, // [15:15] is the sub-list for method output_type
|
|
15, // [15:15] is the sub-list for method input_type
|
|
15, // [15:15] is the sub-list for extension type_name
|
|
15, // [15:15] is the sub-list for extension extendee
|
|
0, // [0:15] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_api_persistence_v1_tasks_proto_init() }
|
|
func file_temporal_server_api_persistence_v1_tasks_proto_init() {
|
|
if File_temporal_server_api_persistence_v1_tasks_proto != nil {
|
|
return
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc), len(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 6,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_api_persistence_v1_tasks_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_api_persistence_v1_tasks_proto_depIdxs,
|
|
MessageInfos: file_temporal_server_api_persistence_v1_tasks_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_api_persistence_v1_tasks_proto = out.File
|
|
file_temporal_server_api_persistence_v1_tasks_proto_goTypes = nil
|
|
file_temporal_server_api_persistence_v1_tasks_proto_depIdxs = nil
|
|
}
|