Files
tasks/components/scheduler/generator.go
Lina JodoinandGitHub 184d48d0c6 [Scheduled Actions V2] Generator component (#6905)
## What changed?
- Added the Generator component, a sub-state machine of the top-level Scheduler
- PRs #6904 and #6903 are merged as part of this commit, as they are interdependent:
  - https://github.com/temporalio/temporal/pull/6903
  - https://github.com/temporalio/temporal/pull/6904

## Why?
* The generator generates buffered actions, and we want those!

## How did you test it?
- New tests, `go test -v`
2025-01-17 00:49:09 +00:00

109 lines
3.6 KiB
Go

// The MIT License
//
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
//
// Copyright (c) 2020 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 scheduler
import (
"fmt"
schedulespb "go.temporal.io/server/api/schedule/v1"
"go.temporal.io/server/service/history/hsm"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/types/known/timestamppb"
)
type (
// The Generator sub state machine is responsible for buffering actions according
// to the schedule's specification. Manually requested actions (from an immediate
// request or backfill) are separately handled in the Backfiller sub state machine.
Generator struct {
*schedulespb.GeneratorInternal
}
// The machine definition provides serialization/deserialization and type information.
generatorMachineDefinition struct{}
GeneratorMachineState int
)
const (
// Unique identifier for the Generator sub state machine.
GeneratorMachineType = "scheduler.Generator"
// The Generator has only a single running state.
GeneratorMachineStateRunning GeneratorMachineState = 0
)
var (
_ hsm.StateMachine[GeneratorMachineState] = Generator{}
_ hsm.StateMachineDefinition = &generatorMachineDefinition{}
// Each sub state machine is a singleton of the top-level Scheduler, accessed with
// a fixed key
GeneratorMachineKey = hsm.Key{Type: GeneratorMachineType, ID: ""}
)
// NewGenerator returns an intialized Generator sub state machine, which should
// be parented under a Scheduler root node.
func NewGenerator() *Generator {
return &Generator{
GeneratorInternal: &schedulespb.GeneratorInternal{
NextInvocationTime: timestamppb.Now(),
LastProcessedTime: timestamppb.Now(),
},
}
}
func (g Generator) State() GeneratorMachineState {
return GeneratorMachineStateRunning
}
func (g Generator) SetState(_ GeneratorMachineState) {}
func (g Generator) RegenerateTasks(node *hsm.Node) ([]hsm.Task, error) {
return g.tasks()
}
func (generatorMachineDefinition) Type() string {
return GeneratorMachineType
}
func (generatorMachineDefinition) Serialize(state any) ([]byte, error) {
if state, ok := state.(Generator); ok {
return proto.Marshal(state.GeneratorInternal)
}
return nil, fmt.Errorf("invalid generator state provided: %v", state)
}
func (generatorMachineDefinition) Deserialize(body []byte) (any, error) {
state := &schedulespb.GeneratorInternal{}
return Generator{
GeneratorInternal: state,
}, proto.Unmarshal(body, state)
}
func (generatorMachineDefinition) CompareState(a any, b any) (int, error) {
panic("TODO: CompareState not yet implemented for Generator")
}