mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-30 14:56:19 +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.
618 lines
25 KiB
Go
618 lines
25 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/chasm/lib/scheduler/proto/v1/request_response.proto
|
|
|
|
package schedulerpb
|
|
|
|
import (
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
|
|
v1 "go.temporal.io/api/workflowservice/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)
|
|
)
|
|
|
|
type CreateScheduleRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Internal namespace ID (UUID).
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
FrontendRequest *v1.CreateScheduleRequest `protobuf:"bytes,2,opt,name=frontend_request,json=frontendRequest,proto3" json:"frontend_request,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateScheduleRequest) Reset() {
|
|
*x = CreateScheduleRequest{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateScheduleRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateScheduleRequest) ProtoMessage() {}
|
|
|
|
func (x *CreateScheduleRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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 CreateScheduleRequest.ProtoReflect.Descriptor instead.
|
|
func (*CreateScheduleRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *CreateScheduleRequest) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *CreateScheduleRequest) GetFrontendRequest() *v1.CreateScheduleRequest {
|
|
if x != nil {
|
|
return x.FrontendRequest
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type CreateScheduleResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
FrontendResponse *v1.CreateScheduleResponse `protobuf:"bytes,1,opt,name=frontend_response,json=frontendResponse,proto3" json:"frontend_response,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateScheduleResponse) Reset() {
|
|
*x = CreateScheduleResponse{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateScheduleResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateScheduleResponse) ProtoMessage() {}
|
|
|
|
func (x *CreateScheduleResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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 CreateScheduleResponse.ProtoReflect.Descriptor instead.
|
|
func (*CreateScheduleResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *CreateScheduleResponse) GetFrontendResponse() *v1.CreateScheduleResponse {
|
|
if x != nil {
|
|
return x.FrontendResponse
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type UpdateScheduleRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Internal namespace ID (UUID).
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
FrontendRequest *v1.UpdateScheduleRequest `protobuf:"bytes,2,opt,name=frontend_request,json=frontendRequest,proto3" json:"frontend_request,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateScheduleRequest) Reset() {
|
|
*x = UpdateScheduleRequest{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateScheduleRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateScheduleRequest) ProtoMessage() {}
|
|
|
|
func (x *UpdateScheduleRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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 UpdateScheduleRequest.ProtoReflect.Descriptor instead.
|
|
func (*UpdateScheduleRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *UpdateScheduleRequest) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *UpdateScheduleRequest) GetFrontendRequest() *v1.UpdateScheduleRequest {
|
|
if x != nil {
|
|
return x.FrontendRequest
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type UpdateScheduleResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
FrontendResponse *v1.UpdateScheduleResponse `protobuf:"bytes,1,opt,name=frontend_response,json=frontendResponse,proto3" json:"frontend_response,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateScheduleResponse) Reset() {
|
|
*x = UpdateScheduleResponse{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateScheduleResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateScheduleResponse) ProtoMessage() {}
|
|
|
|
func (x *UpdateScheduleResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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 UpdateScheduleResponse.ProtoReflect.Descriptor instead.
|
|
func (*UpdateScheduleResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *UpdateScheduleResponse) GetFrontendResponse() *v1.UpdateScheduleResponse {
|
|
if x != nil {
|
|
return x.FrontendResponse
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type PatchScheduleRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Internal namespace ID (UUID).
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
FrontendRequest *v1.PatchScheduleRequest `protobuf:"bytes,2,opt,name=frontend_request,json=frontendRequest,proto3" json:"frontend_request,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *PatchScheduleRequest) Reset() {
|
|
*x = PatchScheduleRequest{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *PatchScheduleRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*PatchScheduleRequest) ProtoMessage() {}
|
|
|
|
func (x *PatchScheduleRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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 PatchScheduleRequest.ProtoReflect.Descriptor instead.
|
|
func (*PatchScheduleRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *PatchScheduleRequest) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *PatchScheduleRequest) GetFrontendRequest() *v1.PatchScheduleRequest {
|
|
if x != nil {
|
|
return x.FrontendRequest
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type PatchScheduleResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
FrontendResponse *v1.PatchScheduleResponse `protobuf:"bytes,1,opt,name=frontend_response,json=frontendResponse,proto3" json:"frontend_response,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *PatchScheduleResponse) Reset() {
|
|
*x = PatchScheduleResponse{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *PatchScheduleResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*PatchScheduleResponse) ProtoMessage() {}
|
|
|
|
func (x *PatchScheduleResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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 PatchScheduleResponse.ProtoReflect.Descriptor instead.
|
|
func (*PatchScheduleResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *PatchScheduleResponse) GetFrontendResponse() *v1.PatchScheduleResponse {
|
|
if x != nil {
|
|
return x.FrontendResponse
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type DeleteScheduleRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Internal namespace ID (UUID).
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
FrontendRequest *v1.DeleteScheduleRequest `protobuf:"bytes,2,opt,name=frontend_request,json=frontendRequest,proto3" json:"frontend_request,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeleteScheduleRequest) Reset() {
|
|
*x = DeleteScheduleRequest{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeleteScheduleRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeleteScheduleRequest) ProtoMessage() {}
|
|
|
|
func (x *DeleteScheduleRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[6]
|
|
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 DeleteScheduleRequest.ProtoReflect.Descriptor instead.
|
|
func (*DeleteScheduleRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *DeleteScheduleRequest) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteScheduleRequest) GetFrontendRequest() *v1.DeleteScheduleRequest {
|
|
if x != nil {
|
|
return x.FrontendRequest
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type DeleteScheduleResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
FrontendResponse *v1.DeleteScheduleResponse `protobuf:"bytes,1,opt,name=frontend_response,json=frontendResponse,proto3" json:"frontend_response,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeleteScheduleResponse) Reset() {
|
|
*x = DeleteScheduleResponse{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeleteScheduleResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeleteScheduleResponse) ProtoMessage() {}
|
|
|
|
func (x *DeleteScheduleResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[7]
|
|
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 DeleteScheduleResponse.ProtoReflect.Descriptor instead.
|
|
func (*DeleteScheduleResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *DeleteScheduleResponse) GetFrontendResponse() *v1.DeleteScheduleResponse {
|
|
if x != nil {
|
|
return x.FrontendResponse
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type DescribeScheduleRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Internal namespace ID (UUID).
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
FrontendRequest *v1.DescribeScheduleRequest `protobuf:"bytes,2,opt,name=frontend_request,json=frontendRequest,proto3" json:"frontend_request,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DescribeScheduleRequest) Reset() {
|
|
*x = DescribeScheduleRequest{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DescribeScheduleRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DescribeScheduleRequest) ProtoMessage() {}
|
|
|
|
func (x *DescribeScheduleRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[8]
|
|
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 DescribeScheduleRequest.ProtoReflect.Descriptor instead.
|
|
func (*DescribeScheduleRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (x *DescribeScheduleRequest) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DescribeScheduleRequest) GetFrontendRequest() *v1.DescribeScheduleRequest {
|
|
if x != nil {
|
|
return x.FrontendRequest
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type DescribeScheduleResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
FrontendResponse *v1.DescribeScheduleResponse `protobuf:"bytes,1,opt,name=frontend_response,json=frontendResponse,proto3" json:"frontend_response,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DescribeScheduleResponse) Reset() {
|
|
*x = DescribeScheduleResponse{}
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DescribeScheduleResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DescribeScheduleResponse) ProtoMessage() {}
|
|
|
|
func (x *DescribeScheduleResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[9]
|
|
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 DescribeScheduleResponse.ProtoReflect.Descriptor instead.
|
|
func (*DescribeScheduleResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *DescribeScheduleResponse) GetFrontendResponse() *v1.DescribeScheduleResponse {
|
|
if x != nil {
|
|
return x.FrontendResponse
|
|
}
|
|
return nil
|
|
}
|
|
|
|
var File_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc = "" +
|
|
"\n" +
|
|
"Ctemporal/server/chasm/lib/scheduler/proto/v1/request_response.proto\x12,temporal.server.chasm.lib.scheduler.proto.v1\x1a6temporal/api/workflowservice/v1/request_response.proto\"\x9d\x01\n" +
|
|
"\x15CreateScheduleRequest\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12a\n" +
|
|
"\x10frontend_request\x18\x02 \x01(\v26.temporal.api.workflowservice.v1.CreateScheduleRequestR\x0ffrontendRequest\"~\n" +
|
|
"\x16CreateScheduleResponse\x12d\n" +
|
|
"\x11frontend_response\x18\x01 \x01(\v27.temporal.api.workflowservice.v1.CreateScheduleResponseR\x10frontendResponse\"\x9d\x01\n" +
|
|
"\x15UpdateScheduleRequest\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12a\n" +
|
|
"\x10frontend_request\x18\x02 \x01(\v26.temporal.api.workflowservice.v1.UpdateScheduleRequestR\x0ffrontendRequest\"~\n" +
|
|
"\x16UpdateScheduleResponse\x12d\n" +
|
|
"\x11frontend_response\x18\x01 \x01(\v27.temporal.api.workflowservice.v1.UpdateScheduleResponseR\x10frontendResponse\"\x9b\x01\n" +
|
|
"\x14PatchScheduleRequest\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12`\n" +
|
|
"\x10frontend_request\x18\x02 \x01(\v25.temporal.api.workflowservice.v1.PatchScheduleRequestR\x0ffrontendRequest\"|\n" +
|
|
"\x15PatchScheduleResponse\x12c\n" +
|
|
"\x11frontend_response\x18\x01 \x01(\v26.temporal.api.workflowservice.v1.PatchScheduleResponseR\x10frontendResponse\"\x9d\x01\n" +
|
|
"\x15DeleteScheduleRequest\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12a\n" +
|
|
"\x10frontend_request\x18\x02 \x01(\v26.temporal.api.workflowservice.v1.DeleteScheduleRequestR\x0ffrontendRequest\"~\n" +
|
|
"\x16DeleteScheduleResponse\x12d\n" +
|
|
"\x11frontend_response\x18\x01 \x01(\v27.temporal.api.workflowservice.v1.DeleteScheduleResponseR\x10frontendResponse\"\xa1\x01\n" +
|
|
"\x17DescribeScheduleRequest\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12c\n" +
|
|
"\x10frontend_request\x18\x02 \x01(\v28.temporal.api.workflowservice.v1.DescribeScheduleRequestR\x0ffrontendRequest\"\x82\x01\n" +
|
|
"\x18DescribeScheduleResponse\x12f\n" +
|
|
"\x11frontend_response\x18\x01 \x01(\v29.temporal.api.workflowservice.v1.DescribeScheduleResponseR\x10frontendResponseBGZEgo.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb;schedulerpbb\x06proto3"
|
|
|
|
var (
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescOnce sync.Once
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc)))
|
|
})
|
|
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
|
|
var file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_goTypes = []any{
|
|
(*CreateScheduleRequest)(nil), // 0: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleRequest
|
|
(*CreateScheduleResponse)(nil), // 1: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleResponse
|
|
(*UpdateScheduleRequest)(nil), // 2: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleRequest
|
|
(*UpdateScheduleResponse)(nil), // 3: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleResponse
|
|
(*PatchScheduleRequest)(nil), // 4: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleRequest
|
|
(*PatchScheduleResponse)(nil), // 5: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleResponse
|
|
(*DeleteScheduleRequest)(nil), // 6: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleRequest
|
|
(*DeleteScheduleResponse)(nil), // 7: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleResponse
|
|
(*DescribeScheduleRequest)(nil), // 8: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleRequest
|
|
(*DescribeScheduleResponse)(nil), // 9: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleResponse
|
|
(*v1.CreateScheduleRequest)(nil), // 10: temporal.api.workflowservice.v1.CreateScheduleRequest
|
|
(*v1.CreateScheduleResponse)(nil), // 11: temporal.api.workflowservice.v1.CreateScheduleResponse
|
|
(*v1.UpdateScheduleRequest)(nil), // 12: temporal.api.workflowservice.v1.UpdateScheduleRequest
|
|
(*v1.UpdateScheduleResponse)(nil), // 13: temporal.api.workflowservice.v1.UpdateScheduleResponse
|
|
(*v1.PatchScheduleRequest)(nil), // 14: temporal.api.workflowservice.v1.PatchScheduleRequest
|
|
(*v1.PatchScheduleResponse)(nil), // 15: temporal.api.workflowservice.v1.PatchScheduleResponse
|
|
(*v1.DeleteScheduleRequest)(nil), // 16: temporal.api.workflowservice.v1.DeleteScheduleRequest
|
|
(*v1.DeleteScheduleResponse)(nil), // 17: temporal.api.workflowservice.v1.DeleteScheduleResponse
|
|
(*v1.DescribeScheduleRequest)(nil), // 18: temporal.api.workflowservice.v1.DescribeScheduleRequest
|
|
(*v1.DescribeScheduleResponse)(nil), // 19: temporal.api.workflowservice.v1.DescribeScheduleResponse
|
|
}
|
|
var file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_depIdxs = []int32{
|
|
10, // 0: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.CreateScheduleRequest
|
|
11, // 1: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.CreateScheduleResponse
|
|
12, // 2: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.UpdateScheduleRequest
|
|
13, // 3: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.UpdateScheduleResponse
|
|
14, // 4: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.PatchScheduleRequest
|
|
15, // 5: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.PatchScheduleResponse
|
|
16, // 6: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.DeleteScheduleRequest
|
|
17, // 7: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.DeleteScheduleResponse
|
|
18, // 8: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.DescribeScheduleRequest
|
|
19, // 9: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.DescribeScheduleResponse
|
|
10, // [10:10] is the sub-list for method output_type
|
|
10, // [10:10] is the sub-list for method input_type
|
|
10, // [10:10] is the sub-list for extension type_name
|
|
10, // [10:10] is the sub-list for extension extendee
|
|
0, // [0:10] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init() }
|
|
func file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init() {
|
|
if File_temporal_server_chasm_lib_scheduler_proto_v1_request_response_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_scheduler_proto_v1_request_response_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 10,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_depIdxs,
|
|
MessageInfos: file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto = out.File
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_goTypes = nil
|
|
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_depIdxs = nil
|
|
}
|