mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
## What changed?
<!-- Describe what has changed in this PR -->
Remove license header from every file. Because it is really hard to
follow in this PR here is the summary:
1. License header is removed from all `.go` and `.proto` files
:fireworks::fireworks:🎆.
2. `LICENSE` file in the root directory has only Temporal and Uber
copyrights.
3. 5 other `LICENSE` files added to the packages which have copyrights
different from Temporal and Uber: Datadog, Xargin, "Mat Ryer, Tyler
Bunnell and contributors".
4. `license_file` flag is removed from all code generation tools.
5. `copyright_file` flag is removed from `go:generate mockgen`
directive.
6. All copyright related targets are removed from `Makefile`.
7. Updated Temporal copyright year to 2025 everywhere.
## Why?
<!-- Tell your future self why have you made these changes -->
I double checked with legal department that it is not needed to have
license header in every file. One file per repo is enough. I put all
copyrights to the root `LICENSE` file and removed header from all other
files. Also updated tools and `Makefile`.
865 lines
33 KiB
Go
865 lines
33 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/api/persistence/v1/predicates.proto
|
|
|
|
package persistence
|
|
|
|
import (
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
|
|
v1 "go.temporal.io/server/api/enums/v1"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
type Predicate struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
PredicateType v1.PredicateType `protobuf:"varint,1,opt,name=predicate_type,json=predicateType,proto3,enum=temporal.server.api.enums.v1.PredicateType" json:"predicate_type,omitempty"`
|
|
// Types that are valid to be assigned to Attributes:
|
|
//
|
|
// *Predicate_UniversalPredicateAttributes
|
|
// *Predicate_EmptyPredicateAttributes
|
|
// *Predicate_AndPredicateAttributes
|
|
// *Predicate_OrPredicateAttributes
|
|
// *Predicate_NotPredicateAttributes
|
|
// *Predicate_NamespaceIdPredicateAttributes
|
|
// *Predicate_TaskTypePredicateAttributes
|
|
// *Predicate_DestinationPredicateAttributes
|
|
// *Predicate_OutboundTaskGroupPredicateAttributes
|
|
// *Predicate_OutboundTaskPredicateAttributes
|
|
Attributes isPredicate_Attributes `protobuf_oneof:"attributes"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *Predicate) Reset() {
|
|
*x = Predicate{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *Predicate) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Predicate) ProtoMessage() {}
|
|
|
|
func (x *Predicate) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Predicate.ProtoReflect.Descriptor instead.
|
|
func (*Predicate) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *Predicate) GetPredicateType() v1.PredicateType {
|
|
if x != nil {
|
|
return x.PredicateType
|
|
}
|
|
return v1.PredicateType(0)
|
|
}
|
|
|
|
func (x *Predicate) GetAttributes() isPredicate_Attributes {
|
|
if x != nil {
|
|
return x.Attributes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetUniversalPredicateAttributes() *UniversalPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_UniversalPredicateAttributes); ok {
|
|
return x.UniversalPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetEmptyPredicateAttributes() *EmptyPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_EmptyPredicateAttributes); ok {
|
|
return x.EmptyPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetAndPredicateAttributes() *AndPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_AndPredicateAttributes); ok {
|
|
return x.AndPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetOrPredicateAttributes() *OrPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_OrPredicateAttributes); ok {
|
|
return x.OrPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetNotPredicateAttributes() *NotPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_NotPredicateAttributes); ok {
|
|
return x.NotPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetNamespaceIdPredicateAttributes() *NamespaceIdPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_NamespaceIdPredicateAttributes); ok {
|
|
return x.NamespaceIdPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetTaskTypePredicateAttributes() *TaskTypePredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_TaskTypePredicateAttributes); ok {
|
|
return x.TaskTypePredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetDestinationPredicateAttributes() *DestinationPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_DestinationPredicateAttributes); ok {
|
|
return x.DestinationPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetOutboundTaskGroupPredicateAttributes() *OutboundTaskGroupPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_OutboundTaskGroupPredicateAttributes); ok {
|
|
return x.OutboundTaskGroupPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Predicate) GetOutboundTaskPredicateAttributes() *OutboundTaskPredicateAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*Predicate_OutboundTaskPredicateAttributes); ok {
|
|
return x.OutboundTaskPredicateAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type isPredicate_Attributes interface {
|
|
isPredicate_Attributes()
|
|
}
|
|
|
|
type Predicate_UniversalPredicateAttributes struct {
|
|
UniversalPredicateAttributes *UniversalPredicateAttributes `protobuf:"bytes,2,opt,name=universal_predicate_attributes,json=universalPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_EmptyPredicateAttributes struct {
|
|
EmptyPredicateAttributes *EmptyPredicateAttributes `protobuf:"bytes,3,opt,name=empty_predicate_attributes,json=emptyPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_AndPredicateAttributes struct {
|
|
AndPredicateAttributes *AndPredicateAttributes `protobuf:"bytes,4,opt,name=and_predicate_attributes,json=andPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_OrPredicateAttributes struct {
|
|
OrPredicateAttributes *OrPredicateAttributes `protobuf:"bytes,5,opt,name=or_predicate_attributes,json=orPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_NotPredicateAttributes struct {
|
|
NotPredicateAttributes *NotPredicateAttributes `protobuf:"bytes,6,opt,name=not_predicate_attributes,json=notPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_NamespaceIdPredicateAttributes struct {
|
|
NamespaceIdPredicateAttributes *NamespaceIdPredicateAttributes `protobuf:"bytes,7,opt,name=namespace_id_predicate_attributes,json=namespaceIdPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_TaskTypePredicateAttributes struct {
|
|
TaskTypePredicateAttributes *TaskTypePredicateAttributes `protobuf:"bytes,8,opt,name=task_type_predicate_attributes,json=taskTypePredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_DestinationPredicateAttributes struct {
|
|
DestinationPredicateAttributes *DestinationPredicateAttributes `protobuf:"bytes,9,opt,name=destination_predicate_attributes,json=destinationPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_OutboundTaskGroupPredicateAttributes struct {
|
|
OutboundTaskGroupPredicateAttributes *OutboundTaskGroupPredicateAttributes `protobuf:"bytes,10,opt,name=outbound_task_group_predicate_attributes,json=outboundTaskGroupPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type Predicate_OutboundTaskPredicateAttributes struct {
|
|
OutboundTaskPredicateAttributes *OutboundTaskPredicateAttributes `protobuf:"bytes,11,opt,name=outbound_task_predicate_attributes,json=outboundTaskPredicateAttributes,proto3,oneof"`
|
|
}
|
|
|
|
func (*Predicate_UniversalPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_EmptyPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_AndPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_OrPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_NotPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_NamespaceIdPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_TaskTypePredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_DestinationPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_OutboundTaskGroupPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
func (*Predicate_OutboundTaskPredicateAttributes) isPredicate_Attributes() {}
|
|
|
|
type UniversalPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UniversalPredicateAttributes) Reset() {
|
|
*x = UniversalPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UniversalPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UniversalPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *UniversalPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use UniversalPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*UniversalPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
type EmptyPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *EmptyPredicateAttributes) Reset() {
|
|
*x = EmptyPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *EmptyPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*EmptyPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *EmptyPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use EmptyPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*EmptyPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
type AndPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AndPredicateAttributes) Reset() {
|
|
*x = AndPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AndPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AndPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *AndPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AndPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*AndPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *AndPredicateAttributes) GetPredicates() []*Predicate {
|
|
if x != nil {
|
|
return x.Predicates
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type OrPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *OrPredicateAttributes) Reset() {
|
|
*x = OrPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *OrPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*OrPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *OrPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use OrPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*OrPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *OrPredicateAttributes) GetPredicates() []*Predicate {
|
|
if x != nil {
|
|
return x.Predicates
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type NotPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Predicate *Predicate `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *NotPredicateAttributes) Reset() {
|
|
*x = NotPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *NotPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*NotPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *NotPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[5]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use NotPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*NotPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *NotPredicateAttributes) GetPredicate() *Predicate {
|
|
if x != nil {
|
|
return x.Predicate
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type NamespaceIdPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceIds []string `protobuf:"bytes,1,rep,name=namespace_ids,json=namespaceIds,proto3" json:"namespace_ids,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *NamespaceIdPredicateAttributes) Reset() {
|
|
*x = NamespaceIdPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *NamespaceIdPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*NamespaceIdPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *NamespaceIdPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[6]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use NamespaceIdPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*NamespaceIdPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *NamespaceIdPredicateAttributes) GetNamespaceIds() []string {
|
|
if x != nil {
|
|
return x.NamespaceIds
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type TaskTypePredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskTypes []v1.TaskType `protobuf:"varint,1,rep,packed,name=task_types,json=taskTypes,proto3,enum=temporal.server.api.enums.v1.TaskType" json:"task_types,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TaskTypePredicateAttributes) Reset() {
|
|
*x = TaskTypePredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TaskTypePredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TaskTypePredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *TaskTypePredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[7]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TaskTypePredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*TaskTypePredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *TaskTypePredicateAttributes) GetTaskTypes() []v1.TaskType {
|
|
if x != nil {
|
|
return x.TaskTypes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type DestinationPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Destinations []string `protobuf:"bytes,1,rep,name=destinations,proto3" json:"destinations,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DestinationPredicateAttributes) Reset() {
|
|
*x = DestinationPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DestinationPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DestinationPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *DestinationPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[8]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DestinationPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*DestinationPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (x *DestinationPredicateAttributes) GetDestinations() []string {
|
|
if x != nil {
|
|
return x.Destinations
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type OutboundTaskGroupPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Groups []string `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *OutboundTaskGroupPredicateAttributes) Reset() {
|
|
*x = OutboundTaskGroupPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *OutboundTaskGroupPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*OutboundTaskGroupPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *OutboundTaskGroupPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[9]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use OutboundTaskGroupPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*OutboundTaskGroupPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *OutboundTaskGroupPredicateAttributes) GetGroups() []string {
|
|
if x != nil {
|
|
return x.Groups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type OutboundTaskPredicateAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Groups []*OutboundTaskPredicateAttributes_Group `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes) Reset() {
|
|
*x = OutboundTaskPredicateAttributes{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[10]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*OutboundTaskPredicateAttributes) ProtoMessage() {}
|
|
|
|
func (x *OutboundTaskPredicateAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[10]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use OutboundTaskPredicateAttributes.ProtoReflect.Descriptor instead.
|
|
func (*OutboundTaskPredicateAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{10}
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes) GetGroups() []*OutboundTaskPredicateAttributes_Group {
|
|
if x != nil {
|
|
return x.Groups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type OutboundTaskPredicateAttributes_Group struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskGroup string `protobuf:"bytes,1,opt,name=task_group,json=taskGroup,proto3" json:"task_group,omitempty"`
|
|
NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
Destination string `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes_Group) Reset() {
|
|
*x = OutboundTaskPredicateAttributes_Group{}
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[11]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes_Group) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*OutboundTaskPredicateAttributes_Group) ProtoMessage() {}
|
|
|
|
func (x *OutboundTaskPredicateAttributes_Group) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[11]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use OutboundTaskPredicateAttributes_Group.ProtoReflect.Descriptor instead.
|
|
func (*OutboundTaskPredicateAttributes_Group) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP(), []int{10, 0}
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes_Group) GetTaskGroup() string {
|
|
if x != nil {
|
|
return x.TaskGroup
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes_Group) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *OutboundTaskPredicateAttributes_Group) GetDestination() string {
|
|
if x != nil {
|
|
return x.Destination
|
|
}
|
|
return ""
|
|
}
|
|
|
|
var File_temporal_server_api_persistence_v1_predicates_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_api_persistence_v1_predicates_proto_rawDesc = "" +
|
|
"\n" +
|
|
"3temporal/server/api/persistence/v1/predicates.proto\x12\"temporal.server.api.persistence.v1\x1a,temporal/server/api/enums/v1/predicate.proto\x1a'temporal/server/api/enums/v1/task.proto\"\xc1\v\n" +
|
|
"\tPredicate\x12R\n" +
|
|
"\x0epredicate_type\x18\x01 \x01(\x0e2+.temporal.server.api.enums.v1.PredicateTypeR\rpredicateType\x12\x88\x01\n" +
|
|
"\x1euniversal_predicate_attributes\x18\x02 \x01(\v2@.temporal.server.api.persistence.v1.UniversalPredicateAttributesH\x00R\x1cuniversalPredicateAttributes\x12|\n" +
|
|
"\x1aempty_predicate_attributes\x18\x03 \x01(\v2<.temporal.server.api.persistence.v1.EmptyPredicateAttributesH\x00R\x18emptyPredicateAttributes\x12v\n" +
|
|
"\x18and_predicate_attributes\x18\x04 \x01(\v2:.temporal.server.api.persistence.v1.AndPredicateAttributesH\x00R\x16andPredicateAttributes\x12s\n" +
|
|
"\x17or_predicate_attributes\x18\x05 \x01(\v29.temporal.server.api.persistence.v1.OrPredicateAttributesH\x00R\x15orPredicateAttributes\x12v\n" +
|
|
"\x18not_predicate_attributes\x18\x06 \x01(\v2:.temporal.server.api.persistence.v1.NotPredicateAttributesH\x00R\x16notPredicateAttributes\x12\x8f\x01\n" +
|
|
"!namespace_id_predicate_attributes\x18\a \x01(\v2B.temporal.server.api.persistence.v1.NamespaceIdPredicateAttributesH\x00R\x1enamespaceIdPredicateAttributes\x12\x86\x01\n" +
|
|
"\x1etask_type_predicate_attributes\x18\b \x01(\v2?.temporal.server.api.persistence.v1.TaskTypePredicateAttributesH\x00R\x1btaskTypePredicateAttributes\x12\x8e\x01\n" +
|
|
" destination_predicate_attributes\x18\t \x01(\v2B.temporal.server.api.persistence.v1.DestinationPredicateAttributesH\x00R\x1edestinationPredicateAttributes\x12\xa2\x01\n" +
|
|
"(outbound_task_group_predicate_attributes\x18\n" +
|
|
" \x01(\v2H.temporal.server.api.persistence.v1.OutboundTaskGroupPredicateAttributesH\x00R$outboundTaskGroupPredicateAttributes\x12\x92\x01\n" +
|
|
"\"outbound_task_predicate_attributes\x18\v \x01(\v2C.temporal.server.api.persistence.v1.OutboundTaskPredicateAttributesH\x00R\x1foutboundTaskPredicateAttributesB\f\n" +
|
|
"\n" +
|
|
"attributes\"\x1e\n" +
|
|
"\x1cUniversalPredicateAttributes\"\x1a\n" +
|
|
"\x18EmptyPredicateAttributes\"g\n" +
|
|
"\x16AndPredicateAttributes\x12M\n" +
|
|
"\n" +
|
|
"predicates\x18\x01 \x03(\v2-.temporal.server.api.persistence.v1.PredicateR\n" +
|
|
"predicates\"f\n" +
|
|
"\x15OrPredicateAttributes\x12M\n" +
|
|
"\n" +
|
|
"predicates\x18\x01 \x03(\v2-.temporal.server.api.persistence.v1.PredicateR\n" +
|
|
"predicates\"e\n" +
|
|
"\x16NotPredicateAttributes\x12K\n" +
|
|
"\tpredicate\x18\x01 \x01(\v2-.temporal.server.api.persistence.v1.PredicateR\tpredicate\"E\n" +
|
|
"\x1eNamespaceIdPredicateAttributes\x12#\n" +
|
|
"\rnamespace_ids\x18\x01 \x03(\tR\fnamespaceIds\"d\n" +
|
|
"\x1bTaskTypePredicateAttributes\x12E\n" +
|
|
"\n" +
|
|
"task_types\x18\x01 \x03(\x0e2&.temporal.server.api.enums.v1.TaskTypeR\ttaskTypes\"D\n" +
|
|
"\x1eDestinationPredicateAttributes\x12\"\n" +
|
|
"\fdestinations\x18\x01 \x03(\tR\fdestinations\">\n" +
|
|
"$OutboundTaskGroupPredicateAttributes\x12\x16\n" +
|
|
"\x06groups\x18\x01 \x03(\tR\x06groups\"\xf1\x01\n" +
|
|
"\x1fOutboundTaskPredicateAttributes\x12a\n" +
|
|
"\x06groups\x18\x01 \x03(\v2I.temporal.server.api.persistence.v1.OutboundTaskPredicateAttributes.GroupR\x06groups\x1ak\n" +
|
|
"\x05Group\x12\x1d\n" +
|
|
"\n" +
|
|
"task_group\x18\x01 \x01(\tR\ttaskGroup\x12!\n" +
|
|
"\fnamespace_id\x18\x02 \x01(\tR\vnamespaceId\x12 \n" +
|
|
"\vdestination\x18\x03 \x01(\tR\vdestinationB6Z4go.temporal.io/server/api/persistence/v1;persistenceb\x06proto3"
|
|
|
|
var (
|
|
file_temporal_server_api_persistence_v1_predicates_proto_rawDescOnce sync.Once
|
|
file_temporal_server_api_persistence_v1_predicates_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_api_persistence_v1_predicates_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_api_persistence_v1_predicates_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc), len(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc)))
|
|
})
|
|
return file_temporal_server_api_persistence_v1_predicates_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_api_persistence_v1_predicates_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
|
|
var file_temporal_server_api_persistence_v1_predicates_proto_goTypes = []any{
|
|
(*Predicate)(nil), // 0: temporal.server.api.persistence.v1.Predicate
|
|
(*UniversalPredicateAttributes)(nil), // 1: temporal.server.api.persistence.v1.UniversalPredicateAttributes
|
|
(*EmptyPredicateAttributes)(nil), // 2: temporal.server.api.persistence.v1.EmptyPredicateAttributes
|
|
(*AndPredicateAttributes)(nil), // 3: temporal.server.api.persistence.v1.AndPredicateAttributes
|
|
(*OrPredicateAttributes)(nil), // 4: temporal.server.api.persistence.v1.OrPredicateAttributes
|
|
(*NotPredicateAttributes)(nil), // 5: temporal.server.api.persistence.v1.NotPredicateAttributes
|
|
(*NamespaceIdPredicateAttributes)(nil), // 6: temporal.server.api.persistence.v1.NamespaceIdPredicateAttributes
|
|
(*TaskTypePredicateAttributes)(nil), // 7: temporal.server.api.persistence.v1.TaskTypePredicateAttributes
|
|
(*DestinationPredicateAttributes)(nil), // 8: temporal.server.api.persistence.v1.DestinationPredicateAttributes
|
|
(*OutboundTaskGroupPredicateAttributes)(nil), // 9: temporal.server.api.persistence.v1.OutboundTaskGroupPredicateAttributes
|
|
(*OutboundTaskPredicateAttributes)(nil), // 10: temporal.server.api.persistence.v1.OutboundTaskPredicateAttributes
|
|
(*OutboundTaskPredicateAttributes_Group)(nil), // 11: temporal.server.api.persistence.v1.OutboundTaskPredicateAttributes.Group
|
|
(v1.PredicateType)(0), // 12: temporal.server.api.enums.v1.PredicateType
|
|
(v1.TaskType)(0), // 13: temporal.server.api.enums.v1.TaskType
|
|
}
|
|
var file_temporal_server_api_persistence_v1_predicates_proto_depIdxs = []int32{
|
|
12, // 0: temporal.server.api.persistence.v1.Predicate.predicate_type:type_name -> temporal.server.api.enums.v1.PredicateType
|
|
1, // 1: temporal.server.api.persistence.v1.Predicate.universal_predicate_attributes:type_name -> temporal.server.api.persistence.v1.UniversalPredicateAttributes
|
|
2, // 2: temporal.server.api.persistence.v1.Predicate.empty_predicate_attributes:type_name -> temporal.server.api.persistence.v1.EmptyPredicateAttributes
|
|
3, // 3: temporal.server.api.persistence.v1.Predicate.and_predicate_attributes:type_name -> temporal.server.api.persistence.v1.AndPredicateAttributes
|
|
4, // 4: temporal.server.api.persistence.v1.Predicate.or_predicate_attributes:type_name -> temporal.server.api.persistence.v1.OrPredicateAttributes
|
|
5, // 5: temporal.server.api.persistence.v1.Predicate.not_predicate_attributes:type_name -> temporal.server.api.persistence.v1.NotPredicateAttributes
|
|
6, // 6: temporal.server.api.persistence.v1.Predicate.namespace_id_predicate_attributes:type_name -> temporal.server.api.persistence.v1.NamespaceIdPredicateAttributes
|
|
7, // 7: temporal.server.api.persistence.v1.Predicate.task_type_predicate_attributes:type_name -> temporal.server.api.persistence.v1.TaskTypePredicateAttributes
|
|
8, // 8: temporal.server.api.persistence.v1.Predicate.destination_predicate_attributes:type_name -> temporal.server.api.persistence.v1.DestinationPredicateAttributes
|
|
9, // 9: temporal.server.api.persistence.v1.Predicate.outbound_task_group_predicate_attributes:type_name -> temporal.server.api.persistence.v1.OutboundTaskGroupPredicateAttributes
|
|
10, // 10: temporal.server.api.persistence.v1.Predicate.outbound_task_predicate_attributes:type_name -> temporal.server.api.persistence.v1.OutboundTaskPredicateAttributes
|
|
0, // 11: temporal.server.api.persistence.v1.AndPredicateAttributes.predicates:type_name -> temporal.server.api.persistence.v1.Predicate
|
|
0, // 12: temporal.server.api.persistence.v1.OrPredicateAttributes.predicates:type_name -> temporal.server.api.persistence.v1.Predicate
|
|
0, // 13: temporal.server.api.persistence.v1.NotPredicateAttributes.predicate:type_name -> temporal.server.api.persistence.v1.Predicate
|
|
13, // 14: temporal.server.api.persistence.v1.TaskTypePredicateAttributes.task_types:type_name -> temporal.server.api.enums.v1.TaskType
|
|
11, // 15: temporal.server.api.persistence.v1.OutboundTaskPredicateAttributes.groups:type_name -> temporal.server.api.persistence.v1.OutboundTaskPredicateAttributes.Group
|
|
16, // [16:16] is the sub-list for method output_type
|
|
16, // [16:16] is the sub-list for method input_type
|
|
16, // [16:16] is the sub-list for extension type_name
|
|
16, // [16:16] is the sub-list for extension extendee
|
|
0, // [0:16] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_api_persistence_v1_predicates_proto_init() }
|
|
func file_temporal_server_api_persistence_v1_predicates_proto_init() {
|
|
if File_temporal_server_api_persistence_v1_predicates_proto != nil {
|
|
return
|
|
}
|
|
file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0].OneofWrappers = []any{
|
|
(*Predicate_UniversalPredicateAttributes)(nil),
|
|
(*Predicate_EmptyPredicateAttributes)(nil),
|
|
(*Predicate_AndPredicateAttributes)(nil),
|
|
(*Predicate_OrPredicateAttributes)(nil),
|
|
(*Predicate_NotPredicateAttributes)(nil),
|
|
(*Predicate_NamespaceIdPredicateAttributes)(nil),
|
|
(*Predicate_TaskTypePredicateAttributes)(nil),
|
|
(*Predicate_DestinationPredicateAttributes)(nil),
|
|
(*Predicate_OutboundTaskGroupPredicateAttributes)(nil),
|
|
(*Predicate_OutboundTaskPredicateAttributes)(nil),
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc), len(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 12,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_api_persistence_v1_predicates_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_api_persistence_v1_predicates_proto_depIdxs,
|
|
MessageInfos: file_temporal_server_api_persistence_v1_predicates_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_api_persistence_v1_predicates_proto = out.File
|
|
file_temporal_server_api_persistence_v1_predicates_proto_goTypes = nil
|
|
file_temporal_server_api_persistence_v1_predicates_proto_depIdxs = nil
|
|
}
|