mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-02 12:22:18 +00:00
Lina JodoinandGitHub
f2f90fbba4
## What changed? - Added an RPC service to the CHASM Scheduler which implements its CRUD operations. - The intention is for the frontend handler to attempt to route to CHASM operations in history, and in the event of a not-found, let frontend retry its old (V1 scheduler) path. - These assume frontend's validation. As we move towards ripping out the old scheduler code, we'll start moving all of that existing logic over into the CHASM world, but for now, let's keep it as-is for as light a possible touch on existing paths. - This is based on `standalone-activity` just to get the API boilerplate stuff.
90 lines
6.6 KiB
Go
90 lines
6.6 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/chasm/lib/scheduler/proto/v1/service.proto
|
|
|
|
package schedulerpb
|
|
|
|
import (
|
|
reflect "reflect"
|
|
unsafe "unsafe"
|
|
|
|
_ "go.temporal.io/server/api/routing/v1"
|
|
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)
|
|
)
|
|
|
|
var File_temporal_server_chasm_lib_scheduler_proto_v1_service_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_rawDesc = "" +
|
|
"\n" +
|
|
":temporal/server/chasm/lib/scheduler/proto/v1/service.proto\x12,temporal.server.chasm.lib.scheduler.proto.v1\x1aCtemporal/server/chasm/lib/scheduler/proto/v1/request_response.proto\x1a.temporal/server/api/routing/v1/extension.proto2\xdf\a\n" +
|
|
"\x10SchedulerService\x12\xbf\x01\n" +
|
|
"\x0eCreateSchedule\x12C.temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleRequest\x1aD.temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleResponse\"\"\x92\xc4\x03\x1e\x1a\x1cfrontend_request.schedule_id\x12\xbf\x01\n" +
|
|
"\x0eUpdateSchedule\x12C.temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleRequest\x1aD.temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleResponse\"\"\x92\xc4\x03\x1e\x1a\x1cfrontend_request.schedule_id\x12\xbc\x01\n" +
|
|
"\rPatchSchedule\x12B.temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleRequest\x1aC.temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleResponse\"\"\x92\xc4\x03\x1e\x1a\x1cfrontend_request.schedule_id\x12\xbf\x01\n" +
|
|
"\x0eDeleteSchedule\x12C.temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleRequest\x1aD.temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleResponse\"\"\x92\xc4\x03\x1e\x1a\x1cfrontend_request.schedule_id\x12\xc5\x01\n" +
|
|
"\x10DescribeSchedule\x12E.temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleRequest\x1aF.temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleResponse\"\"\x92\xc4\x03\x1e\x1a\x1cfrontend_request.schedule_idBGZEgo.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb;schedulerpbb\x06proto3"
|
|
|
|
var file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_goTypes = []any{
|
|
(*CreateScheduleRequest)(nil), // 0: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleRequest
|
|
(*UpdateScheduleRequest)(nil), // 1: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleRequest
|
|
(*PatchScheduleRequest)(nil), // 2: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleRequest
|
|
(*DeleteScheduleRequest)(nil), // 3: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleRequest
|
|
(*DescribeScheduleRequest)(nil), // 4: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleRequest
|
|
(*CreateScheduleResponse)(nil), // 5: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleResponse
|
|
(*UpdateScheduleResponse)(nil), // 6: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleResponse
|
|
(*PatchScheduleResponse)(nil), // 7: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleResponse
|
|
(*DeleteScheduleResponse)(nil), // 8: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleResponse
|
|
(*DescribeScheduleResponse)(nil), // 9: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleResponse
|
|
}
|
|
var file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_depIdxs = []int32{
|
|
0, // 0: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.CreateSchedule:input_type -> temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleRequest
|
|
1, // 1: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.UpdateSchedule:input_type -> temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleRequest
|
|
2, // 2: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.PatchSchedule:input_type -> temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleRequest
|
|
3, // 3: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.DeleteSchedule:input_type -> temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleRequest
|
|
4, // 4: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.DescribeSchedule:input_type -> temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleRequest
|
|
5, // 5: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.CreateSchedule:output_type -> temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleResponse
|
|
6, // 6: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.UpdateSchedule:output_type -> temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleResponse
|
|
7, // 7: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.PatchSchedule:output_type -> temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleResponse
|
|
8, // 8: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.DeleteSchedule:output_type -> temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleResponse
|
|
9, // 9: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerService.DescribeSchedule:output_type -> temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleResponse
|
|
5, // [5:10] is the sub-list for method output_type
|
|
0, // [0:5] is the sub-list for method input_type
|
|
0, // [0:0] is the sub-list for extension type_name
|
|
0, // [0:0] is the sub-list for extension extendee
|
|
0, // [0:0] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_init() }
|
|
func file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_init() {
|
|
if File_temporal_server_chasm_lib_scheduler_proto_v1_service_proto != nil {
|
|
return
|
|
}
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init()
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 0,
|
|
NumExtensions: 0,
|
|
NumServices: 1,
|
|
},
|
|
GoTypes: file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_depIdxs,
|
|
}.Build()
|
|
File_temporal_server_chasm_lib_scheduler_proto_v1_service_proto = out.File
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_goTypes = nil
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_depIdxs = nil
|
|
}
|