mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
376 lines
14 KiB
Go
376 lines
14 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/chasm/lib/nexusoperation/proto/v1/operation.proto
|
|
|
|
package nexusoperationpb
|
|
|
|
import (
|
|
reflect "reflect"
|
|
"strconv"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
)
|
|
|
|
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)
|
|
)
|
|
|
|
type OperationStatus int32
|
|
|
|
const (
|
|
// Default value, unspecified status.
|
|
OPERATION_STATUS_UNSPECIFIED OperationStatus = 0
|
|
// Operation is in the queue waiting to be executed or is currently executing.
|
|
OPERATION_STATUS_SCHEDULED OperationStatus = 1
|
|
// Operation has failed with a retryable error and is backing off before the next attempt.
|
|
OPERATION_STATUS_BACKING_OFF OperationStatus = 2
|
|
// Operation was started and will complete asynchronously.
|
|
OPERATION_STATUS_STARTED OperationStatus = 3
|
|
// Operation succeeded.
|
|
// This may happen either as a response to a start request or as reported via callback.
|
|
OPERATION_STATUS_SUCCEEDED OperationStatus = 4
|
|
// Operation failed either when a start request encounters a non-retryable error or as reported via callback.
|
|
OPERATION_STATUS_FAILED OperationStatus = 5
|
|
// Operation completed as canceled (may have not ever been delivered).
|
|
// This may happen either as a response to a start request or as reported via callback.
|
|
OPERATION_STATUS_CANCELED OperationStatus = 6
|
|
// Operation timed out - exceeded the user supplied schedule-to-close timeout.
|
|
// Any attempts to complete the operation in this status will be ignored.
|
|
OPERATION_STATUS_TIMED_OUT OperationStatus = 7
|
|
)
|
|
|
|
// Enum value maps for OperationStatus.
|
|
var (
|
|
OperationStatus_name = map[int32]string{
|
|
0: "OPERATION_STATUS_UNSPECIFIED",
|
|
1: "OPERATION_STATUS_SCHEDULED",
|
|
2: "OPERATION_STATUS_BACKING_OFF",
|
|
3: "OPERATION_STATUS_STARTED",
|
|
4: "OPERATION_STATUS_SUCCEEDED",
|
|
5: "OPERATION_STATUS_FAILED",
|
|
6: "OPERATION_STATUS_CANCELED",
|
|
7: "OPERATION_STATUS_TIMED_OUT",
|
|
}
|
|
OperationStatus_value = map[string]int32{
|
|
"OPERATION_STATUS_UNSPECIFIED": 0,
|
|
"OPERATION_STATUS_SCHEDULED": 1,
|
|
"OPERATION_STATUS_BACKING_OFF": 2,
|
|
"OPERATION_STATUS_STARTED": 3,
|
|
"OPERATION_STATUS_SUCCEEDED": 4,
|
|
"OPERATION_STATUS_FAILED": 5,
|
|
"OPERATION_STATUS_CANCELED": 6,
|
|
"OPERATION_STATUS_TIMED_OUT": 7,
|
|
}
|
|
)
|
|
|
|
func (x OperationStatus) Enum() *OperationStatus {
|
|
p := new(OperationStatus)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x OperationStatus) String() string {
|
|
switch x {
|
|
case OPERATION_STATUS_UNSPECIFIED:
|
|
return "Unspecified"
|
|
case OPERATION_STATUS_SCHEDULED:
|
|
return "Scheduled"
|
|
case OPERATION_STATUS_BACKING_OFF:
|
|
return "BackingOff"
|
|
case OPERATION_STATUS_STARTED:
|
|
return "Started"
|
|
case OPERATION_STATUS_SUCCEEDED:
|
|
return "Succeeded"
|
|
case OPERATION_STATUS_FAILED:
|
|
return "Failed"
|
|
case OPERATION_STATUS_CANCELED:
|
|
return "Canceled"
|
|
case OPERATION_STATUS_TIMED_OUT:
|
|
return "TimedOut"
|
|
default:
|
|
return strconv.Itoa(int(x))
|
|
}
|
|
|
|
}
|
|
|
|
func (OperationStatus) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_enumTypes[0].Descriptor()
|
|
}
|
|
|
|
func (OperationStatus) Type() protoreflect.EnumType {
|
|
return &file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_enumTypes[0]
|
|
}
|
|
|
|
func (x OperationStatus) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use OperationStatus.Descriptor instead.
|
|
func (OperationStatus) EnumDescriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
type CancellationStatus int32
|
|
|
|
const (
|
|
// Default value, unspecified status.
|
|
CANCELLATION_STATUS_UNSPECIFIED CancellationStatus = 0
|
|
// Cancellation request is in the queue waiting to be executed or is currently executing.
|
|
CANCELLATION_STATUS_SCHEDULED CancellationStatus = 1
|
|
// Cancellation request has failed with a retryable error and is backing off before the next attempt.
|
|
CANCELLATION_STATUS_BACKING_OFF CancellationStatus = 2
|
|
// Cancellation request succeeded.
|
|
CANCELLATION_STATUS_SUCCEEDED CancellationStatus = 3
|
|
// Cancellation request failed with a non-retryable error.
|
|
CANCELLATION_STATUS_FAILED CancellationStatus = 4
|
|
// The associated operation timed out - exceeded the user supplied schedule-to-close timeout.
|
|
CANCELLATION_STATUS_TIMED_OUT CancellationStatus = 5
|
|
// Cancellation request is blocked (eg: by circuit breaker).
|
|
CANCELLATION_STATUS_BLOCKED CancellationStatus = 6
|
|
)
|
|
|
|
// Enum value maps for CancellationStatus.
|
|
var (
|
|
CancellationStatus_name = map[int32]string{
|
|
0: "CANCELLATION_STATUS_UNSPECIFIED",
|
|
1: "CANCELLATION_STATUS_SCHEDULED",
|
|
2: "CANCELLATION_STATUS_BACKING_OFF",
|
|
3: "CANCELLATION_STATUS_SUCCEEDED",
|
|
4: "CANCELLATION_STATUS_FAILED",
|
|
5: "CANCELLATION_STATUS_TIMED_OUT",
|
|
6: "CANCELLATION_STATUS_BLOCKED",
|
|
}
|
|
CancellationStatus_value = map[string]int32{
|
|
"CANCELLATION_STATUS_UNSPECIFIED": 0,
|
|
"CANCELLATION_STATUS_SCHEDULED": 1,
|
|
"CANCELLATION_STATUS_BACKING_OFF": 2,
|
|
"CANCELLATION_STATUS_SUCCEEDED": 3,
|
|
"CANCELLATION_STATUS_FAILED": 4,
|
|
"CANCELLATION_STATUS_TIMED_OUT": 5,
|
|
"CANCELLATION_STATUS_BLOCKED": 6,
|
|
}
|
|
)
|
|
|
|
func (x CancellationStatus) Enum() *CancellationStatus {
|
|
p := new(CancellationStatus)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x CancellationStatus) String() string {
|
|
switch x {
|
|
case CANCELLATION_STATUS_UNSPECIFIED:
|
|
return "Unspecified"
|
|
case CANCELLATION_STATUS_SCHEDULED:
|
|
return "Scheduled"
|
|
case CANCELLATION_STATUS_BACKING_OFF:
|
|
return "BackingOff"
|
|
case CANCELLATION_STATUS_SUCCEEDED:
|
|
return "Succeeded"
|
|
case CANCELLATION_STATUS_FAILED:
|
|
return "Failed"
|
|
case CANCELLATION_STATUS_TIMED_OUT:
|
|
return "TimedOut"
|
|
case CANCELLATION_STATUS_BLOCKED:
|
|
return "Blocked"
|
|
default:
|
|
return strconv.Itoa(int(x))
|
|
}
|
|
|
|
}
|
|
|
|
func (CancellationStatus) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_enumTypes[1].Descriptor()
|
|
}
|
|
|
|
func (CancellationStatus) Type() protoreflect.EnumType {
|
|
return &file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_enumTypes[1]
|
|
}
|
|
|
|
func (x CancellationStatus) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use CancellationStatus.Descriptor instead.
|
|
func (CancellationStatus) EnumDescriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
type OperationState struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Status OperationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.server.chasm.lib.nexusoperation.proto.v1.OperationStatus" json:"status,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *OperationState) Reset() {
|
|
*x = OperationState{}
|
|
mi := &file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *OperationState) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*OperationState) ProtoMessage() {}
|
|
|
|
func (x *OperationState) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_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 OperationState.ProtoReflect.Descriptor instead.
|
|
func (*OperationState) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *OperationState) GetStatus() OperationStatus {
|
|
if x != nil {
|
|
return x.Status
|
|
}
|
|
return OPERATION_STATUS_UNSPECIFIED
|
|
}
|
|
|
|
type CancellationState struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Status CancellationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.server.chasm.lib.nexusoperation.proto.v1.CancellationStatus" json:"status,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CancellationState) Reset() {
|
|
*x = CancellationState{}
|
|
mi := &file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CancellationState) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CancellationState) ProtoMessage() {}
|
|
|
|
func (x *CancellationState) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_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 CancellationState.ProtoReflect.Descriptor instead.
|
|
func (*CancellationState) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *CancellationState) GetStatus() CancellationStatus {
|
|
if x != nil {
|
|
return x.Status
|
|
}
|
|
return CANCELLATION_STATUS_UNSPECIFIED
|
|
}
|
|
|
|
var File_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDesc = "" +
|
|
"\n" +
|
|
"Atemporal/server/chasm/lib/nexusoperation/proto/v1/operation.proto\x121temporal.server.chasm.lib.nexusoperation.proto.v1\"l\n" +
|
|
"\x0eOperationState\x12Z\n" +
|
|
"\x06status\x18\x01 \x01(\x0e2B.temporal.server.chasm.lib.nexusoperation.proto.v1.OperationStatusR\x06status\"r\n" +
|
|
"\x11CancellationState\x12]\n" +
|
|
"\x06status\x18\x01 \x01(\x0e2E.temporal.server.chasm.lib.nexusoperation.proto.v1.CancellationStatusR\x06status*\x8f\x02\n" +
|
|
"\x0fOperationStatus\x12 \n" +
|
|
"\x1cOPERATION_STATUS_UNSPECIFIED\x10\x00\x12\x1e\n" +
|
|
"\x1aOPERATION_STATUS_SCHEDULED\x10\x01\x12 \n" +
|
|
"\x1cOPERATION_STATUS_BACKING_OFF\x10\x02\x12\x1c\n" +
|
|
"\x18OPERATION_STATUS_STARTED\x10\x03\x12\x1e\n" +
|
|
"\x1aOPERATION_STATUS_SUCCEEDED\x10\x04\x12\x1b\n" +
|
|
"\x17OPERATION_STATUS_FAILED\x10\x05\x12\x1d\n" +
|
|
"\x19OPERATION_STATUS_CANCELED\x10\x06\x12\x1e\n" +
|
|
"\x1aOPERATION_STATUS_TIMED_OUT\x10\a*\x88\x02\n" +
|
|
"\x12CancellationStatus\x12#\n" +
|
|
"\x1fCANCELLATION_STATUS_UNSPECIFIED\x10\x00\x12!\n" +
|
|
"\x1dCANCELLATION_STATUS_SCHEDULED\x10\x01\x12#\n" +
|
|
"\x1fCANCELLATION_STATUS_BACKING_OFF\x10\x02\x12!\n" +
|
|
"\x1dCANCELLATION_STATUS_SUCCEEDED\x10\x03\x12\x1e\n" +
|
|
"\x1aCANCELLATION_STATUS_FAILED\x10\x04\x12!\n" +
|
|
"\x1dCANCELLATION_STATUS_TIMED_OUT\x10\x05\x12\x1f\n" +
|
|
"\x1bCANCELLATION_STATUS_BLOCKED\x10\x06BVZTgithub.com/hanzoai/tasks/chasm/lib/nexusoperation/gen/nexusoperationpb;nexusoperationpbb\x06proto3"
|
|
|
|
var (
|
|
file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescOnce sync.Once
|
|
file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDesc), len(file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDesc)))
|
|
})
|
|
return file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
|
|
var file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
|
|
var file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_goTypes = []any{
|
|
(OperationStatus)(0), // 0: temporal.server.chasm.lib.nexusoperation.proto.v1.OperationStatus
|
|
(CancellationStatus)(0), // 1: temporal.server.chasm.lib.nexusoperation.proto.v1.CancellationStatus
|
|
(*OperationState)(nil), // 2: temporal.server.chasm.lib.nexusoperation.proto.v1.OperationState
|
|
(*CancellationState)(nil), // 3: temporal.server.chasm.lib.nexusoperation.proto.v1.CancellationState
|
|
}
|
|
var file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_depIdxs = []int32{
|
|
0, // 0: temporal.server.chasm.lib.nexusoperation.proto.v1.OperationState.status:type_name -> temporal.server.chasm.lib.nexusoperation.proto.v1.OperationStatus
|
|
1, // 1: temporal.server.chasm.lib.nexusoperation.proto.v1.CancellationState.status:type_name -> temporal.server.chasm.lib.nexusoperation.proto.v1.CancellationStatus
|
|
2, // [2:2] is the sub-list for method output_type
|
|
2, // [2:2] is the sub-list for method input_type
|
|
2, // [2:2] is the sub-list for extension type_name
|
|
2, // [2:2] is the sub-list for extension extendee
|
|
0, // [0:2] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_init() }
|
|
func file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_init() {
|
|
if File_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_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_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDesc), len(file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_rawDesc)),
|
|
NumEnums: 2,
|
|
NumMessages: 2,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_depIdxs,
|
|
EnumInfos: file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_enumTypes,
|
|
MessageInfos: file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto = out.File
|
|
file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_goTypes = nil
|
|
file_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_depIdxs = nil
|
|
}
|