Files
tasks/chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go
zeekay 5a601d081b rebrand: go.temporal.io/server -> github.com/hanzoai/tasks
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).
2026-03-19 10:36:40 -07:00

824 lines
34 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
}
type ListScheduleMatchingTimesRequest 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.ListScheduleMatchingTimesRequest `protobuf:"bytes,2,opt,name=frontend_request,json=frontendRequest,proto3" json:"frontend_request,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ListScheduleMatchingTimesRequest) Reset() {
*x = ListScheduleMatchingTimesRequest{}
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ListScheduleMatchingTimesRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListScheduleMatchingTimesRequest) ProtoMessage() {}
func (x *ListScheduleMatchingTimesRequest) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[10]
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 ListScheduleMatchingTimesRequest.ProtoReflect.Descriptor instead.
func (*ListScheduleMatchingTimesRequest) Descriptor() ([]byte, []int) {
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{10}
}
func (x *ListScheduleMatchingTimesRequest) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *ListScheduleMatchingTimesRequest) GetFrontendRequest() *v1.ListScheduleMatchingTimesRequest {
if x != nil {
return x.FrontendRequest
}
return nil
}
type ListScheduleMatchingTimesResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
FrontendResponse *v1.ListScheduleMatchingTimesResponse `protobuf:"bytes,1,opt,name=frontend_response,json=frontendResponse,proto3" json:"frontend_response,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ListScheduleMatchingTimesResponse) Reset() {
*x = ListScheduleMatchingTimesResponse{}
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ListScheduleMatchingTimesResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ListScheduleMatchingTimesResponse) ProtoMessage() {}
func (x *ListScheduleMatchingTimesResponse) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[11]
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 ListScheduleMatchingTimesResponse.ProtoReflect.Descriptor instead.
func (*ListScheduleMatchingTimesResponse) Descriptor() ([]byte, []int) {
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{11}
}
func (x *ListScheduleMatchingTimesResponse) GetFrontendResponse() *v1.ListScheduleMatchingTimesResponse {
if x != nil {
return x.FrontendResponse
}
return nil
}
type CreateFromMigrationStateRequest 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"`
State *SchedulerMigrationState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateFromMigrationStateRequest) Reset() {
*x = CreateFromMigrationStateRequest{}
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateFromMigrationStateRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateFromMigrationStateRequest) ProtoMessage() {}
func (x *CreateFromMigrationStateRequest) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[12]
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 CreateFromMigrationStateRequest.ProtoReflect.Descriptor instead.
func (*CreateFromMigrationStateRequest) Descriptor() ([]byte, []int) {
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{12}
}
func (x *CreateFromMigrationStateRequest) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *CreateFromMigrationStateRequest) GetState() *SchedulerMigrationState {
if x != nil {
return x.State
}
return nil
}
type CreateFromMigrationStateResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateFromMigrationStateResponse) Reset() {
*x = CreateFromMigrationStateResponse{}
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateFromMigrationStateResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateFromMigrationStateResponse) ProtoMessage() {}
func (x *CreateFromMigrationStateResponse) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[13]
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 CreateFromMigrationStateResponse.ProtoReflect.Descriptor instead.
func (*CreateFromMigrationStateResponse) Descriptor() ([]byte, []int) {
return file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDescGZIP(), []int{13}
}
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\x1a:temporal/server/chasm/lib/scheduler/proto/v1/message.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\x10frontendResponse\"\xb3\x01\n" +
" ListScheduleMatchingTimesRequest\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12l\n" +
"\x10frontend_request\x18\x02 \x01(\v2A.temporal.api.workflowservice.v1.ListScheduleMatchingTimesRequestR\x0ffrontendRequest\"\x94\x01\n" +
"!ListScheduleMatchingTimesResponse\x12o\n" +
"\x11frontend_response\x18\x01 \x01(\v2B.temporal.api.workflowservice.v1.ListScheduleMatchingTimesResponseR\x10frontendResponse\"\xa1\x01\n" +
"\x1fCreateFromMigrationStateRequest\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12[\n" +
"\x05state\x18\x02 \x01(\v2E.temporal.server.chasm.lib.scheduler.proto.v1.SchedulerMigrationStateR\x05state\"\"\n" +
" CreateFromMigrationStateResponseBGZEgithub.com/hanzoai/tasks/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, 14)
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
(*ListScheduleMatchingTimesRequest)(nil), // 10: temporal.server.chasm.lib.scheduler.proto.v1.ListScheduleMatchingTimesRequest
(*ListScheduleMatchingTimesResponse)(nil), // 11: temporal.server.chasm.lib.scheduler.proto.v1.ListScheduleMatchingTimesResponse
(*CreateFromMigrationStateRequest)(nil), // 12: temporal.server.chasm.lib.scheduler.proto.v1.CreateFromMigrationStateRequest
(*CreateFromMigrationStateResponse)(nil), // 13: temporal.server.chasm.lib.scheduler.proto.v1.CreateFromMigrationStateResponse
(*v1.CreateScheduleRequest)(nil), // 14: temporal.api.workflowservice.v1.CreateScheduleRequest
(*v1.CreateScheduleResponse)(nil), // 15: temporal.api.workflowservice.v1.CreateScheduleResponse
(*v1.UpdateScheduleRequest)(nil), // 16: temporal.api.workflowservice.v1.UpdateScheduleRequest
(*v1.UpdateScheduleResponse)(nil), // 17: temporal.api.workflowservice.v1.UpdateScheduleResponse
(*v1.PatchScheduleRequest)(nil), // 18: temporal.api.workflowservice.v1.PatchScheduleRequest
(*v1.PatchScheduleResponse)(nil), // 19: temporal.api.workflowservice.v1.PatchScheduleResponse
(*v1.DeleteScheduleRequest)(nil), // 20: temporal.api.workflowservice.v1.DeleteScheduleRequest
(*v1.DeleteScheduleResponse)(nil), // 21: temporal.api.workflowservice.v1.DeleteScheduleResponse
(*v1.DescribeScheduleRequest)(nil), // 22: temporal.api.workflowservice.v1.DescribeScheduleRequest
(*v1.DescribeScheduleResponse)(nil), // 23: temporal.api.workflowservice.v1.DescribeScheduleResponse
(*v1.ListScheduleMatchingTimesRequest)(nil), // 24: temporal.api.workflowservice.v1.ListScheduleMatchingTimesRequest
(*v1.ListScheduleMatchingTimesResponse)(nil), // 25: temporal.api.workflowservice.v1.ListScheduleMatchingTimesResponse
(*SchedulerMigrationState)(nil), // 26: temporal.server.chasm.lib.scheduler.proto.v1.SchedulerMigrationState
}
var file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_depIdxs = []int32{
14, // 0: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.CreateScheduleRequest
15, // 1: temporal.server.chasm.lib.scheduler.proto.v1.CreateScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.CreateScheduleResponse
16, // 2: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.UpdateScheduleRequest
17, // 3: temporal.server.chasm.lib.scheduler.proto.v1.UpdateScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.UpdateScheduleResponse
18, // 4: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.PatchScheduleRequest
19, // 5: temporal.server.chasm.lib.scheduler.proto.v1.PatchScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.PatchScheduleResponse
20, // 6: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.DeleteScheduleRequest
21, // 7: temporal.server.chasm.lib.scheduler.proto.v1.DeleteScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.DeleteScheduleResponse
22, // 8: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.DescribeScheduleRequest
23, // 9: temporal.server.chasm.lib.scheduler.proto.v1.DescribeScheduleResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.DescribeScheduleResponse
24, // 10: temporal.server.chasm.lib.scheduler.proto.v1.ListScheduleMatchingTimesRequest.frontend_request:type_name -> temporal.api.workflowservice.v1.ListScheduleMatchingTimesRequest
25, // 11: temporal.server.chasm.lib.scheduler.proto.v1.ListScheduleMatchingTimesResponse.frontend_response:type_name -> temporal.api.workflowservice.v1.ListScheduleMatchingTimesResponse
26, // 12: temporal.server.chasm.lib.scheduler.proto.v1.CreateFromMigrationStateRequest.state:type_name -> temporal.server.chasm.lib.scheduler.proto.v1.SchedulerMigrationState
13, // [13:13] is the sub-list for method output_type
13, // [13:13] is the sub-list for method input_type
13, // [13:13] is the sub-list for extension type_name
13, // [13:13] is the sub-list for extension extendee
0, // [0:13] 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
}
file_temporal_server_chasm_lib_scheduler_proto_v1_message_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_request_response_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc)),
NumEnums: 0,
NumMessages: 14,
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
}