Files
tasks/api/persistence/v1/predicates.pb.go
Alex ShtinandGitHub 8e8f1b0f7c Remove license header from every file (#7689)
## 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`.
2025-05-01 18:50:21 -07:00

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
}