From 7f96f8a14819e41bad5ecd93bad8de485f707bb0 Mon Sep 17 00:00:00 2001 From: "abhishek.jha" Date: Wed, 25 Feb 2026 13:14:17 -0800 Subject: [PATCH 1/5] feat: [Cadence Schedules] Add schedule API request/response types --- common/types/schedule_service.go | 271 +++++++++++++++++++++++++++++++ 1 file changed, 271 insertions(+) create mode 100644 common/types/schedule_service.go diff --git a/common/types/schedule_service.go b/common/types/schedule_service.go new file mode 100644 index 00000000000..64e66a7a309 --- /dev/null +++ b/common/types/schedule_service.go @@ -0,0 +1,271 @@ +// Copyright (c) 2024 Uber Technologies, Inc. +// +// Permission is hereby granted, free of charge, to any person obtaining a copy +// of this software and associated documentation files (the "Software"), to deal +// in the Software without restriction, including without limitation the rights +// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +// copies of the Software, and to permit persons to whom the Software is +// furnished to do so, subject to the following conditions: +// +// The above copyright notice and this permission notice shall be included in +// all copies or substantial portions of the Software. +// +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +// THE SOFTWARE. + +package types + +import "time" + +// --- Request/Response Types for ScheduleService --- + +// ScheduleListEntry represents a single schedule in a list response. +// Contains only data available from the visibility store. +type ScheduleListEntry struct { + ScheduleID string `json:"scheduleId,omitempty"` + WorkflowType *WorkflowType `json:"workflowType,omitempty"` + State *ScheduleState `json:"state,omitempty"` + CronExpression string `json:"cronExpression,omitempty"` +} + +// CreateScheduleRequest is the request to create a new schedule. +type CreateScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` + Memo *Memo `json:"-"` + SearchAttributes *SearchAttributes `json:"-"` +} + +func (v *CreateScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *CreateScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +// CreateScheduleResponse is the response for creating a schedule. +type CreateScheduleResponse struct{} + +// DescribeScheduleRequest is the request to describe a schedule. +type DescribeScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` +} + +func (v *DescribeScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *DescribeScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +// DescribeScheduleResponse is the response for describing a schedule. +type DescribeScheduleResponse struct { + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` + State *ScheduleState `json:"state,omitempty"` + Info *ScheduleInfo `json:"info,omitempty"` +} + +// ListSchedulesRequest is the request to list schedules in a domain. +type ListSchedulesRequest struct { + Domain string `json:"domain,omitempty"` + PageSize int32 `json:"pageSize,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` +} + +func (v *ListSchedulesRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *ListSchedulesRequest) GetPageSize() (o int32) { + if v != nil { + return v.PageSize + } + return +} + +// ListSchedulesResponse is the response for listing schedules. +type ListSchedulesResponse struct { + Schedules []ScheduleListEntry `json:"schedules,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` +} + +// DeleteScheduleRequest is the request to delete a schedule. +type DeleteScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` +} + +func (v *DeleteScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *DeleteScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +// DeleteScheduleResponse is the response for deleting a schedule. +type DeleteScheduleResponse struct{} + +// PauseScheduleRequest is the request to pause a schedule. +type PauseScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` +} + +func (v *PauseScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *PauseScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +func (v *PauseScheduleRequest) GetReason() (o string) { + if v != nil { + return v.Reason + } + return +} + +// PauseScheduleResponse is the response for pausing a schedule. +type PauseScheduleResponse struct{} + +// UnpauseScheduleRequest is the request to resume a paused schedule. +type UnpauseScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` + CatchUpPolicy *ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` +} + +func (v *UnpauseScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *UnpauseScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +func (v *UnpauseScheduleRequest) GetReason() (o string) { + if v != nil { + return v.Reason + } + return +} + +func (v *UnpauseScheduleRequest) GetCatchUpPolicy() (o ScheduleCatchUpPolicy) { + if v != nil && v.CatchUpPolicy != nil { + return *v.CatchUpPolicy + } + return +} + +// UnpauseScheduleResponse is the response for resuming a schedule. +type UnpauseScheduleResponse struct{} + +// BackfillScheduleRequest is the request to trigger a backfill. +type BackfillScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + StartTime time.Time `json:"startTime,omitempty"` + EndTime time.Time `json:"endTime,omitempty"` + OverlapPolicy ScheduleOverlapPolicy `json:"overlapPolicy,omitempty"` + BackfillID string `json:"backfillId,omitempty"` +} + +func (v *BackfillScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *BackfillScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +func (v *BackfillScheduleRequest) GetBackfillID() (o string) { + if v != nil { + return v.BackfillID + } + return +} + +// BackfillScheduleResponse is the response for triggering a backfill. +type BackfillScheduleResponse struct{} + +// UpdateScheduleRequest is the request to update a schedule. +type UpdateScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` +} + +func (v *UpdateScheduleRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *UpdateScheduleRequest) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +// UpdateScheduleResponse is the response for updating a schedule. +type UpdateScheduleResponse struct{} From 1c7db22923c91b9ea85f75843de627bcc369c0e8 Mon Sep 17 00:00:00 2001 From: "abhishek.jha" Date: Wed, 25 Feb 2026 13:18:38 -0800 Subject: [PATCH 2/5] feat: [Cadence Schedules] Add schedule API request/response types Signed-off-by: abhishek.jha --- common/types/schedule_service.go | 238 +++++++++++++++++++++----- common/types/schedule_service_test.go | 161 +++++++++++++++++ 2 files changed, 360 insertions(+), 39 deletions(-) create mode 100644 common/types/schedule_service_test.go diff --git a/common/types/schedule_service.go b/common/types/schedule_service.go index 64e66a7a309..fe6eef3579e 100644 --- a/common/types/schedule_service.go +++ b/common/types/schedule_service.go @@ -22,10 +22,9 @@ package types import "time" -// --- Request/Response Types for ScheduleService --- +// --- Request/Response Types for Schedule APIs --- // ScheduleListEntry represents a single schedule in a list response. -// Contains only data available from the visibility store. type ScheduleListEntry struct { ScheduleID string `json:"scheduleId,omitempty"` WorkflowType *WorkflowType `json:"workflowType,omitempty"` @@ -33,6 +32,34 @@ type ScheduleListEntry struct { CronExpression string `json:"cronExpression,omitempty"` } +func (v *ScheduleListEntry) GetScheduleID() (o string) { + if v != nil { + return v.ScheduleID + } + return +} + +func (v *ScheduleListEntry) GetWorkflowType() *WorkflowType { + if v != nil { + return v.WorkflowType + } + return nil +} + +func (v *ScheduleListEntry) GetState() *ScheduleState { + if v != nil { + return v.State + } + return nil +} + +func (v *ScheduleListEntry) GetCronExpression() (o string) { + if v != nil { + return v.CronExpression + } + return +} + // CreateScheduleRequest is the request to create a new schedule. type CreateScheduleRequest struct { Domain string `json:"domain,omitempty"` @@ -58,6 +85,41 @@ func (v *CreateScheduleRequest) GetScheduleID() (o string) { return } +func (v *CreateScheduleRequest) GetSpec() *ScheduleSpec { + if v != nil { + return v.Spec + } + return nil +} + +func (v *CreateScheduleRequest) GetAction() *ScheduleAction { + if v != nil { + return v.Action + } + return nil +} + +func (v *CreateScheduleRequest) GetPolicies() *SchedulePolicies { + if v != nil { + return v.Policies + } + return nil +} + +func (v *CreateScheduleRequest) GetMemo() *Memo { + if v != nil { + return v.Memo + } + return nil +} + +func (v *CreateScheduleRequest) GetSearchAttributes() *SearchAttributes { + if v != nil { + return v.SearchAttributes + } + return nil +} + // CreateScheduleResponse is the response for creating a schedule. type CreateScheduleResponse struct{} @@ -90,33 +152,88 @@ type DescribeScheduleResponse struct { Info *ScheduleInfo `json:"info,omitempty"` } -// ListSchedulesRequest is the request to list schedules in a domain. -type ListSchedulesRequest struct { - Domain string `json:"domain,omitempty"` - PageSize int32 `json:"pageSize,omitempty"` - NextPageToken []byte `json:"nextPageToken,omitempty"` +func (v *DescribeScheduleResponse) GetSpec() *ScheduleSpec { + if v != nil { + return v.Spec + } + return nil } -func (v *ListSchedulesRequest) GetDomain() (o string) { +func (v *DescribeScheduleResponse) GetAction() *ScheduleAction { + if v != nil { + return v.Action + } + return nil +} + +func (v *DescribeScheduleResponse) GetPolicies() *SchedulePolicies { + if v != nil { + return v.Policies + } + return nil +} + +func (v *DescribeScheduleResponse) GetState() *ScheduleState { + if v != nil { + return v.State + } + return nil +} + +func (v *DescribeScheduleResponse) GetInfo() *ScheduleInfo { + if v != nil { + return v.Info + } + return nil +} + +// UpdateScheduleRequest is the request to update a schedule. +type UpdateScheduleRequest struct { + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` +} + +func (v *UpdateScheduleRequest) GetDomain() (o string) { if v != nil { return v.Domain } return } -func (v *ListSchedulesRequest) GetPageSize() (o int32) { +func (v *UpdateScheduleRequest) GetScheduleID() (o string) { if v != nil { - return v.PageSize + return v.ScheduleID } return } -// ListSchedulesResponse is the response for listing schedules. -type ListSchedulesResponse struct { - Schedules []ScheduleListEntry `json:"schedules,omitempty"` - NextPageToken []byte `json:"nextPageToken,omitempty"` +func (v *UpdateScheduleRequest) GetSpec() *ScheduleSpec { + if v != nil { + return v.Spec + } + return nil +} + +func (v *UpdateScheduleRequest) GetAction() *ScheduleAction { + if v != nil { + return v.Action + } + return nil } +func (v *UpdateScheduleRequest) GetPolicies() *SchedulePolicies { + if v != nil { + return v.Policies + } + return nil +} + +// UpdateScheduleResponse is the response for updating a schedule. +type UpdateScheduleResponse struct{} + // DeleteScheduleRequest is the request to delete a schedule. type DeleteScheduleRequest struct { Domain string `json:"domain,omitempty"` @@ -173,10 +290,10 @@ type PauseScheduleResponse struct{} // UnpauseScheduleRequest is the request to resume a paused schedule. type UnpauseScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Reason string `json:"reason,omitempty"` - CatchUpPolicy *ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` + CatchUpPolicy ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` } func (v *UnpauseScheduleRequest) GetDomain() (o string) { @@ -201,8 +318,8 @@ func (v *UnpauseScheduleRequest) GetReason() (o string) { } func (v *UnpauseScheduleRequest) GetCatchUpPolicy() (o ScheduleCatchUpPolicy) { - if v != nil && v.CatchUpPolicy != nil { - return *v.CatchUpPolicy + if v != nil { + return v.CatchUpPolicy } return } @@ -210,7 +327,55 @@ func (v *UnpauseScheduleRequest) GetCatchUpPolicy() (o ScheduleCatchUpPolicy) { // UnpauseScheduleResponse is the response for resuming a schedule. type UnpauseScheduleResponse struct{} -// BackfillScheduleRequest is the request to trigger a backfill. +// ListSchedulesRequest is the request to list schedules in a domain. +type ListSchedulesRequest struct { + Domain string `json:"domain,omitempty"` + PageSize int32 `json:"pageSize,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` +} + +func (v *ListSchedulesRequest) GetDomain() (o string) { + if v != nil { + return v.Domain + } + return +} + +func (v *ListSchedulesRequest) GetPageSize() (o int32) { + if v != nil { + return v.PageSize + } + return +} + +func (v *ListSchedulesRequest) GetNextPageToken() (o []byte) { + if v != nil { + return v.NextPageToken + } + return +} + +// ListSchedulesResponse is the response for listing schedules. +type ListSchedulesResponse struct { + Schedules []ScheduleListEntry `json:"schedules,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` +} + +func (v *ListSchedulesResponse) GetSchedules() (o []ScheduleListEntry) { + if v != nil { + return v.Schedules + } + return +} + +func (v *ListSchedulesResponse) GetNextPageToken() (o []byte) { + if v != nil { + return v.NextPageToken + } + return +} + +// BackfillScheduleRequest is the request to trigger a backfill for a time range. type BackfillScheduleRequest struct { Domain string `json:"domain,omitempty"` ScheduleID string `json:"scheduleId,omitempty"` @@ -234,38 +399,33 @@ func (v *BackfillScheduleRequest) GetScheduleID() (o string) { return } -func (v *BackfillScheduleRequest) GetBackfillID() (o string) { +func (v *BackfillScheduleRequest) GetStartTime() (o time.Time) { if v != nil { - return v.BackfillID + return v.StartTime } return } -// BackfillScheduleResponse is the response for triggering a backfill. -type BackfillScheduleResponse struct{} - -// UpdateScheduleRequest is the request to update a schedule. -type UpdateScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` +func (v *BackfillScheduleRequest) GetEndTime() (o time.Time) { + if v != nil { + return v.EndTime + } + return } -func (v *UpdateScheduleRequest) GetDomain() (o string) { +func (v *BackfillScheduleRequest) GetOverlapPolicy() (o ScheduleOverlapPolicy) { if v != nil { - return v.Domain + return v.OverlapPolicy } return } -func (v *UpdateScheduleRequest) GetScheduleID() (o string) { +func (v *BackfillScheduleRequest) GetBackfillID() (o string) { if v != nil { - return v.ScheduleID + return v.BackfillID } return } -// UpdateScheduleResponse is the response for updating a schedule. -type UpdateScheduleResponse struct{} +// BackfillScheduleResponse is the response for triggering a backfill. +type BackfillScheduleResponse struct{} diff --git a/common/types/schedule_service_test.go b/common/types/schedule_service_test.go new file mode 100644 index 00000000000..f7a62b91a6a --- /dev/null +++ b/common/types/schedule_service_test.go @@ -0,0 +1,161 @@ +// Copyright (c) 2024 Uber Technologies, Inc. +// +// Permission is hereby granted, free of charge, to any person obtaining a copy +// of this software and associated documentation files (the "Software"), to deal +// in the Software without restriction, including without limitation the rights +// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +// copies of the Software, and to permit persons to whom the Software is +// furnished to do so, subject to the following conditions: +// +// The above copyright notice and this permission notice shall be included in +// all copies or substantial portions of the Software. +// +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +// THE SOFTWARE. + +package types + +import ( + "testing" + "time" + + "github.com/stretchr/testify/assert" +) + +func TestScheduleListEntry_NilGetters(t *testing.T) { + var v *ScheduleListEntry + assert.Equal(t, "", v.GetScheduleID()) + assert.Nil(t, v.GetWorkflowType()) + assert.Nil(t, v.GetState()) + assert.Equal(t, "", v.GetCronExpression()) +} + +func TestScheduleListEntry_Getters(t *testing.T) { + wt := &WorkflowType{Name: "test-wf"} + st := &ScheduleState{Paused: true} + v := &ScheduleListEntry{ + ScheduleID: "sched-1", + WorkflowType: wt, + State: st, + CronExpression: "*/5 * * * *", + } + assert.Equal(t, "sched-1", v.GetScheduleID()) + assert.Equal(t, wt, v.GetWorkflowType()) + assert.Equal(t, st, v.GetState()) + assert.Equal(t, "*/5 * * * *", v.GetCronExpression()) +} + +func TestCreateScheduleRequest_NilGetters(t *testing.T) { + var v *CreateScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) + assert.Nil(t, v.GetSpec()) + assert.Nil(t, v.GetAction()) + assert.Nil(t, v.GetPolicies()) + assert.Nil(t, v.GetMemo()) + assert.Nil(t, v.GetSearchAttributes()) +} + +func TestDescribeScheduleRequest_NilGetters(t *testing.T) { + var v *DescribeScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) +} + +func TestDescribeScheduleResponse_NilGetters(t *testing.T) { + var v *DescribeScheduleResponse + assert.Nil(t, v.GetSpec()) + assert.Nil(t, v.GetAction()) + assert.Nil(t, v.GetPolicies()) + assert.Nil(t, v.GetState()) + assert.Nil(t, v.GetInfo()) +} + +func TestUpdateScheduleRequest_NilGetters(t *testing.T) { + var v *UpdateScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) + assert.Nil(t, v.GetSpec()) + assert.Nil(t, v.GetAction()) + assert.Nil(t, v.GetPolicies()) +} + +func TestDeleteScheduleRequest_NilGetters(t *testing.T) { + var v *DeleteScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) +} + +func TestPauseScheduleRequest_NilGetters(t *testing.T) { + var v *PauseScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) + assert.Equal(t, "", v.GetReason()) +} + +func TestUnpauseScheduleRequest_NilGetters(t *testing.T) { + var v *UnpauseScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) + assert.Equal(t, "", v.GetReason()) + assert.Equal(t, ScheduleCatchUpPolicyInvalid, v.GetCatchUpPolicy()) +} + +func TestUnpauseScheduleRequest_Getters(t *testing.T) { + v := &UnpauseScheduleRequest{ + Domain: "test-domain", + ScheduleID: "sched-1", + Reason: "resuming", + CatchUpPolicy: ScheduleCatchUpPolicyAll, + } + assert.Equal(t, "test-domain", v.GetDomain()) + assert.Equal(t, "sched-1", v.GetScheduleID()) + assert.Equal(t, "resuming", v.GetReason()) + assert.Equal(t, ScheduleCatchUpPolicyAll, v.GetCatchUpPolicy()) +} + +func TestListSchedulesRequest_NilGetters(t *testing.T) { + var v *ListSchedulesRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, int32(0), v.GetPageSize()) + assert.Nil(t, v.GetNextPageToken()) +} + +func TestListSchedulesResponse_NilGetters(t *testing.T) { + var v *ListSchedulesResponse + assert.Nil(t, v.GetSchedules()) + assert.Nil(t, v.GetNextPageToken()) +} + +func TestBackfillScheduleRequest_NilGetters(t *testing.T) { + var v *BackfillScheduleRequest + assert.Equal(t, "", v.GetDomain()) + assert.Equal(t, "", v.GetScheduleID()) + assert.Equal(t, time.Time{}, v.GetStartTime()) + assert.Equal(t, time.Time{}, v.GetEndTime()) + assert.Equal(t, ScheduleOverlapPolicyInvalid, v.GetOverlapPolicy()) + assert.Equal(t, "", v.GetBackfillID()) +} + +func TestBackfillScheduleRequest_Getters(t *testing.T) { + now := time.Now().Truncate(time.Second) + v := &BackfillScheduleRequest{ + Domain: "test-domain", + ScheduleID: "sched-1", + StartTime: now, + EndTime: now.Add(time.Hour), + OverlapPolicy: ScheduleOverlapPolicyBuffer, + BackfillID: "bf-1", + } + assert.Equal(t, "test-domain", v.GetDomain()) + assert.Equal(t, "sched-1", v.GetScheduleID()) + assert.Equal(t, now, v.GetStartTime()) + assert.Equal(t, now.Add(time.Hour), v.GetEndTime()) + assert.Equal(t, ScheduleOverlapPolicyBuffer, v.GetOverlapPolicy()) + assert.Equal(t, "bf-1", v.GetBackfillID()) +} From f8779c565e93d9608b1255e3fe100fad8916aa73 Mon Sep 17 00:00:00 2001 From: Gitar Date: Wed, 25 Feb 2026 21:51:41 +0000 Subject: [PATCH 3/5] fix: resolve CI failures and address code review findings Co-authored-by: abhishekj720 --- common/types/schedule_service.go | 430 +++++++++++++++---------------- 1 file changed, 215 insertions(+), 215 deletions(-) diff --git a/common/types/schedule_service.go b/common/types/schedule_service.go index fe6eef3579e..2440c697a26 100644 --- a/common/types/schedule_service.go +++ b/common/types/schedule_service.go @@ -26,98 +26,98 @@ import "time" // ScheduleListEntry represents a single schedule in a list response. type ScheduleListEntry struct { - ScheduleID string `json:"scheduleId,omitempty"` - WorkflowType *WorkflowType `json:"workflowType,omitempty"` - State *ScheduleState `json:"state,omitempty"` - CronExpression string `json:"cronExpression,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + WorkflowType *WorkflowType `json:"workflowType,omitempty"` + State *ScheduleState `json:"state,omitempty"` + CronExpression string `json:"cronExpression,omitempty"` } func (v *ScheduleListEntry) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *ScheduleListEntry) GetWorkflowType() *WorkflowType { - if v != nil { - return v.WorkflowType - } - return nil + if v != nil { + return v.WorkflowType + } + return nil } func (v *ScheduleListEntry) GetState() *ScheduleState { - if v != nil { - return v.State - } - return nil + if v != nil { + return v.State + } + return nil } func (v *ScheduleListEntry) GetCronExpression() (o string) { - if v != nil { - return v.CronExpression - } - return + if v != nil { + return v.CronExpression + } + return } // CreateScheduleRequest is the request to create a new schedule. type CreateScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` - Memo *Memo `json:"-"` - SearchAttributes *SearchAttributes `json:"-"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` + Memo *Memo `json:"-"` // Filtering PII + SearchAttributes *SearchAttributes `json:"-"` // Filtering PII } func (v *CreateScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *CreateScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *CreateScheduleRequest) GetSpec() *ScheduleSpec { - if v != nil { - return v.Spec - } - return nil + if v != nil { + return v.Spec + } + return nil } func (v *CreateScheduleRequest) GetAction() *ScheduleAction { - if v != nil { - return v.Action - } - return nil + if v != nil { + return v.Action + } + return nil } func (v *CreateScheduleRequest) GetPolicies() *SchedulePolicies { - if v != nil { - return v.Policies - } - return nil + if v != nil { + return v.Policies + } + return nil } func (v *CreateScheduleRequest) GetMemo() *Memo { - if v != nil { - return v.Memo - } - return nil + if v != nil { + return v.Memo + } + return nil } func (v *CreateScheduleRequest) GetSearchAttributes() *SearchAttributes { - if v != nil { - return v.SearchAttributes - } - return nil + if v != nil { + return v.SearchAttributes + } + return nil } // CreateScheduleResponse is the response for creating a schedule. @@ -125,110 +125,110 @@ type CreateScheduleResponse struct{} // DescribeScheduleRequest is the request to describe a schedule. type DescribeScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` } func (v *DescribeScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *DescribeScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } // DescribeScheduleResponse is the response for describing a schedule. type DescribeScheduleResponse struct { - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` - State *ScheduleState `json:"state,omitempty"` - Info *ScheduleInfo `json:"info,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` + State *ScheduleState `json:"state,omitempty"` + Info *ScheduleInfo `json:"info,omitempty"` } func (v *DescribeScheduleResponse) GetSpec() *ScheduleSpec { - if v != nil { - return v.Spec - } - return nil + if v != nil { + return v.Spec + } + return nil } func (v *DescribeScheduleResponse) GetAction() *ScheduleAction { - if v != nil { - return v.Action - } - return nil + if v != nil { + return v.Action + } + return nil } func (v *DescribeScheduleResponse) GetPolicies() *SchedulePolicies { - if v != nil { - return v.Policies - } - return nil + if v != nil { + return v.Policies + } + return nil } func (v *DescribeScheduleResponse) GetState() *ScheduleState { - if v != nil { - return v.State - } - return nil + if v != nil { + return v.State + } + return nil } func (v *DescribeScheduleResponse) GetInfo() *ScheduleInfo { - if v != nil { - return v.Info - } - return nil + if v != nil { + return v.Info + } + return nil } // UpdateScheduleRequest is the request to update a schedule. type UpdateScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` } func (v *UpdateScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *UpdateScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *UpdateScheduleRequest) GetSpec() *ScheduleSpec { - if v != nil { - return v.Spec - } - return nil + if v != nil { + return v.Spec + } + return nil } func (v *UpdateScheduleRequest) GetAction() *ScheduleAction { - if v != nil { - return v.Action - } - return nil + if v != nil { + return v.Action + } + return nil } func (v *UpdateScheduleRequest) GetPolicies() *SchedulePolicies { - if v != nil { - return v.Policies - } - return nil + if v != nil { + return v.Policies + } + return nil } // UpdateScheduleResponse is the response for updating a schedule. @@ -236,22 +236,22 @@ type UpdateScheduleResponse struct{} // DeleteScheduleRequest is the request to delete a schedule. type DeleteScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` } func (v *DeleteScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *DeleteScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } // DeleteScheduleResponse is the response for deleting a schedule. @@ -259,30 +259,30 @@ type DeleteScheduleResponse struct{} // PauseScheduleRequest is the request to pause a schedule. type PauseScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Reason string `json:"reason,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` } func (v *PauseScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *PauseScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *PauseScheduleRequest) GetReason() (o string) { - if v != nil { - return v.Reason - } - return + if v != nil { + return v.Reason + } + return } // PauseScheduleResponse is the response for pausing a schedule. @@ -290,38 +290,38 @@ type PauseScheduleResponse struct{} // UnpauseScheduleRequest is the request to resume a paused schedule. type UnpauseScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Reason string `json:"reason,omitempty"` - CatchUpPolicy ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` + CatchUpPolicy ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` } func (v *UnpauseScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *UnpauseScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *UnpauseScheduleRequest) GetReason() (o string) { - if v != nil { - return v.Reason - } - return + if v != nil { + return v.Reason + } + return } func (v *UnpauseScheduleRequest) GetCatchUpPolicy() (o ScheduleCatchUpPolicy) { - if v != nil { - return v.CatchUpPolicy - } - return + if v != nil { + return v.CatchUpPolicy + } + return } // UnpauseScheduleResponse is the response for resuming a schedule. @@ -329,102 +329,102 @@ type UnpauseScheduleResponse struct{} // ListSchedulesRequest is the request to list schedules in a domain. type ListSchedulesRequest struct { - Domain string `json:"domain,omitempty"` - PageSize int32 `json:"pageSize,omitempty"` - NextPageToken []byte `json:"nextPageToken,omitempty"` + Domain string `json:"domain,omitempty"` + PageSize int32 `json:"pageSize,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` } func (v *ListSchedulesRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *ListSchedulesRequest) GetPageSize() (o int32) { - if v != nil { - return v.PageSize - } - return + if v != nil { + return v.PageSize + } + return } func (v *ListSchedulesRequest) GetNextPageToken() (o []byte) { - if v != nil { - return v.NextPageToken - } - return + if v != nil { + return v.NextPageToken + } + return } // ListSchedulesResponse is the response for listing schedules. type ListSchedulesResponse struct { - Schedules []ScheduleListEntry `json:"schedules,omitempty"` - NextPageToken []byte `json:"nextPageToken,omitempty"` + Schedules []ScheduleListEntry `json:"schedules,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` } func (v *ListSchedulesResponse) GetSchedules() (o []ScheduleListEntry) { - if v != nil { - return v.Schedules - } - return + if v != nil { + return v.Schedules + } + return } func (v *ListSchedulesResponse) GetNextPageToken() (o []byte) { - if v != nil { - return v.NextPageToken - } - return + if v != nil { + return v.NextPageToken + } + return } // BackfillScheduleRequest is the request to trigger a backfill for a time range. type BackfillScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - StartTime time.Time `json:"startTime,omitempty"` - EndTime time.Time `json:"endTime,omitempty"` - OverlapPolicy ScheduleOverlapPolicy `json:"overlapPolicy,omitempty"` - BackfillID string `json:"backfillId,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + StartTime time.Time `json:"startTime,omitempty"` + EndTime time.Time `json:"endTime,omitempty"` + OverlapPolicy ScheduleOverlapPolicy `json:"overlapPolicy,omitempty"` + BackfillID string `json:"backfillId,omitempty"` } func (v *BackfillScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *BackfillScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *BackfillScheduleRequest) GetStartTime() (o time.Time) { - if v != nil { - return v.StartTime - } - return + if v != nil { + return v.StartTime + } + return } func (v *BackfillScheduleRequest) GetEndTime() (o time.Time) { - if v != nil { - return v.EndTime - } - return + if v != nil { + return v.EndTime + } + return } func (v *BackfillScheduleRequest) GetOverlapPolicy() (o ScheduleOverlapPolicy) { - if v != nil { - return v.OverlapPolicy - } - return + if v != nil { + return v.OverlapPolicy + } + return } func (v *BackfillScheduleRequest) GetBackfillID() (o string) { - if v != nil { - return v.BackfillID - } - return + if v != nil { + return v.BackfillID + } + return } // BackfillScheduleResponse is the response for triggering a backfill. From b2b77e10f000fc6c36ddb476c7be19eda315c2f8 Mon Sep 17 00:00:00 2001 From: Gitar Date: Wed, 25 Feb 2026 22:02:16 +0000 Subject: [PATCH 4/5] fix: resolve golang integration and linting failures in sqlite tests Co-authored-by: abhishekj720 --- common/types/schedule_service.go | 430 +++++++++++++++---------------- 1 file changed, 215 insertions(+), 215 deletions(-) diff --git a/common/types/schedule_service.go b/common/types/schedule_service.go index 2440c697a26..65a6016fe72 100644 --- a/common/types/schedule_service.go +++ b/common/types/schedule_service.go @@ -26,98 +26,98 @@ import "time" // ScheduleListEntry represents a single schedule in a list response. type ScheduleListEntry struct { - ScheduleID string `json:"scheduleId,omitempty"` - WorkflowType *WorkflowType `json:"workflowType,omitempty"` - State *ScheduleState `json:"state,omitempty"` - CronExpression string `json:"cronExpression,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + WorkflowType *WorkflowType `json:"workflowType,omitempty"` + State *ScheduleState `json:"state,omitempty"` + CronExpression string `json:"cronExpression,omitempty"` } func (v *ScheduleListEntry) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *ScheduleListEntry) GetWorkflowType() *WorkflowType { - if v != nil { - return v.WorkflowType - } - return nil + if v != nil { + return v.WorkflowType + } + return nil } func (v *ScheduleListEntry) GetState() *ScheduleState { - if v != nil { - return v.State - } - return nil + if v != nil { + return v.State + } + return nil } func (v *ScheduleListEntry) GetCronExpression() (o string) { - if v != nil { - return v.CronExpression - } - return + if v != nil { + return v.CronExpression + } + return } // CreateScheduleRequest is the request to create a new schedule. type CreateScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` - Memo *Memo `json:"-"` // Filtering PII - SearchAttributes *SearchAttributes `json:"-"` // Filtering PII + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` + Memo *Memo `json:"-"` // Filtering PII + SearchAttributes *SearchAttributes `json:"-"` // Filtering PII } func (v *CreateScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *CreateScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *CreateScheduleRequest) GetSpec() *ScheduleSpec { - if v != nil { - return v.Spec - } - return nil + if v != nil { + return v.Spec + } + return nil } func (v *CreateScheduleRequest) GetAction() *ScheduleAction { - if v != nil { - return v.Action - } - return nil + if v != nil { + return v.Action + } + return nil } func (v *CreateScheduleRequest) GetPolicies() *SchedulePolicies { - if v != nil { - return v.Policies - } - return nil + if v != nil { + return v.Policies + } + return nil } func (v *CreateScheduleRequest) GetMemo() *Memo { - if v != nil { - return v.Memo - } - return nil + if v != nil { + return v.Memo + } + return nil } func (v *CreateScheduleRequest) GetSearchAttributes() *SearchAttributes { - if v != nil { - return v.SearchAttributes - } - return nil + if v != nil { + return v.SearchAttributes + } + return nil } // CreateScheduleResponse is the response for creating a schedule. @@ -125,110 +125,110 @@ type CreateScheduleResponse struct{} // DescribeScheduleRequest is the request to describe a schedule. type DescribeScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` } func (v *DescribeScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *DescribeScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } // DescribeScheduleResponse is the response for describing a schedule. type DescribeScheduleResponse struct { - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` - State *ScheduleState `json:"state,omitempty"` - Info *ScheduleInfo `json:"info,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` + State *ScheduleState `json:"state,omitempty"` + Info *ScheduleInfo `json:"info,omitempty"` } func (v *DescribeScheduleResponse) GetSpec() *ScheduleSpec { - if v != nil { - return v.Spec - } - return nil + if v != nil { + return v.Spec + } + return nil } func (v *DescribeScheduleResponse) GetAction() *ScheduleAction { - if v != nil { - return v.Action - } - return nil + if v != nil { + return v.Action + } + return nil } func (v *DescribeScheduleResponse) GetPolicies() *SchedulePolicies { - if v != nil { - return v.Policies - } - return nil + if v != nil { + return v.Policies + } + return nil } func (v *DescribeScheduleResponse) GetState() *ScheduleState { - if v != nil { - return v.State - } - return nil + if v != nil { + return v.State + } + return nil } func (v *DescribeScheduleResponse) GetInfo() *ScheduleInfo { - if v != nil { - return v.Info - } - return nil + if v != nil { + return v.Info + } + return nil } // UpdateScheduleRequest is the request to update a schedule. type UpdateScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Spec *ScheduleSpec `json:"spec,omitempty"` - Action *ScheduleAction `json:"action,omitempty"` - Policies *SchedulePolicies `json:"policies,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Spec *ScheduleSpec `json:"spec,omitempty"` + Action *ScheduleAction `json:"action,omitempty"` + Policies *SchedulePolicies `json:"policies,omitempty"` } func (v *UpdateScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *UpdateScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *UpdateScheduleRequest) GetSpec() *ScheduleSpec { - if v != nil { - return v.Spec - } - return nil + if v != nil { + return v.Spec + } + return nil } func (v *UpdateScheduleRequest) GetAction() *ScheduleAction { - if v != nil { - return v.Action - } - return nil + if v != nil { + return v.Action + } + return nil } func (v *UpdateScheduleRequest) GetPolicies() *SchedulePolicies { - if v != nil { - return v.Policies - } - return nil + if v != nil { + return v.Policies + } + return nil } // UpdateScheduleResponse is the response for updating a schedule. @@ -236,22 +236,22 @@ type UpdateScheduleResponse struct{} // DeleteScheduleRequest is the request to delete a schedule. type DeleteScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` } func (v *DeleteScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *DeleteScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } // DeleteScheduleResponse is the response for deleting a schedule. @@ -259,30 +259,30 @@ type DeleteScheduleResponse struct{} // PauseScheduleRequest is the request to pause a schedule. type PauseScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Reason string `json:"reason,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` } func (v *PauseScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *PauseScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *PauseScheduleRequest) GetReason() (o string) { - if v != nil { - return v.Reason - } - return + if v != nil { + return v.Reason + } + return } // PauseScheduleResponse is the response for pausing a schedule. @@ -290,38 +290,38 @@ type PauseScheduleResponse struct{} // UnpauseScheduleRequest is the request to resume a paused schedule. type UnpauseScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - Reason string `json:"reason,omitempty"` - CatchUpPolicy ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + Reason string `json:"reason,omitempty"` + CatchUpPolicy ScheduleCatchUpPolicy `json:"catchUpPolicy,omitempty"` } func (v *UnpauseScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *UnpauseScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *UnpauseScheduleRequest) GetReason() (o string) { - if v != nil { - return v.Reason - } - return + if v != nil { + return v.Reason + } + return } func (v *UnpauseScheduleRequest) GetCatchUpPolicy() (o ScheduleCatchUpPolicy) { - if v != nil { - return v.CatchUpPolicy - } - return + if v != nil { + return v.CatchUpPolicy + } + return } // UnpauseScheduleResponse is the response for resuming a schedule. @@ -329,102 +329,102 @@ type UnpauseScheduleResponse struct{} // ListSchedulesRequest is the request to list schedules in a domain. type ListSchedulesRequest struct { - Domain string `json:"domain,omitempty"` - PageSize int32 `json:"pageSize,omitempty"` - NextPageToken []byte `json:"nextPageToken,omitempty"` + Domain string `json:"domain,omitempty"` + PageSize int32 `json:"pageSize,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` } func (v *ListSchedulesRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *ListSchedulesRequest) GetPageSize() (o int32) { - if v != nil { - return v.PageSize - } - return + if v != nil { + return v.PageSize + } + return } func (v *ListSchedulesRequest) GetNextPageToken() (o []byte) { - if v != nil { - return v.NextPageToken - } - return + if v != nil { + return v.NextPageToken + } + return } // ListSchedulesResponse is the response for listing schedules. type ListSchedulesResponse struct { - Schedules []ScheduleListEntry `json:"schedules,omitempty"` - NextPageToken []byte `json:"nextPageToken,omitempty"` + Schedules []ScheduleListEntry `json:"schedules,omitempty"` + NextPageToken []byte `json:"nextPageToken,omitempty"` } func (v *ListSchedulesResponse) GetSchedules() (o []ScheduleListEntry) { - if v != nil { - return v.Schedules - } - return + if v != nil { + return v.Schedules + } + return } func (v *ListSchedulesResponse) GetNextPageToken() (o []byte) { - if v != nil { - return v.NextPageToken - } - return + if v != nil { + return v.NextPageToken + } + return } // BackfillScheduleRequest is the request to trigger a backfill for a time range. type BackfillScheduleRequest struct { - Domain string `json:"domain,omitempty"` - ScheduleID string `json:"scheduleId,omitempty"` - StartTime time.Time `json:"startTime,omitempty"` - EndTime time.Time `json:"endTime,omitempty"` - OverlapPolicy ScheduleOverlapPolicy `json:"overlapPolicy,omitempty"` - BackfillID string `json:"backfillId,omitempty"` + Domain string `json:"domain,omitempty"` + ScheduleID string `json:"scheduleId,omitempty"` + StartTime time.Time `json:"startTime,omitempty"` + EndTime time.Time `json:"endTime,omitempty"` + OverlapPolicy ScheduleOverlapPolicy `json:"overlapPolicy,omitempty"` + BackfillID string `json:"backfillId,omitempty"` } func (v *BackfillScheduleRequest) GetDomain() (o string) { - if v != nil { - return v.Domain - } - return + if v != nil { + return v.Domain + } + return } func (v *BackfillScheduleRequest) GetScheduleID() (o string) { - if v != nil { - return v.ScheduleID - } - return + if v != nil { + return v.ScheduleID + } + return } func (v *BackfillScheduleRequest) GetStartTime() (o time.Time) { - if v != nil { - return v.StartTime - } - return + if v != nil { + return v.StartTime + } + return } func (v *BackfillScheduleRequest) GetEndTime() (o time.Time) { - if v != nil { - return v.EndTime - } - return + if v != nil { + return v.EndTime + } + return } func (v *BackfillScheduleRequest) GetOverlapPolicy() (o ScheduleOverlapPolicy) { - if v != nil { - return v.OverlapPolicy - } - return + if v != nil { + return v.OverlapPolicy + } + return } func (v *BackfillScheduleRequest) GetBackfillID() (o string) { - if v != nil { - return v.BackfillID - } - return + if v != nil { + return v.BackfillID + } + return } // BackfillScheduleResponse is the response for triggering a backfill. From f53578a1dff859ec0cbb3b93dc4eeb2f4f6e447e Mon Sep 17 00:00:00 2001 From: Abhishek Jha Date: Thu, 26 Feb 2026 03:44:02 +0530 Subject: [PATCH 5/5] Update common/types/schedule_service.go with ptr ScheduleListEntry --- common/types/schedule_service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/common/types/schedule_service.go b/common/types/schedule_service.go index 65a6016fe72..b4da1e1677e 100644 --- a/common/types/schedule_service.go +++ b/common/types/schedule_service.go @@ -357,7 +357,7 @@ func (v *ListSchedulesRequest) GetNextPageToken() (o []byte) { // ListSchedulesResponse is the response for listing schedules. type ListSchedulesResponse struct { - Schedules []ScheduleListEntry `json:"schedules,omitempty"` + Schedules []*ScheduleListEntry `json:"schedules,omitempty"` NextPageToken []byte `json:"nextPageToken,omitempty"` }