mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Yichao YangandGitHub
6a73a744e6
## What changed? <!-- Describe what has changed in this PR --> - Add mutable state tombstone and mutation proto ## Why? <!-- Tell your future self why have you made these changes --> - To track delete sub state machines so that we can sync mutable state mutations across clusters. Otherwise we will have to sync mutable state snapshot for every update since we don't know what has been deleted in the past transitions. - The tombstone list will be bounded to store a limited # of tombstones. If the tombstone list is not tracking all tombstones for the versioned transition range being synced, full mutable state snapshot will be synced. ## How did you test it? <!-- How have you verified this change? Tested locally? Added a unit test? Checked in staging env? --> - N/A, only proto defs, not used anywhere ## Potential risks <!-- Assuming the worst case, what can be broken when deploying this change to production? --> ## Documentation <!-- Have you made sure this change doesn't falsify anything currently stated in `docs/`? If significant new behavior is added, have you described that in `docs/`? --> ## Is hotfix candidate? <!-- Is this PR a hotfix candidate or does it require a notification to be sent to the broader community? (Yes/No) -->
1206 lines
55 KiB
Go
1206 lines
55 KiB
Go
// The MIT License
|
|
//
|
|
// Copyright (c) 2024 Temporal 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.
|
|
|
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/api/persistence/v1/hsm.proto
|
|
|
|
package persistence
|
|
|
|
import (
|
|
reflect "reflect"
|
|
sync "sync"
|
|
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
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)
|
|
)
|
|
|
|
// A node in a hierarchical state machine tree.
|
|
type StateMachineNode struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Serialized data of the underlying state machine.
|
|
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
|
|
// Map of state machine type to a map of machines by ID.
|
|
Children map[string]*StateMachineMap `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
|
|
// Versioned transition when the node was instantiated.
|
|
// This field, plus node path uniquely identifies a state machine node in a mutable state instance.
|
|
// This field will always be set even when transition history is disabled.
|
|
// NOTE: If transition history is disabled, the transition_count field will be 0 and
|
|
// cannot be used to uniquely identify a node.
|
|
// NOTE: Node deletion is not yet implemented at the time of writing so we can still uniquely identify a node just
|
|
// with the initial namespace failover version.
|
|
InitialVersionedTransition *VersionedTransition `protobuf:"bytes,3,opt,name=initial_versioned_transition,json=initialVersionedTransition,proto3" json:"initial_versioned_transition,omitempty"`
|
|
// Versioned transition when the node was last updated.
|
|
// This field will always be set even when transition history is disabled.
|
|
// NOTE: If transition history is disabled, the transition_count field will be 0 and
|
|
// cannot be used for non-concurrent task staleness check or to determine whether this node should be synced
|
|
// during state replication.
|
|
LastUpdateVersionedTransition *VersionedTransition `protobuf:"bytes,4,opt,name=last_update_versioned_transition,json=lastUpdateVersionedTransition,proto3" json:"last_update_versioned_transition,omitempty"`
|
|
// Number of transitions on this state machine object.
|
|
// Used to verify that a task is not stale if the state machine does not allow concurrent task execution.
|
|
// The transition count monotonically increases with each state transition and only resets when the entire
|
|
// mutable state was rebuilt. This case is handled by the task_generation_shard_clock_timestamp field in
|
|
// WorkflowExecutionInfo.
|
|
// NOTE: This field is cluster specific and cannot be replicated.
|
|
// NOTE: This field will be made obsolete when transition history is enabled in favor of
|
|
// last_update_versioned_transition.
|
|
TransitionCount int64 `protobuf:"varint,100,opt,name=transition_count,json=transitionCount,proto3" json:"transition_count,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachineNode) Reset() {
|
|
*x = StateMachineNode{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineNode) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineNode) ProtoMessage() {}
|
|
|
|
func (x *StateMachineNode) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[0]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineNode.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineNode) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *StateMachineNode) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineNode) GetChildren() map[string]*StateMachineMap {
|
|
if x != nil {
|
|
return x.Children
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineNode) GetInitialVersionedTransition() *VersionedTransition {
|
|
if x != nil {
|
|
return x.InitialVersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineNode) GetLastUpdateVersionedTransition() *VersionedTransition {
|
|
if x != nil {
|
|
return x.LastUpdateVersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineNode) GetTransitionCount() int64 {
|
|
if x != nil {
|
|
return x.TransitionCount
|
|
}
|
|
return 0
|
|
}
|
|
|
|
// Map of state machine ID to StateMachineNode.
|
|
type StateMachineMap struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// (-- api-linter: core::0140::prepositions=disabled
|
|
//
|
|
// aip.dev/not-precedent: "by" is used to clarify the keys and values. --)
|
|
MachinesById map[string]*StateMachineNode `protobuf:"bytes,1,rep,name=machines_by_id,json=machinesById,proto3" json:"machines_by_id,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
|
|
}
|
|
|
|
func (x *StateMachineMap) Reset() {
|
|
*x = StateMachineMap{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineMap) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineMap) ProtoMessage() {}
|
|
|
|
func (x *StateMachineMap) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[1]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineMap.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineMap) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *StateMachineMap) GetMachinesById() map[string]*StateMachineNode {
|
|
if x != nil {
|
|
return x.MachinesById
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type StateMachineKey struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Addressable type of the corresponding state machine in a single tree level.
|
|
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
|
|
// Addressable ID of the corresponding state machine in a single tree level.
|
|
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachineKey) Reset() {
|
|
*x = StateMachineKey{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineKey) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineKey) ProtoMessage() {}
|
|
|
|
func (x *StateMachineKey) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[2]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineKey.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineKey) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *StateMachineKey) GetType() string {
|
|
if x != nil {
|
|
return x.Type
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StateMachineKey) GetId() string {
|
|
if x != nil {
|
|
return x.Id
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// A reference to a state machine at a point in time.
|
|
type StateMachineRef struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Nested path to a state machine.
|
|
Path []*StateMachineKey `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
|
|
// Versioned transition of the ref was instantiated.
|
|
// Used to verify that the ref is not referencing a stale state or, in some situations,
|
|
// that the ref itself is not stale.
|
|
// NOTE: If transition history is disabled, the field will not be specified and
|
|
// cannot be used for staleness check.
|
|
MutableStateVersionedTransition *VersionedTransition `protobuf:"bytes,2,opt,name=mutable_state_versioned_transition,json=mutableStateVersionedTransition,proto3" json:"mutable_state_versioned_transition,omitempty"`
|
|
// Versioned transition when the state machine node was instantiated.
|
|
// This field, plus node path uniquely identifies a state machine node in a mutable state instance.
|
|
// This field will always be set even when transition history is disabled.
|
|
// NOTE: If transition history is disabled, the transition_count field will be 0 and
|
|
// cannot be used to uniquely identify a node.
|
|
// NOTE: Node deletion is not yet implemented at the time of writing so we can still uniquely identify a node just
|
|
// with the initial namespace failover version.
|
|
MachineInitialVersionedTransition *VersionedTransition `protobuf:"bytes,3,opt,name=machine_initial_versioned_transition,json=machineInitialVersionedTransition,proto3" json:"machine_initial_versioned_transition,omitempty"`
|
|
// Versioned transition when the state machine node was last updated.
|
|
// If not specified, this reference is considered non-concurrent,
|
|
// and should match the last_update_versioned_transition on the corresponding state machine node.
|
|
// NOTE: If transition history is disabled, the transition_count field will be 0 and
|
|
// cannot be used for non-concurrent task staleness check.
|
|
MachineLastUpdateVersionedTransition *VersionedTransition `protobuf:"bytes,4,opt,name=machine_last_update_versioned_transition,json=machineLastUpdateVersionedTransition,proto3" json:"machine_last_update_versioned_transition,omitempty"`
|
|
// Number of transitions executed on the referenced state machine node at the time this Ref is instantiated.
|
|
// If non-zero, this reference is considered non-concurrent and this number should match the number of state
|
|
// transitions on the corresponding state machine node.
|
|
// This field will be obsolete once mutable state transition history is productionized.
|
|
MachineTransitionCount int64 `protobuf:"varint,100,opt,name=machine_transition_count,json=machineTransitionCount,proto3" json:"machine_transition_count,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachineRef) Reset() {
|
|
*x = StateMachineRef{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineRef) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineRef) ProtoMessage() {}
|
|
|
|
func (x *StateMachineRef) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[3]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineRef.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineRef) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *StateMachineRef) GetPath() []*StateMachineKey {
|
|
if x != nil {
|
|
return x.Path
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineRef) GetMutableStateVersionedTransition() *VersionedTransition {
|
|
if x != nil {
|
|
return x.MutableStateVersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineRef) GetMachineInitialVersionedTransition() *VersionedTransition {
|
|
if x != nil {
|
|
return x.MachineInitialVersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineRef) GetMachineLastUpdateVersionedTransition() *VersionedTransition {
|
|
if x != nil {
|
|
return x.MachineLastUpdateVersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineRef) GetMachineTransitionCount() int64 {
|
|
if x != nil {
|
|
return x.MachineTransitionCount
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type StateMachineTaskInfo struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Reference to a state machine.
|
|
Ref *StateMachineRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
|
|
// Task type. Not to be confused with the state machine's type in the `ref` field.
|
|
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
|
|
// Opaque data attached to this task. May be nil. Deserialized by a registered TaskSerializer for this type.
|
|
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachineTaskInfo) Reset() {
|
|
*x = StateMachineTaskInfo{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineTaskInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineTaskInfo) ProtoMessage() {}
|
|
|
|
func (x *StateMachineTaskInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[4]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineTaskInfo.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineTaskInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *StateMachineTaskInfo) GetRef() *StateMachineRef {
|
|
if x != nil {
|
|
return x.Ref
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineTaskInfo) GetType() string {
|
|
if x != nil {
|
|
return x.Type
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StateMachineTaskInfo) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// A group of state machine timer tasks for a given deadline, used for collapsing state machine timer tasks.
|
|
type StateMachineTimerGroup struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Task information.
|
|
Infos []*StateMachineTaskInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
|
|
// When this timer should be fired.
|
|
// (-- api-linter: core::0142::time-field-names=disabled
|
|
//
|
|
// aip.dev/not-precedent: Ignoring lint rules. --)
|
|
Deadline *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=deadline,proto3" json:"deadline,omitempty"`
|
|
// Whether or not a task was put in the queue for this group's deadline.
|
|
Scheduled bool `protobuf:"varint,3,opt,name=scheduled,proto3" json:"scheduled,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachineTimerGroup) Reset() {
|
|
*x = StateMachineTimerGroup{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineTimerGroup) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineTimerGroup) ProtoMessage() {}
|
|
|
|
func (x *StateMachineTimerGroup) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[5]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineTimerGroup.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineTimerGroup) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *StateMachineTimerGroup) GetInfos() []*StateMachineTaskInfo {
|
|
if x != nil {
|
|
return x.Infos
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineTimerGroup) GetDeadline() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.Deadline
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineTimerGroup) GetScheduled() bool {
|
|
if x != nil {
|
|
return x.Scheduled
|
|
}
|
|
return false
|
|
}
|
|
|
|
// VersionedTransition is a unique identifier for a specific mutable state transition.
|
|
type VersionedTransition struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// The namespace failover version at transition time.
|
|
NamespaceFailoverVersion int64 `protobuf:"varint,1,opt,name=namespace_failover_version,json=namespaceFailoverVersion,proto3" json:"namespace_failover_version,omitempty"`
|
|
// State transition count perceived during the specified namespace_failover_version.
|
|
TransitionCount int64 `protobuf:"varint,2,opt,name=transition_count,json=transitionCount,proto3" json:"transition_count,omitempty"`
|
|
}
|
|
|
|
func (x *VersionedTransition) Reset() {
|
|
*x = VersionedTransition{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *VersionedTransition) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*VersionedTransition) ProtoMessage() {}
|
|
|
|
func (x *VersionedTransition) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[6]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use VersionedTransition.ProtoReflect.Descriptor instead.
|
|
func (*VersionedTransition) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *VersionedTransition) GetNamespaceFailoverVersion() int64 {
|
|
if x != nil {
|
|
return x.NamespaceFailoverVersion
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *VersionedTransition) GetTransitionCount() int64 {
|
|
if x != nil {
|
|
return x.TransitionCount
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type StateMachineTombstoneBatch struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// The versioned transition in which the tombstones were created.
|
|
VersionedTransition *VersionedTransition `protobuf:"bytes,1,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
|
|
StateMachineTombstones []*StateMachineTombstone `protobuf:"bytes,2,rep,name=state_machine_tombstones,json=stateMachineTombstones,proto3" json:"state_machine_tombstones,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachineTombstoneBatch) Reset() {
|
|
*x = StateMachineTombstoneBatch{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineTombstoneBatch) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineTombstoneBatch) ProtoMessage() {}
|
|
|
|
func (x *StateMachineTombstoneBatch) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[7]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineTombstoneBatch.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineTombstoneBatch) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *StateMachineTombstoneBatch) GetVersionedTransition() *VersionedTransition {
|
|
if x != nil {
|
|
return x.VersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineTombstoneBatch) GetStateMachineTombstones() []*StateMachineTombstone {
|
|
if x != nil {
|
|
return x.StateMachineTombstones
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type StateMachineTombstone struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Types that are assignable to StateMachineKey:
|
|
//
|
|
// *StateMachineTombstone_ActivityScheduledEventId
|
|
// *StateMachineTombstone_TimerId
|
|
// *StateMachineTombstone_ChildExecutionInitiatedEventId
|
|
// *StateMachineTombstone_RequestCancelInitiatedEventId
|
|
// *StateMachineTombstone_SignalExternalInitiatedEventId
|
|
// *StateMachineTombstone_UpdateId
|
|
// *StateMachineTombstone_StateMachinePath
|
|
StateMachineKey isStateMachineTombstone_StateMachineKey `protobuf_oneof:"state_machine_key"`
|
|
}
|
|
|
|
func (x *StateMachineTombstone) Reset() {
|
|
*x = StateMachineTombstone{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachineTombstone) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachineTombstone) ProtoMessage() {}
|
|
|
|
func (x *StateMachineTombstone) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[8]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachineTombstone.ProtoReflect.Descriptor instead.
|
|
func (*StateMachineTombstone) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (m *StateMachineTombstone) GetStateMachineKey() isStateMachineTombstone_StateMachineKey {
|
|
if m != nil {
|
|
return m.StateMachineKey
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetActivityScheduledEventId() int64 {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_ActivityScheduledEventId); ok {
|
|
return x.ActivityScheduledEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetTimerId() string {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_TimerId); ok {
|
|
return x.TimerId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetChildExecutionInitiatedEventId() int64 {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_ChildExecutionInitiatedEventId); ok {
|
|
return x.ChildExecutionInitiatedEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetRequestCancelInitiatedEventId() int64 {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_RequestCancelInitiatedEventId); ok {
|
|
return x.RequestCancelInitiatedEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetSignalExternalInitiatedEventId() int64 {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_SignalExternalInitiatedEventId); ok {
|
|
return x.SignalExternalInitiatedEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetUpdateId() string {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_UpdateId); ok {
|
|
return x.UpdateId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StateMachineTombstone) GetStateMachinePath() *StateMachinePath {
|
|
if x, ok := x.GetStateMachineKey().(*StateMachineTombstone_StateMachinePath); ok {
|
|
return x.StateMachinePath
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type isStateMachineTombstone_StateMachineKey interface {
|
|
isStateMachineTombstone_StateMachineKey()
|
|
}
|
|
|
|
type StateMachineTombstone_ActivityScheduledEventId struct {
|
|
ActivityScheduledEventId int64 `protobuf:"varint,1,opt,name=activity_scheduled_event_id,json=activityScheduledEventId,proto3,oneof"`
|
|
}
|
|
|
|
type StateMachineTombstone_TimerId struct {
|
|
TimerId string `protobuf:"bytes,2,opt,name=timer_id,json=timerId,proto3,oneof"`
|
|
}
|
|
|
|
type StateMachineTombstone_ChildExecutionInitiatedEventId struct {
|
|
ChildExecutionInitiatedEventId int64 `protobuf:"varint,3,opt,name=child_execution_initiated_event_id,json=childExecutionInitiatedEventId,proto3,oneof"`
|
|
}
|
|
|
|
type StateMachineTombstone_RequestCancelInitiatedEventId struct {
|
|
RequestCancelInitiatedEventId int64 `protobuf:"varint,4,opt,name=request_cancel_initiated_event_id,json=requestCancelInitiatedEventId,proto3,oneof"`
|
|
}
|
|
|
|
type StateMachineTombstone_SignalExternalInitiatedEventId struct {
|
|
SignalExternalInitiatedEventId int64 `protobuf:"varint,5,opt,name=signal_external_initiated_event_id,json=signalExternalInitiatedEventId,proto3,oneof"`
|
|
}
|
|
|
|
type StateMachineTombstone_UpdateId struct {
|
|
UpdateId string `protobuf:"bytes,6,opt,name=update_id,json=updateId,proto3,oneof"`
|
|
}
|
|
|
|
type StateMachineTombstone_StateMachinePath struct {
|
|
StateMachinePath *StateMachinePath `protobuf:"bytes,7,opt,name=state_machine_path,json=stateMachinePath,proto3,oneof"`
|
|
}
|
|
|
|
func (*StateMachineTombstone_ActivityScheduledEventId) isStateMachineTombstone_StateMachineKey() {}
|
|
|
|
func (*StateMachineTombstone_TimerId) isStateMachineTombstone_StateMachineKey() {}
|
|
|
|
func (*StateMachineTombstone_ChildExecutionInitiatedEventId) isStateMachineTombstone_StateMachineKey() {
|
|
}
|
|
|
|
func (*StateMachineTombstone_RequestCancelInitiatedEventId) isStateMachineTombstone_StateMachineKey() {
|
|
}
|
|
|
|
func (*StateMachineTombstone_SignalExternalInitiatedEventId) isStateMachineTombstone_StateMachineKey() {
|
|
}
|
|
|
|
func (*StateMachineTombstone_UpdateId) isStateMachineTombstone_StateMachineKey() {}
|
|
|
|
func (*StateMachineTombstone_StateMachinePath) isStateMachineTombstone_StateMachineKey() {}
|
|
|
|
type StateMachinePath struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Path []*StateMachineKey `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
|
|
}
|
|
|
|
func (x *StateMachinePath) Reset() {
|
|
*x = StateMachinePath{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *StateMachinePath) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StateMachinePath) ProtoMessage() {}
|
|
|
|
func (x *StateMachinePath) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[9]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StateMachinePath.ProtoReflect.Descriptor instead.
|
|
func (*StateMachinePath) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *StateMachinePath) GetPath() []*StateMachineKey {
|
|
if x != nil {
|
|
return x.Path
|
|
}
|
|
return nil
|
|
}
|
|
|
|
var File_temporal_server_api_persistence_v1_hsm_proto protoreflect.FileDescriptor
|
|
|
|
var file_temporal_server_api_persistence_v1_hsm_proto_rawDesc = []byte{
|
|
0x0a, 0x2c, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
|
|
0x2f, 0x61, 0x70, 0x69, 0x2f, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2f,
|
|
0x76, 0x31, 0x2f, 0x68, 0x73, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x22, 0x74, 0x65, 0x6d,
|
|
0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e,
|
|
0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x1a, 0x1f,
|
|
0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74,
|
|
0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbd, 0x04,
|
|
0x0a, 0x10, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4e, 0x6f, 0x64,
|
|
0x65, 0x12, 0x16, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52,
|
|
0x04, 0x64, 0x61, 0x74, 0x61, 0x42, 0x02, 0x68, 0x00, 0x12, 0x62, 0x0a, 0x08, 0x63, 0x68, 0x69, 0x6c,
|
|
0x64, 0x72, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x42, 0x2e, 0x74, 0x65, 0x6d, 0x70,
|
|
0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70,
|
|
0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61,
|
|
0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x2e, 0x43, 0x68,
|
|
0x69, 0x6c, 0x64, 0x72, 0x65, 0x6e, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x08, 0x63, 0x68, 0x69, 0x6c,
|
|
0x64, 0x72, 0x65, 0x6e, 0x42, 0x02, 0x68, 0x00, 0x12, 0x7d, 0x0a, 0x1c, 0x69, 0x6e, 0x69, 0x74, 0x69,
|
|
0x61, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x5f, 0x74, 0x72, 0x61, 0x6e,
|
|
0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x74,
|
|
0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70,
|
|
0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e,
|
|
0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69,
|
|
0x6f, 0x6e, 0x52, 0x1a, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f,
|
|
0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x02, 0x68,
|
|
0x00, 0x12, 0x84, 0x01, 0x0a, 0x20, 0x6c, 0x61, 0x73, 0x74, 0x5f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65,
|
|
0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69,
|
|
0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x74, 0x65, 0x6d, 0x70,
|
|
0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e,
|
|
0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x65,
|
|
0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e,
|
|
0x52, 0x1d, 0x6c, 0x61, 0x73, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69,
|
|
0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x02, 0x68,
|
|
0x00, 0x12, 0x2d, 0x0a, 0x10, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f,
|
|
0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x64, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x74, 0x72, 0x61, 0x6e,
|
|
0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x42, 0x02, 0x68, 0x00, 0x1a, 0x78,
|
|
0x0a, 0x0d, 0x43, 0x68, 0x69, 0x6c, 0x64, 0x72, 0x65, 0x6e, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x14,
|
|
0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79,
|
|
0x42, 0x02, 0x68, 0x00, 0x12, 0x4d, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01,
|
|
0x28, 0x0b, 0x32, 0x33, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72,
|
|
0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e,
|
|
0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69,
|
|
0x6e, 0x65, 0x4d, 0x61, 0x70, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x02, 0x68, 0x00, 0x3a,
|
|
0x02, 0x38, 0x01, 0x22, 0x81, 0x02, 0x0a, 0x0f, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68,
|
|
0x69, 0x6e, 0x65, 0x4d, 0x61, 0x70, 0x12, 0x6f, 0x0a, 0x0e, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65,
|
|
0x73, 0x5f, 0x62, 0x79, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x45, 0x2e, 0x74,
|
|
0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61,
|
|
0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31,
|
|
0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4d, 0x61, 0x70, 0x2e,
|
|
0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x73, 0x42, 0x79, 0x49, 0x64, 0x45, 0x6e, 0x74, 0x72, 0x79,
|
|
0x52, 0x0c, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x73, 0x42, 0x79, 0x49, 0x64, 0x42, 0x02,
|
|
0x68, 0x00, 0x1a, 0x7d, 0x0a, 0x11, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x73, 0x42, 0x79, 0x49,
|
|
0x64, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x14, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01,
|
|
0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x42, 0x02, 0x68, 0x00, 0x12, 0x4e, 0x0a, 0x05, 0x76, 0x61,
|
|
0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x34, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f,
|
|
0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70,
|
|
0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61,
|
|
0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x52, 0x05, 0x76, 0x61,
|
|
0x6c, 0x75, 0x65, 0x42, 0x02, 0x68, 0x00, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x3d, 0x0a, 0x0f, 0x53, 0x74,
|
|
0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4b, 0x65, 0x79, 0x12, 0x16, 0x0a,
|
|
0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65,
|
|
0x42, 0x02, 0x68, 0x00, 0x12, 0x12, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
|
|
0x02, 0x69, 0x64, 0x42, 0x02, 0x68, 0x00, 0x22, 0xcc, 0x04, 0x0a, 0x0f, 0x53, 0x74, 0x61, 0x74, 0x65,
|
|
0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x66, 0x12, 0x4b, 0x0a, 0x04, 0x70, 0x61, 0x74,
|
|
0x68, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72,
|
|
0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72,
|
|
0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65,
|
|
0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68, 0x42,
|
|
0x02, 0x68, 0x00, 0x12, 0x88, 0x01, 0x0a, 0x22, 0x6d, 0x75, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f,
|
|
0x73, 0x74, 0x61, 0x74, 0x65, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x5f, 0x74,
|
|
0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37,
|
|
0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e,
|
|
0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76,
|
|
0x31, 0x2e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73,
|
|
0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x1f, 0x6d, 0x75, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x74, 0x61,
|
|
0x74, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69,
|
|
0x74, 0x69, 0x6f, 0x6e, 0x42, 0x02, 0x68, 0x00, 0x12, 0x8c, 0x01, 0x0a, 0x24, 0x6d, 0x61, 0x63, 0x68,
|
|
0x69, 0x6e, 0x65, 0x5f, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x6c, 0x5f, 0x76, 0x65, 0x72, 0x73,
|
|
0x69, 0x6f, 0x6e, 0x65, 0x64, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18,
|
|
0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e,
|
|
0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73,
|
|
0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
|
|
0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x21, 0x6d, 0x61, 0x63,
|
|
0x68, 0x69, 0x6e, 0x65, 0x49, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x6c, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f,
|
|
0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x02, 0x68, 0x00,
|
|
0x12, 0x93, 0x01, 0x0a, 0x28, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x5f, 0x6c, 0x61, 0x73, 0x74,
|
|
0x5f, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65,
|
|
0x64, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28,
|
|
0x0b, 0x32, 0x37, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76,
|
|
0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63,
|
|
0x65, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72,
|
|
0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x24, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65,
|
|
0x4c, 0x61, 0x73, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
|
|
0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x02, 0x68, 0x00, 0x12,
|
|
0x3c, 0x0a, 0x18, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69,
|
|
0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x64, 0x20, 0x01, 0x28, 0x03,
|
|
0x52, 0x16, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69,
|
|
0x6f, 0x6e, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x42, 0x02, 0x68, 0x00, 0x22, 0x91, 0x01, 0x0a, 0x14, 0x53,
|
|
0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e,
|
|
0x66, 0x6f, 0x12, 0x49, 0x0a, 0x03, 0x72, 0x65, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
|
|
0x33, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
|
|
0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e,
|
|
0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x52, 0x65,
|
|
0x66, 0x52, 0x03, 0x72, 0x65, 0x66, 0x42, 0x02, 0x68, 0x00, 0x12, 0x16, 0x0a, 0x04, 0x74, 0x79, 0x70,
|
|
0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x42, 0x02, 0x68,
|
|
0x00, 0x12, 0x16, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04,
|
|
0x64, 0x61, 0x74, 0x61, 0x42, 0x02, 0x68, 0x00, 0x22, 0xca, 0x01, 0x0a, 0x16, 0x53, 0x74, 0x61, 0x74,
|
|
0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x72, 0x47, 0x72, 0x6f, 0x75,
|
|
0x70, 0x12, 0x52, 0x0a, 0x05, 0x69, 0x6e, 0x66, 0x6f, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b,
|
|
0x32, 0x38, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65,
|
|
0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65,
|
|
0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54,
|
|
0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x05, 0x69, 0x6e, 0x66, 0x6f, 0x73, 0x42, 0x02,
|
|
0x68, 0x00, 0x12, 0x3a, 0x0a, 0x08, 0x64, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x18, 0x02, 0x20,
|
|
0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
|
|
0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x08, 0x64,
|
|
0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x42, 0x02, 0x68, 0x00, 0x12, 0x20, 0x0a, 0x09, 0x73, 0x63,
|
|
0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x09, 0x73,
|
|
0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x64, 0x42, 0x02, 0x68, 0x00, 0x22, 0x86, 0x01, 0x0a, 0x13,
|
|
0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69,
|
|
0x6f, 0x6e, 0x12, 0x40, 0x0a, 0x1a, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x66,
|
|
0x61, 0x69, 0x6c, 0x6f, 0x76, 0x65, 0x72, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18,
|
|
0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x18, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x46,
|
|
0x61, 0x69, 0x6c, 0x6f, 0x76, 0x65, 0x72, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x02, 0x68,
|
|
0x00, 0x12, 0x2d, 0x0a, 0x10, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x63,
|
|
0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0f, 0x74, 0x72, 0x61, 0x6e, 0x73,
|
|
0x69, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x42, 0x02, 0x68, 0x00, 0x22, 0x85,
|
|
0x02, 0x0a, 0x1a, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x6f,
|
|
0x6d, 0x62, 0x73, 0x74, 0x6f, 0x6e, 0x65, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x6e, 0x0a, 0x14, 0x76,
|
|
0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69,
|
|
0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f,
|
|
0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65,
|
|
0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x65, 0x72, 0x73,
|
|
0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x13,
|
|
0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x69, 0x74, 0x69,
|
|
0x6f, 0x6e, 0x42, 0x02, 0x68, 0x00, 0x12, 0x77, 0x0a, 0x18, 0x73, 0x74, 0x61, 0x74, 0x65, 0x5f,
|
|
0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x5f, 0x74, 0x6f, 0x6d, 0x62, 0x73, 0x74, 0x6f, 0x6e, 0x65,
|
|
0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72, 0x61,
|
|
0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72, 0x73,
|
|
0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65,
|
|
0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x6f, 0x6d, 0x62, 0x73, 0x74, 0x6f, 0x6e, 0x65, 0x52,
|
|
0x16, 0x73, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x6f, 0x6d, 0x62,
|
|
0x73, 0x74, 0x6f, 0x6e, 0x65, 0x73, 0x42, 0x02, 0x68, 0x00, 0x22, 0x93, 0x04, 0x0a, 0x15, 0x53, 0x74,
|
|
0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x54, 0x6f, 0x6d, 0x62, 0x73, 0x74, 0x6f,
|
|
0x6e, 0x65, 0x12, 0x43, 0x0a, 0x1b, 0x61, 0x63, 0x74, 0x69, 0x76, 0x69, 0x74, 0x79, 0x5f, 0x73,
|
|
0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x64, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64,
|
|
0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00, 0x52, 0x18, 0x61, 0x63, 0x74, 0x69, 0x76, 0x69, 0x74,
|
|
0x79, 0x53, 0x63, 0x68, 0x65, 0x64, 0x75, 0x6c, 0x65, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64,
|
|
0x42, 0x02, 0x68, 0x00, 0x12, 0x1f, 0x0a, 0x08, 0x74, 0x69, 0x6d, 0x65, 0x72, 0x5f, 0x69, 0x64,
|
|
0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x72, 0x49, 0x64,
|
|
0x42, 0x02, 0x68, 0x00, 0x12, 0x50, 0x0a, 0x22, 0x63, 0x68, 0x69, 0x6c, 0x64, 0x5f, 0x65, 0x78, 0x65,
|
|
0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x65, 0x64, 0x5f,
|
|
0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00,
|
|
0x52, 0x1e, 0x63, 0x68, 0x69, 0x6c, 0x64, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x69, 0x6f, 0x6e, 0x49,
|
|
0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x65, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x42, 0x02,
|
|
0x68, 0x00, 0x12, 0x4e, 0x0a, 0x21, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x63, 0x61, 0x6e,
|
|
0x63, 0x65, 0x6c, 0x5f, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x65, 0x76, 0x65,
|
|
0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00, 0x52, 0x1d, 0x72,
|
|
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x43, 0x61, 0x6e, 0x63, 0x65, 0x6c, 0x49, 0x6e, 0x69, 0x74, 0x69,
|
|
0x61, 0x74, 0x65, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x42, 0x02, 0x68, 0x00, 0x12, 0x50,
|
|
0x0a, 0x22, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c, 0x5f, 0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
|
|
0x5f, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74,
|
|
0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00, 0x52, 0x1e, 0x73, 0x69, 0x67, 0x6e,
|
|
0x61, 0x6c, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x69, 0x74, 0x69, 0x61, 0x74,
|
|
0x65, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x42, 0x02, 0x68, 0x00, 0x12, 0x21, 0x0a, 0x09,
|
|
0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00,
|
|
0x52, 0x08, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x49, 0x64, 0x42, 0x02, 0x68, 0x00, 0x12, 0x68,
|
|
0x0a, 0x12, 0x73, 0x74, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x5f, 0x70,
|
|
0x61, 0x74, 0x68, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x34, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f,
|
|
0x72, 0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65,
|
|
0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61,
|
|
0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x74, 0x68, 0x48, 0x00, 0x52, 0x10,
|
|
0x73, 0x74, 0x61, 0x74, 0x65, 0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x74, 0x68, 0x42,
|
|
0x02, 0x68, 0x00, 0x42, 0x13, 0x0a, 0x11, 0x73, 0x74, 0x61, 0x74, 0x65, 0x5f, 0x6d, 0x61, 0x63, 0x68,
|
|
0x69, 0x6e, 0x65, 0x5f, 0x6b, 0x65, 0x79, 0x22, 0x5f, 0x0a, 0x10, 0x53, 0x74, 0x61, 0x74, 0x65, 0x4d,
|
|
0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x50, 0x61, 0x74, 0x68, 0x12, 0x4b, 0x0a, 0x04, 0x70, 0x61,
|
|
0x74, 0x68, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72,
|
|
0x61, 0x6c, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x65, 0x72,
|
|
0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65,
|
|
0x4d, 0x61, 0x63, 0x68, 0x69, 0x6e, 0x65, 0x4b, 0x65, 0x79, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68,
|
|
0x42, 0x02, 0x68, 0x00, 0x42, 0x36, 0x5a, 0x34, 0x67, 0x6f, 0x2e, 0x74, 0x65, 0x6d, 0x70, 0x6f, 0x72,
|
|
0x61, 0x6c, 0x2e, 0x69, 0x6f, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2f, 0x61, 0x70, 0x69, 0x2f,
|
|
0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x2f, 0x76, 0x31, 0x3b, 0x70, 0x65,
|
|
0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x63, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
|
|
0x33,
|
|
}
|
|
|
|
var (
|
|
file_temporal_server_api_persistence_v1_hsm_proto_rawDescOnce sync.Once
|
|
file_temporal_server_api_persistence_v1_hsm_proto_rawDescData = file_temporal_server_api_persistence_v1_hsm_proto_rawDesc
|
|
)
|
|
|
|
func file_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_api_persistence_v1_hsm_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_api_persistence_v1_hsm_proto_rawDescData = protoimpl.X.CompressGZIP(file_temporal_server_api_persistence_v1_hsm_proto_rawDescData)
|
|
})
|
|
return file_temporal_server_api_persistence_v1_hsm_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_api_persistence_v1_hsm_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
|
|
var file_temporal_server_api_persistence_v1_hsm_proto_goTypes = []interface{}{
|
|
(*StateMachineNode)(nil), // 0: temporal.server.api.persistence.v1.StateMachineNode
|
|
(*StateMachineMap)(nil), // 1: temporal.server.api.persistence.v1.StateMachineMap
|
|
(*StateMachineKey)(nil), // 2: temporal.server.api.persistence.v1.StateMachineKey
|
|
(*StateMachineRef)(nil), // 3: temporal.server.api.persistence.v1.StateMachineRef
|
|
(*StateMachineTaskInfo)(nil), // 4: temporal.server.api.persistence.v1.StateMachineTaskInfo
|
|
(*StateMachineTimerGroup)(nil), // 5: temporal.server.api.persistence.v1.StateMachineTimerGroup
|
|
(*VersionedTransition)(nil), // 6: temporal.server.api.persistence.v1.VersionedTransition
|
|
(*StateMachineTombstoneBatch)(nil), // 7: temporal.server.api.persistence.v1.StateMachineTombstoneBatch
|
|
(*StateMachineTombstone)(nil), // 8: temporal.server.api.persistence.v1.StateMachineTombstone
|
|
(*StateMachinePath)(nil), // 9: temporal.server.api.persistence.v1.StateMachinePath
|
|
nil, // 10: temporal.server.api.persistence.v1.StateMachineNode.ChildrenEntry
|
|
nil, // 11: temporal.server.api.persistence.v1.StateMachineMap.MachinesByIdEntry
|
|
(*timestamppb.Timestamp)(nil), // 12: google.protobuf.Timestamp
|
|
}
|
|
var file_temporal_server_api_persistence_v1_hsm_proto_depIdxs = []int32{
|
|
10, // 0: temporal.server.api.persistence.v1.StateMachineNode.children:type_name -> temporal.server.api.persistence.v1.StateMachineNode.ChildrenEntry
|
|
6, // 1: temporal.server.api.persistence.v1.StateMachineNode.initial_versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
6, // 2: temporal.server.api.persistence.v1.StateMachineNode.last_update_versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
11, // 3: temporal.server.api.persistence.v1.StateMachineMap.machines_by_id:type_name -> temporal.server.api.persistence.v1.StateMachineMap.MachinesByIdEntry
|
|
2, // 4: temporal.server.api.persistence.v1.StateMachineRef.path:type_name -> temporal.server.api.persistence.v1.StateMachineKey
|
|
6, // 5: temporal.server.api.persistence.v1.StateMachineRef.mutable_state_versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
6, // 6: temporal.server.api.persistence.v1.StateMachineRef.machine_initial_versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
6, // 7: temporal.server.api.persistence.v1.StateMachineRef.machine_last_update_versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
3, // 8: temporal.server.api.persistence.v1.StateMachineTaskInfo.ref:type_name -> temporal.server.api.persistence.v1.StateMachineRef
|
|
4, // 9: temporal.server.api.persistence.v1.StateMachineTimerGroup.infos:type_name -> temporal.server.api.persistence.v1.StateMachineTaskInfo
|
|
12, // 10: temporal.server.api.persistence.v1.StateMachineTimerGroup.deadline:type_name -> google.protobuf.Timestamp
|
|
6, // 11: temporal.server.api.persistence.v1.StateMachineTombstoneBatch.versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
8, // 12: temporal.server.api.persistence.v1.StateMachineTombstoneBatch.state_machine_tombstones:type_name -> temporal.server.api.persistence.v1.StateMachineTombstone
|
|
9, // 13: temporal.server.api.persistence.v1.StateMachineTombstone.state_machine_path:type_name -> temporal.server.api.persistence.v1.StateMachinePath
|
|
2, // 14: temporal.server.api.persistence.v1.StateMachinePath.path:type_name -> temporal.server.api.persistence.v1.StateMachineKey
|
|
1, // 15: temporal.server.api.persistence.v1.StateMachineNode.ChildrenEntry.value:type_name -> temporal.server.api.persistence.v1.StateMachineMap
|
|
0, // 16: temporal.server.api.persistence.v1.StateMachineMap.MachinesByIdEntry.value:type_name -> temporal.server.api.persistence.v1.StateMachineNode
|
|
17, // [17:17] is the sub-list for method output_type
|
|
17, // [17:17] is the sub-list for method input_type
|
|
17, // [17:17] is the sub-list for extension type_name
|
|
17, // [17:17] is the sub-list for extension extendee
|
|
0, // [0:17] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_api_persistence_v1_hsm_proto_init() }
|
|
func file_temporal_server_api_persistence_v1_hsm_proto_init() {
|
|
if File_temporal_server_api_persistence_v1_hsm_proto != nil {
|
|
return
|
|
}
|
|
if !protoimpl.UnsafeEnabled {
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineNode); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineMap); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineKey); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineRef); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineTaskInfo); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineTimerGroup); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*VersionedTransition); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineTombstoneBatch); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachineTombstone); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*StateMachinePath); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[8].OneofWrappers = []interface{}{
|
|
(*StateMachineTombstone_ActivityScheduledEventId)(nil),
|
|
(*StateMachineTombstone_TimerId)(nil),
|
|
(*StateMachineTombstone_ChildExecutionInitiatedEventId)(nil),
|
|
(*StateMachineTombstone_RequestCancelInitiatedEventId)(nil),
|
|
(*StateMachineTombstone_SignalExternalInitiatedEventId)(nil),
|
|
(*StateMachineTombstone_UpdateId)(nil),
|
|
(*StateMachineTombstone_StateMachinePath)(nil),
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: file_temporal_server_api_persistence_v1_hsm_proto_rawDesc,
|
|
NumEnums: 0,
|
|
NumMessages: 12,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_api_persistence_v1_hsm_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_api_persistence_v1_hsm_proto_depIdxs,
|
|
MessageInfos: file_temporal_server_api_persistence_v1_hsm_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_api_persistence_v1_hsm_proto = out.File
|
|
file_temporal_server_api_persistence_v1_hsm_proto_rawDesc = nil
|
|
file_temporal_server_api_persistence_v1_hsm_proto_goTypes = nil
|
|
file_temporal_server_api_persistence_v1_hsm_proto_depIdxs = nil
|
|
}
|