// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        (unknown)
// source: api/message.proto

// NOTE run `buf generate` from `cluster/proto` to regenerate code

package api

import (
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

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 ApplyRequest_Type int32

const (
	ApplyRequest_TYPE_UNSPECIFIED                                                ApplyRequest_Type = 0
	ApplyRequest_TYPE_ADD_CLASS                                                  ApplyRequest_Type = 1
	ApplyRequest_TYPE_UPDATE_CLASS                                               ApplyRequest_Type = 2
	ApplyRequest_TYPE_DELETE_CLASS                                               ApplyRequest_Type = 3
	ApplyRequest_TYPE_RESTORE_CLASS                                              ApplyRequest_Type = 4
	ApplyRequest_TYPE_ADD_PROPERTY                                               ApplyRequest_Type = 5
	ApplyRequest_TYPE_UPDATE_SHARD_STATUS                                        ApplyRequest_Type = 10
	ApplyRequest_TYPE_ADD_REPLICA_TO_SHARD                                       ApplyRequest_Type = 11
	ApplyRequest_TYPE_DELETE_REPLICA_FROM_SHARD                                  ApplyRequest_Type = 12
	ApplyRequest_TYPE_ADD_TENANT                                                 ApplyRequest_Type = 16
	ApplyRequest_TYPE_UPDATE_TENANT                                              ApplyRequest_Type = 17
	ApplyRequest_TYPE_DELETE_TENANT                                              ApplyRequest_Type = 18
	ApplyRequest_TYPE_TENANT_PROCESS                                             ApplyRequest_Type = 19
	ApplyRequest_TYPE_CREATE_ALIAS                                               ApplyRequest_Type = 40
	ApplyRequest_TYPE_REPLACE_ALIAS                                              ApplyRequest_Type = 41
	ApplyRequest_TYPE_DELETE_ALIAS                                               ApplyRequest_Type = 42
	ApplyRequest_TYPE_UPSERT_ROLES_PERMISSIONS                                   ApplyRequest_Type = 60
	ApplyRequest_TYPE_DELETE_ROLES                                               ApplyRequest_Type = 61
	ApplyRequest_TYPE_REMOVE_PERMISSIONS                                         ApplyRequest_Type = 62
	ApplyRequest_TYPE_ADD_ROLES_FOR_USER                                         ApplyRequest_Type = 63
	ApplyRequest_TYPE_REVOKE_ROLES_FOR_USER                                      ApplyRequest_Type = 64
	ApplyRequest_TYPE_UPSERT_USER                                                ApplyRequest_Type = 80
	ApplyRequest_TYPE_DELETE_USER                                                ApplyRequest_Type = 81
	ApplyRequest_TYPE_ROTATE_USER_API_KEY                                        ApplyRequest_Type = 82
	ApplyRequest_TYPE_SUSPEND_USER                                               ApplyRequest_Type = 83
	ApplyRequest_TYPE_ACTIVATE_USER                                              ApplyRequest_Type = 84
	ApplyRequest_TYPE_CREATE_USER_WITH_KEY                                       ApplyRequest_Type = 85
	ApplyRequest_TYPE_REPLICATION_REPLICATE                                      ApplyRequest_Type = 200
	ApplyRequest_TYPE_REPLICATION_REPLICATE_UPDATE_STATE                         ApplyRequest_Type = 201
	ApplyRequest_TYPE_REPLICATION_REPLICATE_REGISTER_ERROR                       ApplyRequest_Type = 202
	ApplyRequest_TYPE_REPLICATION_REPLICATE_CANCEL                               ApplyRequest_Type = 203
	ApplyRequest_TYPE_REPLICATION_REPLICATE_DELETE                               ApplyRequest_Type = 204
	ApplyRequest_TYPE_REPLICATION_REPLICATE_REMOVE                               ApplyRequest_Type = 205
	ApplyRequest_TYPE_REPLICATION_REPLICATE_CANCELLATION_COMPLETE                ApplyRequest_Type = 206
	ApplyRequest_TYPE_REPLICATION_REPLICATE_DELETE_ALL                           ApplyRequest_Type = 207
	ApplyRequest_TYPE_REPLICATION_REPLICATE_DELETE_BY_COLLECTION                 ApplyRequest_Type = 208
	ApplyRequest_TYPE_REPLICATION_REPLICATE_DELETE_BY_TENANTS                    ApplyRequest_Type = 209
	ApplyRequest_TYPE_REPLICATION_REPLICATE_SYNC_SHARD                           ApplyRequest_Type = 210
	ApplyRequest_TYPE_REPLICATION_REGISTER_SCHEMA_VERSION                        ApplyRequest_Type = 211
	ApplyRequest_TYPE_REPLICATION_REPLICATE_ADD_REPLICA_TO_SHARD                 ApplyRequest_Type = 212
	ApplyRequest_TYPE_REPLICATION_REPLICATE_FORCE_DELETE_ALL                     ApplyRequest_Type = 220
	ApplyRequest_TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION           ApplyRequest_Type = 221
	ApplyRequest_TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION_AND_SHARD ApplyRequest_Type = 222
	ApplyRequest_TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_TARGET_NODE          ApplyRequest_Type = 223
	ApplyRequest_TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_UUID                 ApplyRequest_Type = 224
	ApplyRequest_TYPE_DISTRIBUTED_TASK_ADD                                       ApplyRequest_Type = 300
	ApplyRequest_TYPE_DISTRIBUTED_TASK_CANCEL                                    ApplyRequest_Type = 301
	ApplyRequest_TYPE_DISTRIBUTED_TASK_RECORD_NODE_COMPLETED                     ApplyRequest_Type = 302
	ApplyRequest_TYPE_DISTRIBUTED_TASK_CLEAN_UP                                  ApplyRequest_Type = 303
)

// Enum value maps for ApplyRequest_Type.
var (
	ApplyRequest_Type_name = map[int32]string{
		0:   "TYPE_UNSPECIFIED",
		1:   "TYPE_ADD_CLASS",
		2:   "TYPE_UPDATE_CLASS",
		3:   "TYPE_DELETE_CLASS",
		4:   "TYPE_RESTORE_CLASS",
		5:   "TYPE_ADD_PROPERTY",
		10:  "TYPE_UPDATE_SHARD_STATUS",
		11:  "TYPE_ADD_REPLICA_TO_SHARD",
		12:  "TYPE_DELETE_REPLICA_FROM_SHARD",
		16:  "TYPE_ADD_TENANT",
		17:  "TYPE_UPDATE_TENANT",
		18:  "TYPE_DELETE_TENANT",
		19:  "TYPE_TENANT_PROCESS",
		40:  "TYPE_CREATE_ALIAS",
		41:  "TYPE_REPLACE_ALIAS",
		42:  "TYPE_DELETE_ALIAS",
		60:  "TYPE_UPSERT_ROLES_PERMISSIONS",
		61:  "TYPE_DELETE_ROLES",
		62:  "TYPE_REMOVE_PERMISSIONS",
		63:  "TYPE_ADD_ROLES_FOR_USER",
		64:  "TYPE_REVOKE_ROLES_FOR_USER",
		80:  "TYPE_UPSERT_USER",
		81:  "TYPE_DELETE_USER",
		82:  "TYPE_ROTATE_USER_API_KEY",
		83:  "TYPE_SUSPEND_USER",
		84:  "TYPE_ACTIVATE_USER",
		85:  "TYPE_CREATE_USER_WITH_KEY",
		200: "TYPE_REPLICATION_REPLICATE",
		201: "TYPE_REPLICATION_REPLICATE_UPDATE_STATE",
		202: "TYPE_REPLICATION_REPLICATE_REGISTER_ERROR",
		203: "TYPE_REPLICATION_REPLICATE_CANCEL",
		204: "TYPE_REPLICATION_REPLICATE_DELETE",
		205: "TYPE_REPLICATION_REPLICATE_REMOVE",
		206: "TYPE_REPLICATION_REPLICATE_CANCELLATION_COMPLETE",
		207: "TYPE_REPLICATION_REPLICATE_DELETE_ALL",
		208: "TYPE_REPLICATION_REPLICATE_DELETE_BY_COLLECTION",
		209: "TYPE_REPLICATION_REPLICATE_DELETE_BY_TENANTS",
		210: "TYPE_REPLICATION_REPLICATE_SYNC_SHARD",
		211: "TYPE_REPLICATION_REGISTER_SCHEMA_VERSION",
		212: "TYPE_REPLICATION_REPLICATE_ADD_REPLICA_TO_SHARD",
		220: "TYPE_REPLICATION_REPLICATE_FORCE_DELETE_ALL",
		221: "TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION",
		222: "TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION_AND_SHARD",
		223: "TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_TARGET_NODE",
		224: "TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_UUID",
		300: "TYPE_DISTRIBUTED_TASK_ADD",
		301: "TYPE_DISTRIBUTED_TASK_CANCEL",
		302: "TYPE_DISTRIBUTED_TASK_RECORD_NODE_COMPLETED",
		303: "TYPE_DISTRIBUTED_TASK_CLEAN_UP",
	}
	ApplyRequest_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":                                                0,
		"TYPE_ADD_CLASS":                                                  1,
		"TYPE_UPDATE_CLASS":                                               2,
		"TYPE_DELETE_CLASS":                                               3,
		"TYPE_RESTORE_CLASS":                                              4,
		"TYPE_ADD_PROPERTY":                                               5,
		"TYPE_UPDATE_SHARD_STATUS":                                        10,
		"TYPE_ADD_REPLICA_TO_SHARD":                                       11,
		"TYPE_DELETE_REPLICA_FROM_SHARD":                                  12,
		"TYPE_ADD_TENANT":                                                 16,
		"TYPE_UPDATE_TENANT":                                              17,
		"TYPE_DELETE_TENANT":                                              18,
		"TYPE_TENANT_PROCESS":                                             19,
		"TYPE_CREATE_ALIAS":                                               40,
		"TYPE_REPLACE_ALIAS":                                              41,
		"TYPE_DELETE_ALIAS":                                               42,
		"TYPE_UPSERT_ROLES_PERMISSIONS":                                   60,
		"TYPE_DELETE_ROLES":                                               61,
		"TYPE_REMOVE_PERMISSIONS":                                         62,
		"TYPE_ADD_ROLES_FOR_USER":                                         63,
		"TYPE_REVOKE_ROLES_FOR_USER":                                      64,
		"TYPE_UPSERT_USER":                                                80,
		"TYPE_DELETE_USER":                                                81,
		"TYPE_ROTATE_USER_API_KEY":                                        82,
		"TYPE_SUSPEND_USER":                                               83,
		"TYPE_ACTIVATE_USER":                                              84,
		"TYPE_CREATE_USER_WITH_KEY":                                       85,
		"TYPE_REPLICATION_REPLICATE":                                      200,
		"TYPE_REPLICATION_REPLICATE_UPDATE_STATE":                         201,
		"TYPE_REPLICATION_REPLICATE_REGISTER_ERROR":                       202,
		"TYPE_REPLICATION_REPLICATE_CANCEL":                               203,
		"TYPE_REPLICATION_REPLICATE_DELETE":                               204,
		"TYPE_REPLICATION_REPLICATE_REMOVE":                               205,
		"TYPE_REPLICATION_REPLICATE_CANCELLATION_COMPLETE":                206,
		"TYPE_REPLICATION_REPLICATE_DELETE_ALL":                           207,
		"TYPE_REPLICATION_REPLICATE_DELETE_BY_COLLECTION":                 208,
		"TYPE_REPLICATION_REPLICATE_DELETE_BY_TENANTS":                    209,
		"TYPE_REPLICATION_REPLICATE_SYNC_SHARD":                           210,
		"TYPE_REPLICATION_REGISTER_SCHEMA_VERSION":                        211,
		"TYPE_REPLICATION_REPLICATE_ADD_REPLICA_TO_SHARD":                 212,
		"TYPE_REPLICATION_REPLICATE_FORCE_DELETE_ALL":                     220,
		"TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION":           221,
		"TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION_AND_SHARD": 222,
		"TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_TARGET_NODE":          223,
		"TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_UUID":                 224,
		"TYPE_DISTRIBUTED_TASK_ADD":                                       300,
		"TYPE_DISTRIBUTED_TASK_CANCEL":                                    301,
		"TYPE_DISTRIBUTED_TASK_RECORD_NODE_COMPLETED":                     302,
		"TYPE_DISTRIBUTED_TASK_CLEAN_UP":                                  303,
	}
)

func (x ApplyRequest_Type) Enum() *ApplyRequest_Type {
	p := new(ApplyRequest_Type)
	*p = x
	return p
}

func (x ApplyRequest_Type) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (ApplyRequest_Type) Descriptor() protoreflect.EnumDescriptor {
	return file_api_message_proto_enumTypes[0].Descriptor()
}

func (ApplyRequest_Type) Type() protoreflect.EnumType {
	return &file_api_message_proto_enumTypes[0]
}

func (x ApplyRequest_Type) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use ApplyRequest_Type.Descriptor instead.
func (ApplyRequest_Type) EnumDescriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{6, 0}
}

type QueryRequest_Type int32

const (
	QueryRequest_TYPE_UNSPECIFIED                                     QueryRequest_Type = 0
	QueryRequest_TYPE_GET_CLASSES                                     QueryRequest_Type = 1
	QueryRequest_TYPE_GET_SCHEMA                                      QueryRequest_Type = 2
	QueryRequest_TYPE_GET_TENANTS                                     QueryRequest_Type = 3
	QueryRequest_TYPE_GET_SHARD_OWNER                                 QueryRequest_Type = 4
	QueryRequest_TYPE_GET_TENANTS_SHARDS                              QueryRequest_Type = 5
	QueryRequest_TYPE_GET_SHARDING_STATE                              QueryRequest_Type = 6
	QueryRequest_TYPE_GET_CLASS_VERSIONS                              QueryRequest_Type = 7
	QueryRequest_TYPE_GET_COLLECTIONS_COUNT                           QueryRequest_Type = 8
	QueryRequest_TYPE_HAS_PERMISSION                                  QueryRequest_Type = 30
	QueryRequest_TYPE_GET_ROLES                                       QueryRequest_Type = 31
	QueryRequest_TYPE_GET_ROLES_FOR_USER                              QueryRequest_Type = 32
	QueryRequest_TYPE_GET_USERS_FOR_ROLE                              QueryRequest_Type = 33
	QueryRequest_TYPE_GET_USERS_OR_GROUPS_WITH_ROLES                  QueryRequest_Type = 34
	QueryRequest_TYPE_GET_USERS                                       QueryRequest_Type = 61
	QueryRequest_TYPE_USER_IDENTIFIER_EXISTS                          QueryRequest_Type = 62
	QueryRequest_TYPE_RESOLVE_ALIAS                                   QueryRequest_Type = 100
	QueryRequest_TYPE_GET_ALIASES                                     QueryRequest_Type = 101
	QueryRequest_TYPE_GET_REPLICATION_DETAILS                         QueryRequest_Type = 200
	QueryRequest_TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION           QueryRequest_Type = 201
	QueryRequest_TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION_AND_SHARD QueryRequest_Type = 202
	QueryRequest_TYPE_GET_REPLICATION_DETAILS_BY_TARGET_NODE          QueryRequest_Type = 203
	QueryRequest_TYPE_GET_SHARDING_STATE_BY_COLLECTION                QueryRequest_Type = 204
	QueryRequest_TYPE_GET_SHARDING_STATE_BY_COLLECTION_AND_SHARD      QueryRequest_Type = 205
	QueryRequest_TYPE_GET_ALL_REPLICATION_DETAILS                     QueryRequest_Type = 206
	QueryRequest_TYPE_GET_REPLICATION_OPERATION_STATE                 QueryRequest_Type = 207
	QueryRequest_TYPE_GET_REPLICATION_SCALE_PLAN                      QueryRequest_Type = 208
	QueryRequest_TYPE_DISTRIBUTED_TASK_LIST                           QueryRequest_Type = 300
)

// Enum value maps for QueryRequest_Type.
var (
	QueryRequest_Type_name = map[int32]string{
		0:   "TYPE_UNSPECIFIED",
		1:   "TYPE_GET_CLASSES",
		2:   "TYPE_GET_SCHEMA",
		3:   "TYPE_GET_TENANTS",
		4:   "TYPE_GET_SHARD_OWNER",
		5:   "TYPE_GET_TENANTS_SHARDS",
		6:   "TYPE_GET_SHARDING_STATE",
		7:   "TYPE_GET_CLASS_VERSIONS",
		8:   "TYPE_GET_COLLECTIONS_COUNT",
		30:  "TYPE_HAS_PERMISSION",
		31:  "TYPE_GET_ROLES",
		32:  "TYPE_GET_ROLES_FOR_USER",
		33:  "TYPE_GET_USERS_FOR_ROLE",
		34:  "TYPE_GET_USERS_OR_GROUPS_WITH_ROLES",
		61:  "TYPE_GET_USERS",
		62:  "TYPE_USER_IDENTIFIER_EXISTS",
		100: "TYPE_RESOLVE_ALIAS",
		101: "TYPE_GET_ALIASES",
		200: "TYPE_GET_REPLICATION_DETAILS",
		201: "TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION",
		202: "TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION_AND_SHARD",
		203: "TYPE_GET_REPLICATION_DETAILS_BY_TARGET_NODE",
		204: "TYPE_GET_SHARDING_STATE_BY_COLLECTION",
		205: "TYPE_GET_SHARDING_STATE_BY_COLLECTION_AND_SHARD",
		206: "TYPE_GET_ALL_REPLICATION_DETAILS",
		207: "TYPE_GET_REPLICATION_OPERATION_STATE",
		208: "TYPE_GET_REPLICATION_SCALE_PLAN",
		300: "TYPE_DISTRIBUTED_TASK_LIST",
	}
	QueryRequest_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":                                     0,
		"TYPE_GET_CLASSES":                                     1,
		"TYPE_GET_SCHEMA":                                      2,
		"TYPE_GET_TENANTS":                                     3,
		"TYPE_GET_SHARD_OWNER":                                 4,
		"TYPE_GET_TENANTS_SHARDS":                              5,
		"TYPE_GET_SHARDING_STATE":                              6,
		"TYPE_GET_CLASS_VERSIONS":                              7,
		"TYPE_GET_COLLECTIONS_COUNT":                           8,
		"TYPE_HAS_PERMISSION":                                  30,
		"TYPE_GET_ROLES":                                       31,
		"TYPE_GET_ROLES_FOR_USER":                              32,
		"TYPE_GET_USERS_FOR_ROLE":                              33,
		"TYPE_GET_USERS_OR_GROUPS_WITH_ROLES":                  34,
		"TYPE_GET_USERS":                                       61,
		"TYPE_USER_IDENTIFIER_EXISTS":                          62,
		"TYPE_RESOLVE_ALIAS":                                   100,
		"TYPE_GET_ALIASES":                                     101,
		"TYPE_GET_REPLICATION_DETAILS":                         200,
		"TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION":           201,
		"TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION_AND_SHARD": 202,
		"TYPE_GET_REPLICATION_DETAILS_BY_TARGET_NODE":          203,
		"TYPE_GET_SHARDING_STATE_BY_COLLECTION":                204,
		"TYPE_GET_SHARDING_STATE_BY_COLLECTION_AND_SHARD":      205,
		"TYPE_GET_ALL_REPLICATION_DETAILS":                     206,
		"TYPE_GET_REPLICATION_OPERATION_STATE":                 207,
		"TYPE_GET_REPLICATION_SCALE_PLAN":                      208,
		"TYPE_DISTRIBUTED_TASK_LIST":                           300,
	}
)

func (x QueryRequest_Type) Enum() *QueryRequest_Type {
	p := new(QueryRequest_Type)
	*p = x
	return p
}

func (x QueryRequest_Type) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (QueryRequest_Type) Descriptor() protoreflect.EnumDescriptor {
	return file_api_message_proto_enumTypes[1].Descriptor()
}

func (QueryRequest_Type) Type() protoreflect.EnumType {
	return &file_api_message_proto_enumTypes[1]
}

func (x QueryRequest_Type) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use QueryRequest_Type.Descriptor instead.
func (QueryRequest_Type) EnumDescriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{8, 0}
}

type TenantsProcess_Op int32

const (
	TenantsProcess_OP_UNSPECIFIED TenantsProcess_Op = 0
	TenantsProcess_OP_START       TenantsProcess_Op = 1
	TenantsProcess_OP_DONE        TenantsProcess_Op = 2
	TenantsProcess_OP_ABORT       TenantsProcess_Op = 3
)

// Enum value maps for TenantsProcess_Op.
var (
	TenantsProcess_Op_name = map[int32]string{
		0: "OP_UNSPECIFIED",
		1: "OP_START",
		2: "OP_DONE",
		3: "OP_ABORT",
	}
	TenantsProcess_Op_value = map[string]int32{
		"OP_UNSPECIFIED": 0,
		"OP_START":       1,
		"OP_DONE":        2,
		"OP_ABORT":       3,
	}
)

func (x TenantsProcess_Op) Enum() *TenantsProcess_Op {
	p := new(TenantsProcess_Op)
	*p = x
	return p
}

func (x TenantsProcess_Op) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (TenantsProcess_Op) Descriptor() protoreflect.EnumDescriptor {
	return file_api_message_proto_enumTypes[2].Descriptor()
}

func (TenantsProcess_Op) Type() protoreflect.EnumType {
	return &file_api_message_proto_enumTypes[2]
}

func (x TenantsProcess_Op) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use TenantsProcess_Op.Descriptor instead.
func (TenantsProcess_Op) EnumDescriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{12, 0}
}

type TenantProcessRequest_Action int32

const (
	TenantProcessRequest_ACTION_UNSPECIFIED TenantProcessRequest_Action = 0
	TenantProcessRequest_ACTION_FREEZING    TenantProcessRequest_Action = 1
	TenantProcessRequest_ACTION_UNFREEZING  TenantProcessRequest_Action = 2
)

// Enum value maps for TenantProcessRequest_Action.
var (
	TenantProcessRequest_Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "ACTION_FREEZING",
		2: "ACTION_UNFREEZING",
	}
	TenantProcessRequest_Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"ACTION_FREEZING":    1,
		"ACTION_UNFREEZING":  2,
	}
)

func (x TenantProcessRequest_Action) Enum() *TenantProcessRequest_Action {
	p := new(TenantProcessRequest_Action)
	*p = x
	return p
}

func (x TenantProcessRequest_Action) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (TenantProcessRequest_Action) Descriptor() protoreflect.EnumDescriptor {
	return file_api_message_proto_enumTypes[3].Descriptor()
}

func (TenantProcessRequest_Action) Type() protoreflect.EnumType {
	return &file_api_message_proto_enumTypes[3]
}

func (x TenantProcessRequest_Action) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use TenantProcessRequest_Action.Descriptor instead.
func (TenantProcessRequest_Action) EnumDescriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{13, 0}
}

type JoinPeerRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string                 `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Voter         bool                   `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JoinPeerRequest) Reset() {
	*x = JoinPeerRequest{}
	mi := &file_api_message_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JoinPeerRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JoinPeerRequest) ProtoMessage() {}

func (x *JoinPeerRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 JoinPeerRequest.ProtoReflect.Descriptor instead.
func (*JoinPeerRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{0}
}

func (x *JoinPeerRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *JoinPeerRequest) GetAddress() string {
	if x != nil {
		return x.Address
	}
	return ""
}

func (x *JoinPeerRequest) GetVoter() bool {
	if x != nil {
		return x.Voter
	}
	return false
}

type JoinPeerResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Leader        string                 `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JoinPeerResponse) Reset() {
	*x = JoinPeerResponse{}
	mi := &file_api_message_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JoinPeerResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JoinPeerResponse) ProtoMessage() {}

func (x *JoinPeerResponse) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 JoinPeerResponse.ProtoReflect.Descriptor instead.
func (*JoinPeerResponse) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{1}
}

func (x *JoinPeerResponse) GetLeader() string {
	if x != nil {
		return x.Leader
	}
	return ""
}

type RemovePeerRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RemovePeerRequest) Reset() {
	*x = RemovePeerRequest{}
	mi := &file_api_message_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RemovePeerRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RemovePeerRequest) ProtoMessage() {}

func (x *RemovePeerRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 RemovePeerRequest.ProtoReflect.Descriptor instead.
func (*RemovePeerRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{2}
}

func (x *RemovePeerRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

type RemovePeerResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Leader        string                 `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RemovePeerResponse) Reset() {
	*x = RemovePeerResponse{}
	mi := &file_api_message_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RemovePeerResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RemovePeerResponse) ProtoMessage() {}

func (x *RemovePeerResponse) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 RemovePeerResponse.ProtoReflect.Descriptor instead.
func (*RemovePeerResponse) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{3}
}

func (x *RemovePeerResponse) GetLeader() string {
	if x != nil {
		return x.Leader
	}
	return ""
}

type NotifyPeerRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string                 `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *NotifyPeerRequest) Reset() {
	*x = NotifyPeerRequest{}
	mi := &file_api_message_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *NotifyPeerRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*NotifyPeerRequest) ProtoMessage() {}

func (x *NotifyPeerRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 NotifyPeerRequest.ProtoReflect.Descriptor instead.
func (*NotifyPeerRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{4}
}

func (x *NotifyPeerRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *NotifyPeerRequest) GetAddress() string {
	if x != nil {
		return x.Address
	}
	return ""
}

type NotifyPeerResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *NotifyPeerResponse) Reset() {
	*x = NotifyPeerResponse{}
	mi := &file_api_message_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *NotifyPeerResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*NotifyPeerResponse) ProtoMessage() {}

func (x *NotifyPeerResponse) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 NotifyPeerResponse.ProtoReflect.Descriptor instead.
func (*NotifyPeerResponse) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{5}
}

type ApplyRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Type          ApplyRequest_Type      `protobuf:"varint,1,opt,name=type,proto3,enum=weaviate.internal.cluster.ApplyRequest_Type" json:"type,omitempty"`
	Class         string                 `protobuf:"bytes,2,opt,name=class,proto3" json:"class,omitempty"`
	Version       uint64                 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	SubCommand    []byte                 `protobuf:"bytes,4,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ApplyRequest) Reset() {
	*x = ApplyRequest{}
	mi := &file_api_message_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ApplyRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ApplyRequest) ProtoMessage() {}

func (x *ApplyRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 ApplyRequest.ProtoReflect.Descriptor instead.
func (*ApplyRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{6}
}

func (x *ApplyRequest) GetType() ApplyRequest_Type {
	if x != nil {
		return x.Type
	}
	return ApplyRequest_TYPE_UNSPECIFIED
}

func (x *ApplyRequest) GetClass() string {
	if x != nil {
		return x.Class
	}
	return ""
}

func (x *ApplyRequest) GetVersion() uint64 {
	if x != nil {
		return x.Version
	}
	return 0
}

func (x *ApplyRequest) GetSubCommand() []byte {
	if x != nil {
		return x.SubCommand
	}
	return nil
}

type ApplyResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Version       uint64                 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Leader        string                 `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ApplyResponse) Reset() {
	*x = ApplyResponse{}
	mi := &file_api_message_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ApplyResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ApplyResponse) ProtoMessage() {}

func (x *ApplyResponse) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 ApplyResponse.ProtoReflect.Descriptor instead.
func (*ApplyResponse) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{7}
}

func (x *ApplyResponse) GetVersion() uint64 {
	if x != nil {
		return x.Version
	}
	return 0
}

func (x *ApplyResponse) GetLeader() string {
	if x != nil {
		return x.Leader
	}
	return ""
}

type QueryRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Type          QueryRequest_Type      `protobuf:"varint,1,opt,name=type,proto3,enum=weaviate.internal.cluster.QueryRequest_Type" json:"type,omitempty"`
	SubCommand    []byte                 `protobuf:"bytes,2,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *QueryRequest) Reset() {
	*x = QueryRequest{}
	mi := &file_api_message_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *QueryRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*QueryRequest) ProtoMessage() {}

func (x *QueryRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{8}
}

func (x *QueryRequest) GetType() QueryRequest_Type {
	if x != nil {
		return x.Type
	}
	return QueryRequest_TYPE_UNSPECIFIED
}

func (x *QueryRequest) GetSubCommand() []byte {
	if x != nil {
		return x.SubCommand
	}
	return nil
}

type QueryResponse struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Payload       []byte                 `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *QueryResponse) Reset() {
	*x = QueryResponse{}
	mi := &file_api_message_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *QueryResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*QueryResponse) ProtoMessage() {}

func (x *QueryResponse) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 QueryResponse.ProtoReflect.Descriptor instead.
func (*QueryResponse) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{9}
}

func (x *QueryResponse) GetPayload() []byte {
	if x != nil {
		return x.Payload
	}
	return nil
}

type AddTenantsRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ClusterNodes  []string               `protobuf:"bytes,1,rep,name=cluster_nodes,json=clusterNodes,proto3" json:"cluster_nodes,omitempty"`
	Tenants       []*Tenant              `protobuf:"bytes,2,rep,name=tenants,proto3" json:"tenants,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AddTenantsRequest) Reset() {
	*x = AddTenantsRequest{}
	mi := &file_api_message_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AddTenantsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AddTenantsRequest) ProtoMessage() {}

func (x *AddTenantsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 AddTenantsRequest.ProtoReflect.Descriptor instead.
func (*AddTenantsRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{10}
}

func (x *AddTenantsRequest) GetClusterNodes() []string {
	if x != nil {
		return x.ClusterNodes
	}
	return nil
}

func (x *AddTenantsRequest) GetTenants() []*Tenant {
	if x != nil {
		return x.Tenants
	}
	return nil
}

type UpdateTenantsRequest struct {
	state                 protoimpl.MessageState `protogen:"open.v1"`
	Tenants               []*Tenant              `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	ClusterNodes          []string               `protobuf:"bytes,2,rep,name=cluster_nodes,json=clusterNodes,proto3" json:"cluster_nodes,omitempty"`
	ImplicitUpdateRequest bool                   `protobuf:"varint,3,opt,name=implicit_update_request,json=implicitUpdateRequest,proto3" json:"implicit_update_request,omitempty"`
	unknownFields         protoimpl.UnknownFields
	sizeCache             protoimpl.SizeCache
}

func (x *UpdateTenantsRequest) Reset() {
	*x = UpdateTenantsRequest{}
	mi := &file_api_message_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *UpdateTenantsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*UpdateTenantsRequest) ProtoMessage() {}

func (x *UpdateTenantsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_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 UpdateTenantsRequest.ProtoReflect.Descriptor instead.
func (*UpdateTenantsRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{11}
}

func (x *UpdateTenantsRequest) GetTenants() []*Tenant {
	if x != nil {
		return x.Tenants
	}
	return nil
}

func (x *UpdateTenantsRequest) GetClusterNodes() []string {
	if x != nil {
		return x.ClusterNodes
	}
	return nil
}

func (x *UpdateTenantsRequest) GetImplicitUpdateRequest() bool {
	if x != nil {
		return x.ImplicitUpdateRequest
	}
	return false
}

type TenantsProcess struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Op            TenantsProcess_Op      `protobuf:"varint,1,opt,name=op,proto3,enum=weaviate.internal.cluster.TenantsProcess_Op" json:"op,omitempty"`
	Tenant        *Tenant                `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *TenantsProcess) Reset() {
	*x = TenantsProcess{}
	mi := &file_api_message_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *TenantsProcess) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*TenantsProcess) ProtoMessage() {}

func (x *TenantsProcess) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[12]
	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 TenantsProcess.ProtoReflect.Descriptor instead.
func (*TenantsProcess) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{12}
}

func (x *TenantsProcess) GetOp() TenantsProcess_Op {
	if x != nil {
		return x.Op
	}
	return TenantsProcess_OP_UNSPECIFIED
}

func (x *TenantsProcess) GetTenant() *Tenant {
	if x != nil {
		return x.Tenant
	}
	return nil
}

type TenantProcessRequest struct {
	state            protoimpl.MessageState      `protogen:"open.v1"`
	Node             string                      `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Action           TenantProcessRequest_Action `protobuf:"varint,2,opt,name=action,proto3,enum=weaviate.internal.cluster.TenantProcessRequest_Action" json:"action,omitempty"`
	TenantsProcesses []*TenantsProcess           `protobuf:"bytes,3,rep,name=tenants_processes,json=tenantsProcesses,proto3" json:"tenants_processes,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *TenantProcessRequest) Reset() {
	*x = TenantProcessRequest{}
	mi := &file_api_message_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *TenantProcessRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*TenantProcessRequest) ProtoMessage() {}

func (x *TenantProcessRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[13]
	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 TenantProcessRequest.ProtoReflect.Descriptor instead.
func (*TenantProcessRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{13}
}

func (x *TenantProcessRequest) GetNode() string {
	if x != nil {
		return x.Node
	}
	return ""
}

func (x *TenantProcessRequest) GetAction() TenantProcessRequest_Action {
	if x != nil {
		return x.Action
	}
	return TenantProcessRequest_ACTION_UNSPECIFIED
}

func (x *TenantProcessRequest) GetTenantsProcesses() []*TenantsProcess {
	if x != nil {
		return x.TenantsProcesses
	}
	return nil
}

type DeleteTenantsRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Tenants       []string               `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DeleteTenantsRequest) Reset() {
	*x = DeleteTenantsRequest{}
	mi := &file_api_message_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DeleteTenantsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DeleteTenantsRequest) ProtoMessage() {}

func (x *DeleteTenantsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[14]
	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 DeleteTenantsRequest.ProtoReflect.Descriptor instead.
func (*DeleteTenantsRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{14}
}

func (x *DeleteTenantsRequest) GetTenants() []string {
	if x != nil {
		return x.Tenants
	}
	return nil
}

type Tenant struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Name          string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status        string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Tenant) Reset() {
	*x = Tenant{}
	mi := &file_api_message_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Tenant) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Tenant) ProtoMessage() {}

func (x *Tenant) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[15]
	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 Tenant.ProtoReflect.Descriptor instead.
func (*Tenant) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{15}
}

func (x *Tenant) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *Tenant) GetStatus() string {
	if x != nil {
		return x.Status
	}
	return ""
}

type AddDistributedTaskRequest struct {
	state                 protoimpl.MessageState `protogen:"open.v1"`
	Namespace             string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                    string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Payload               []byte                 `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	SubmittedAtUnixMillis int64                  `protobuf:"varint,5,opt,name=submitted_at_unix_millis,json=submittedAtUnixMillis,proto3" json:"submitted_at_unix_millis,omitempty"`
	unknownFields         protoimpl.UnknownFields
	sizeCache             protoimpl.SizeCache
}

func (x *AddDistributedTaskRequest) Reset() {
	*x = AddDistributedTaskRequest{}
	mi := &file_api_message_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AddDistributedTaskRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AddDistributedTaskRequest) ProtoMessage() {}

func (x *AddDistributedTaskRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[16]
	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 AddDistributedTaskRequest.ProtoReflect.Descriptor instead.
func (*AddDistributedTaskRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{16}
}

func (x *AddDistributedTaskRequest) GetNamespace() string {
	if x != nil {
		return x.Namespace
	}
	return ""
}

func (x *AddDistributedTaskRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *AddDistributedTaskRequest) GetPayload() []byte {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *AddDistributedTaskRequest) GetSubmittedAtUnixMillis() int64 {
	if x != nil {
		return x.SubmittedAtUnixMillis
	}
	return 0
}

type RecordDistributedTaskNodeCompletionRequest struct {
	state                protoimpl.MessageState `protogen:"open.v1"`
	Namespace            string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                   string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Version              uint64                 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	NodeId               string                 `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Error                *string                `protobuf:"bytes,5,opt,name=error,proto3,oneof" json:"error,omitempty"`
	FinishedAtUnixMillis int64                  `protobuf:"varint,6,opt,name=finished_at_unix_millis,json=finishedAtUnixMillis,proto3" json:"finished_at_unix_millis,omitempty"`
	unknownFields        protoimpl.UnknownFields
	sizeCache            protoimpl.SizeCache
}

func (x *RecordDistributedTaskNodeCompletionRequest) Reset() {
	*x = RecordDistributedTaskNodeCompletionRequest{}
	mi := &file_api_message_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RecordDistributedTaskNodeCompletionRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RecordDistributedTaskNodeCompletionRequest) ProtoMessage() {}

func (x *RecordDistributedTaskNodeCompletionRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[17]
	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 RecordDistributedTaskNodeCompletionRequest.ProtoReflect.Descriptor instead.
func (*RecordDistributedTaskNodeCompletionRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{17}
}

func (x *RecordDistributedTaskNodeCompletionRequest) GetNamespace() string {
	if x != nil {
		return x.Namespace
	}
	return ""
}

func (x *RecordDistributedTaskNodeCompletionRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *RecordDistributedTaskNodeCompletionRequest) GetVersion() uint64 {
	if x != nil {
		return x.Version
	}
	return 0
}

func (x *RecordDistributedTaskNodeCompletionRequest) GetNodeId() string {
	if x != nil {
		return x.NodeId
	}
	return ""
}

func (x *RecordDistributedTaskNodeCompletionRequest) GetError() string {
	if x != nil && x.Error != nil {
		return *x.Error
	}
	return ""
}

func (x *RecordDistributedTaskNodeCompletionRequest) GetFinishedAtUnixMillis() int64 {
	if x != nil {
		return x.FinishedAtUnixMillis
	}
	return 0
}

type CancelDistributedTaskRequest struct {
	state                 protoimpl.MessageState `protogen:"open.v1"`
	Namespace             string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                    string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Version               uint64                 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	CancelledAtUnixMillis int64                  `protobuf:"varint,6,opt,name=cancelled_at_unix_millis,json=cancelledAtUnixMillis,proto3" json:"cancelled_at_unix_millis,omitempty"`
	unknownFields         protoimpl.UnknownFields
	sizeCache             protoimpl.SizeCache
}

func (x *CancelDistributedTaskRequest) Reset() {
	*x = CancelDistributedTaskRequest{}
	mi := &file_api_message_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CancelDistributedTaskRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CancelDistributedTaskRequest) ProtoMessage() {}

func (x *CancelDistributedTaskRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[18]
	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 CancelDistributedTaskRequest.ProtoReflect.Descriptor instead.
func (*CancelDistributedTaskRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{18}
}

func (x *CancelDistributedTaskRequest) GetNamespace() string {
	if x != nil {
		return x.Namespace
	}
	return ""
}

func (x *CancelDistributedTaskRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *CancelDistributedTaskRequest) GetVersion() uint64 {
	if x != nil {
		return x.Version
	}
	return 0
}

func (x *CancelDistributedTaskRequest) GetCancelledAtUnixMillis() int64 {
	if x != nil {
		return x.CancelledAtUnixMillis
	}
	return 0
}

type CleanUpDistributedTaskRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Namespace     string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id            string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Version       uint64                 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CleanUpDistributedTaskRequest) Reset() {
	*x = CleanUpDistributedTaskRequest{}
	mi := &file_api_message_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CleanUpDistributedTaskRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CleanUpDistributedTaskRequest) ProtoMessage() {}

func (x *CleanUpDistributedTaskRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[19]
	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 CleanUpDistributedTaskRequest.ProtoReflect.Descriptor instead.
func (*CleanUpDistributedTaskRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{19}
}

func (x *CleanUpDistributedTaskRequest) GetNamespace() string {
	if x != nil {
		return x.Namespace
	}
	return ""
}

func (x *CleanUpDistributedTaskRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *CleanUpDistributedTaskRequest) GetVersion() uint64 {
	if x != nil {
		return x.Version
	}
	return 0
}

type SyncShardRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Collection    string                 `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Shard         string                 `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	NodeId        string                 `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncShardRequest) Reset() {
	*x = SyncShardRequest{}
	mi := &file_api_message_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SyncShardRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SyncShardRequest) ProtoMessage() {}

func (x *SyncShardRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[20]
	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 SyncShardRequest.ProtoReflect.Descriptor instead.
func (*SyncShardRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{20}
}

func (x *SyncShardRequest) GetCollection() string {
	if x != nil {
		return x.Collection
	}
	return ""
}

func (x *SyncShardRequest) GetShard() string {
	if x != nil {
		return x.Shard
	}
	return ""
}

func (x *SyncShardRequest) GetNodeId() string {
	if x != nil {
		return x.NodeId
	}
	return ""
}

type CreateAliasRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Collection    string                 `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Alias         string                 `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CreateAliasRequest) Reset() {
	*x = CreateAliasRequest{}
	mi := &file_api_message_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreateAliasRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreateAliasRequest) ProtoMessage() {}

func (x *CreateAliasRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[21]
	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 CreateAliasRequest.ProtoReflect.Descriptor instead.
func (*CreateAliasRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{21}
}

func (x *CreateAliasRequest) GetCollection() string {
	if x != nil {
		return x.Collection
	}
	return ""
}

func (x *CreateAliasRequest) GetAlias() string {
	if x != nil {
		return x.Alias
	}
	return ""
}

type ReplaceAliasRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Collection    string                 `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Alias         string                 `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ReplaceAliasRequest) Reset() {
	*x = ReplaceAliasRequest{}
	mi := &file_api_message_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReplaceAliasRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReplaceAliasRequest) ProtoMessage() {}

func (x *ReplaceAliasRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[22]
	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 ReplaceAliasRequest.ProtoReflect.Descriptor instead.
func (*ReplaceAliasRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{22}
}

func (x *ReplaceAliasRequest) GetCollection() string {
	if x != nil {
		return x.Collection
	}
	return ""
}

func (x *ReplaceAliasRequest) GetAlias() string {
	if x != nil {
		return x.Alias
	}
	return ""
}

type DeleteAliasRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Alias         string                 `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DeleteAliasRequest) Reset() {
	*x = DeleteAliasRequest{}
	mi := &file_api_message_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DeleteAliasRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DeleteAliasRequest) ProtoMessage() {}

func (x *DeleteAliasRequest) ProtoReflect() protoreflect.Message {
	mi := &file_api_message_proto_msgTypes[23]
	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 DeleteAliasRequest.ProtoReflect.Descriptor instead.
func (*DeleteAliasRequest) Descriptor() ([]byte, []int) {
	return file_api_message_proto_rawDescGZIP(), []int{23}
}

func (x *DeleteAliasRequest) GetAlias() string {
	if x != nil {
		return x.Alias
	}
	return ""
}

var File_api_message_proto protoreflect.FileDescriptor

const file_api_message_proto_rawDesc = "" +
	"\n" +
	"\x11api/message.proto\x12\x19weaviate.internal.cluster\"Q\n" +
	"\x0fJoinPeerRequest\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x18\n" +
	"\aaddress\x18\x02 \x01(\tR\aaddress\x12\x14\n" +
	"\x05voter\x18\x03 \x01(\bR\x05voter\"*\n" +
	"\x10JoinPeerResponse\x12\x16\n" +
	"\x06leader\x18\x01 \x01(\tR\x06leader\"#\n" +
	"\x11RemovePeerRequest\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\",\n" +
	"\x12RemovePeerResponse\x12\x16\n" +
	"\x06leader\x18\x01 \x01(\tR\x06leader\"=\n" +
	"\x11NotifyPeerRequest\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x18\n" +
	"\aaddress\x18\x02 \x01(\tR\aaddress\"\x14\n" +
	"\x12NotifyPeerResponse\"\xfd\x0e\n" +
	"\fApplyRequest\x12@\n" +
	"\x04type\x18\x01 \x01(\x0e2,.weaviate.internal.cluster.ApplyRequest.TypeR\x04type\x12\x14\n" +
	"\x05class\x18\x02 \x01(\tR\x05class\x12\x18\n" +
	"\aversion\x18\x03 \x01(\x04R\aversion\x12\x1f\n" +
	"\vsub_command\x18\x04 \x01(\fR\n" +
	"subCommand\"\xd9\r\n" +
	"\x04Type\x12\x14\n" +
	"\x10TYPE_UNSPECIFIED\x10\x00\x12\x12\n" +
	"\x0eTYPE_ADD_CLASS\x10\x01\x12\x15\n" +
	"\x11TYPE_UPDATE_CLASS\x10\x02\x12\x15\n" +
	"\x11TYPE_DELETE_CLASS\x10\x03\x12\x16\n" +
	"\x12TYPE_RESTORE_CLASS\x10\x04\x12\x15\n" +
	"\x11TYPE_ADD_PROPERTY\x10\x05\x12\x1c\n" +
	"\x18TYPE_UPDATE_SHARD_STATUS\x10\n" +
	"\x12\x1d\n" +
	"\x19TYPE_ADD_REPLICA_TO_SHARD\x10\v\x12\"\n" +
	"\x1eTYPE_DELETE_REPLICA_FROM_SHARD\x10\f\x12\x13\n" +
	"\x0fTYPE_ADD_TENANT\x10\x10\x12\x16\n" +
	"\x12TYPE_UPDATE_TENANT\x10\x11\x12\x16\n" +
	"\x12TYPE_DELETE_TENANT\x10\x12\x12\x17\n" +
	"\x13TYPE_TENANT_PROCESS\x10\x13\x12\x15\n" +
	"\x11TYPE_CREATE_ALIAS\x10(\x12\x16\n" +
	"\x12TYPE_REPLACE_ALIAS\x10)\x12\x15\n" +
	"\x11TYPE_DELETE_ALIAS\x10*\x12!\n" +
	"\x1dTYPE_UPSERT_ROLES_PERMISSIONS\x10<\x12\x15\n" +
	"\x11TYPE_DELETE_ROLES\x10=\x12\x1b\n" +
	"\x17TYPE_REMOVE_PERMISSIONS\x10>\x12\x1b\n" +
	"\x17TYPE_ADD_ROLES_FOR_USER\x10?\x12\x1e\n" +
	"\x1aTYPE_REVOKE_ROLES_FOR_USER\x10@\x12\x14\n" +
	"\x10TYPE_UPSERT_USER\x10P\x12\x14\n" +
	"\x10TYPE_DELETE_USER\x10Q\x12\x1c\n" +
	"\x18TYPE_ROTATE_USER_API_KEY\x10R\x12\x15\n" +
	"\x11TYPE_SUSPEND_USER\x10S\x12\x16\n" +
	"\x12TYPE_ACTIVATE_USER\x10T\x12\x1d\n" +
	"\x19TYPE_CREATE_USER_WITH_KEY\x10U\x12\x1f\n" +
	"\x1aTYPE_REPLICATION_REPLICATE\x10\xc8\x01\x12,\n" +
	"'TYPE_REPLICATION_REPLICATE_UPDATE_STATE\x10\xc9\x01\x12.\n" +
	")TYPE_REPLICATION_REPLICATE_REGISTER_ERROR\x10\xca\x01\x12&\n" +
	"!TYPE_REPLICATION_REPLICATE_CANCEL\x10\xcb\x01\x12&\n" +
	"!TYPE_REPLICATION_REPLICATE_DELETE\x10\xcc\x01\x12&\n" +
	"!TYPE_REPLICATION_REPLICATE_REMOVE\x10\xcd\x01\x125\n" +
	"0TYPE_REPLICATION_REPLICATE_CANCELLATION_COMPLETE\x10\xce\x01\x12*\n" +
	"%TYPE_REPLICATION_REPLICATE_DELETE_ALL\x10\xcf\x01\x124\n" +
	"/TYPE_REPLICATION_REPLICATE_DELETE_BY_COLLECTION\x10\xd0\x01\x121\n" +
	",TYPE_REPLICATION_REPLICATE_DELETE_BY_TENANTS\x10\xd1\x01\x12*\n" +
	"%TYPE_REPLICATION_REPLICATE_SYNC_SHARD\x10\xd2\x01\x12-\n" +
	"(TYPE_REPLICATION_REGISTER_SCHEMA_VERSION\x10\xd3\x01\x124\n" +
	"/TYPE_REPLICATION_REPLICATE_ADD_REPLICA_TO_SHARD\x10\xd4\x01\x120\n" +
	"+TYPE_REPLICATION_REPLICATE_FORCE_DELETE_ALL\x10\xdc\x01\x12:\n" +
	"5TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION\x10\xdd\x01\x12D\n" +
	"?TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_COLLECTION_AND_SHARD\x10\xde\x01\x12;\n" +
	"6TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_TARGET_NODE\x10\xdf\x01\x124\n" +
	"/TYPE_REPLICATION_REPLICATE_FORCE_DELETE_BY_UUID\x10\xe0\x01\x12\x1e\n" +
	"\x19TYPE_DISTRIBUTED_TASK_ADD\x10\xac\x02\x12!\n" +
	"\x1cTYPE_DISTRIBUTED_TASK_CANCEL\x10\xad\x02\x120\n" +
	"+TYPE_DISTRIBUTED_TASK_RECORD_NODE_COMPLETED\x10\xae\x02\x12#\n" +
	"\x1eTYPE_DISTRIBUTED_TASK_CLEAN_UP\x10\xaf\x02\"\x04\bc\x10c\"A\n" +
	"\rApplyResponse\x12\x18\n" +
	"\aversion\x18\x01 \x01(\x04R\aversion\x12\x16\n" +
	"\x06leader\x18\x02 \x01(\tR\x06leader\"\x91\b\n" +
	"\fQueryRequest\x12@\n" +
	"\x04type\x18\x01 \x01(\x0e2,.weaviate.internal.cluster.QueryRequest.TypeR\x04type\x12\x1f\n" +
	"\vsub_command\x18\x02 \x01(\fR\n" +
	"subCommand\"\x9d\a\n" +
	"\x04Type\x12\x14\n" +
	"\x10TYPE_UNSPECIFIED\x10\x00\x12\x14\n" +
	"\x10TYPE_GET_CLASSES\x10\x01\x12\x13\n" +
	"\x0fTYPE_GET_SCHEMA\x10\x02\x12\x14\n" +
	"\x10TYPE_GET_TENANTS\x10\x03\x12\x18\n" +
	"\x14TYPE_GET_SHARD_OWNER\x10\x04\x12\x1b\n" +
	"\x17TYPE_GET_TENANTS_SHARDS\x10\x05\x12\x1b\n" +
	"\x17TYPE_GET_SHARDING_STATE\x10\x06\x12\x1b\n" +
	"\x17TYPE_GET_CLASS_VERSIONS\x10\a\x12\x1e\n" +
	"\x1aTYPE_GET_COLLECTIONS_COUNT\x10\b\x12\x17\n" +
	"\x13TYPE_HAS_PERMISSION\x10\x1e\x12\x12\n" +
	"\x0eTYPE_GET_ROLES\x10\x1f\x12\x1b\n" +
	"\x17TYPE_GET_ROLES_FOR_USER\x10 \x12\x1b\n" +
	"\x17TYPE_GET_USERS_FOR_ROLE\x10!\x12'\n" +
	"#TYPE_GET_USERS_OR_GROUPS_WITH_ROLES\x10\"\x12\x12\n" +
	"\x0eTYPE_GET_USERS\x10=\x12\x1f\n" +
	"\x1bTYPE_USER_IDENTIFIER_EXISTS\x10>\x12\x16\n" +
	"\x12TYPE_RESOLVE_ALIAS\x10d\x12\x14\n" +
	"\x10TYPE_GET_ALIASES\x10e\x12!\n" +
	"\x1cTYPE_GET_REPLICATION_DETAILS\x10\xc8\x01\x12/\n" +
	"*TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION\x10\xc9\x01\x129\n" +
	"4TYPE_GET_REPLICATION_DETAILS_BY_COLLECTION_AND_SHARD\x10\xca\x01\x120\n" +
	"+TYPE_GET_REPLICATION_DETAILS_BY_TARGET_NODE\x10\xcb\x01\x12*\n" +
	"%TYPE_GET_SHARDING_STATE_BY_COLLECTION\x10\xcc\x01\x124\n" +
	"/TYPE_GET_SHARDING_STATE_BY_COLLECTION_AND_SHARD\x10\xcd\x01\x12%\n" +
	" TYPE_GET_ALL_REPLICATION_DETAILS\x10\xce\x01\x12)\n" +
	"$TYPE_GET_REPLICATION_OPERATION_STATE\x10\xcf\x01\x12$\n" +
	"\x1fTYPE_GET_REPLICATION_SCALE_PLAN\x10\xd0\x01\x12\x1f\n" +
	"\x1aTYPE_DISTRIBUTED_TASK_LIST\x10\xac\x02\")\n" +
	"\rQueryResponse\x12\x18\n" +
	"\apayload\x18\x01 \x01(\fR\apayload\"u\n" +
	"\x11AddTenantsRequest\x12#\n" +
	"\rcluster_nodes\x18\x01 \x03(\tR\fclusterNodes\x12;\n" +
	"\atenants\x18\x02 \x03(\v2!.weaviate.internal.cluster.TenantR\atenants\"\xb0\x01\n" +
	"\x14UpdateTenantsRequest\x12;\n" +
	"\atenants\x18\x01 \x03(\v2!.weaviate.internal.cluster.TenantR\atenants\x12#\n" +
	"\rcluster_nodes\x18\x02 \x03(\tR\fclusterNodes\x126\n" +
	"\x17implicit_update_request\x18\x03 \x01(\bR\x15implicitUpdateRequest\"\xcc\x01\n" +
	"\x0eTenantsProcess\x12<\n" +
	"\x02op\x18\x01 \x01(\x0e2,.weaviate.internal.cluster.TenantsProcess.OpR\x02op\x129\n" +
	"\x06tenant\x18\x02 \x01(\v2!.weaviate.internal.cluster.TenantR\x06tenant\"A\n" +
	"\x02Op\x12\x12\n" +
	"\x0eOP_UNSPECIFIED\x10\x00\x12\f\n" +
	"\bOP_START\x10\x01\x12\v\n" +
	"\aOP_DONE\x10\x02\x12\f\n" +
	"\bOP_ABORT\x10\x03\"\xa0\x02\n" +
	"\x14TenantProcessRequest\x12\x12\n" +
	"\x04node\x18\x01 \x01(\tR\x04node\x12N\n" +
	"\x06action\x18\x02 \x01(\x0e26.weaviate.internal.cluster.TenantProcessRequest.ActionR\x06action\x12V\n" +
	"\x11tenants_processes\x18\x03 \x03(\v2).weaviate.internal.cluster.TenantsProcessR\x10tenantsProcesses\"L\n" +
	"\x06Action\x12\x16\n" +
	"\x12ACTION_UNSPECIFIED\x10\x00\x12\x13\n" +
	"\x0fACTION_FREEZING\x10\x01\x12\x15\n" +
	"\x11ACTION_UNFREEZING\x10\x02\"0\n" +
	"\x14DeleteTenantsRequest\x12\x18\n" +
	"\atenants\x18\x01 \x03(\tR\atenants\"4\n" +
	"\x06Tenant\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12\x16\n" +
	"\x06status\x18\x02 \x01(\tR\x06status\"\x9c\x01\n" +
	"\x19AddDistributedTaskRequest\x12\x1c\n" +
	"\tnamespace\x18\x01 \x01(\tR\tnamespace\x12\x0e\n" +
	"\x02id\x18\x02 \x01(\tR\x02id\x12\x18\n" +
	"\apayload\x18\x04 \x01(\fR\apayload\x127\n" +
	"\x18submitted_at_unix_millis\x18\x05 \x01(\x03R\x15submittedAtUnixMillis\"\xe9\x01\n" +
	"*RecordDistributedTaskNodeCompletionRequest\x12\x1c\n" +
	"\tnamespace\x18\x01 \x01(\tR\tnamespace\x12\x0e\n" +
	"\x02id\x18\x02 \x01(\tR\x02id\x12\x18\n" +
	"\aversion\x18\x03 \x01(\x04R\aversion\x12\x17\n" +
	"\anode_id\x18\x04 \x01(\tR\x06nodeId\x12\x19\n" +
	"\x05error\x18\x05 \x01(\tH\x00R\x05error\x88\x01\x01\x125\n" +
	"\x17finished_at_unix_millis\x18\x06 \x01(\x03R\x14finishedAtUnixMillisB\b\n" +
	"\x06_error\"\x9f\x01\n" +
	"\x1cCancelDistributedTaskRequest\x12\x1c\n" +
	"\tnamespace\x18\x01 \x01(\tR\tnamespace\x12\x0e\n" +
	"\x02id\x18\x02 \x01(\tR\x02id\x12\x18\n" +
	"\aversion\x18\x03 \x01(\x04R\aversion\x127\n" +
	"\x18cancelled_at_unix_millis\x18\x06 \x01(\x03R\x15cancelledAtUnixMillis\"g\n" +
	"\x1dCleanUpDistributedTaskRequest\x12\x1c\n" +
	"\tnamespace\x18\x01 \x01(\tR\tnamespace\x12\x0e\n" +
	"\x02id\x18\x02 \x01(\tR\x02id\x12\x18\n" +
	"\aversion\x18\x03 \x01(\x04R\aversion\"a\n" +
	"\x10SyncShardRequest\x12\x1e\n" +
	"\n" +
	"collection\x18\x01 \x01(\tR\n" +
	"collection\x12\x14\n" +
	"\x05shard\x18\x02 \x01(\tR\x05shard\x12\x17\n" +
	"\anode_id\x18\x03 \x01(\tR\x06nodeId\"J\n" +
	"\x12CreateAliasRequest\x12\x1e\n" +
	"\n" +
	"collection\x18\x01 \x01(\tR\n" +
	"collection\x12\x14\n" +
	"\x05alias\x18\x02 \x01(\tR\x05alias\"K\n" +
	"\x13ReplaceAliasRequest\x12\x1e\n" +
	"\n" +
	"collection\x18\x01 \x01(\tR\n" +
	"collection\x12\x14\n" +
	"\x05alias\x18\x02 \x01(\tR\x05alias\"*\n" +
	"\x12DeleteAliasRequest\x12\x14\n" +
	"\x05alias\x18\x01 \x01(\tR\x05alias2\x8d\x04\n" +
	"\x0eClusterService\x12k\n" +
	"\n" +
	"RemovePeer\x12,.weaviate.internal.cluster.RemovePeerRequest\x1a-.weaviate.internal.cluster.RemovePeerResponse\"\x00\x12e\n" +
	"\bJoinPeer\x12*.weaviate.internal.cluster.JoinPeerRequest\x1a+.weaviate.internal.cluster.JoinPeerResponse\"\x00\x12k\n" +
	"\n" +
	"NotifyPeer\x12,.weaviate.internal.cluster.NotifyPeerRequest\x1a-.weaviate.internal.cluster.NotifyPeerResponse\"\x00\x12\\\n" +
	"\x05Apply\x12'.weaviate.internal.cluster.ApplyRequest\x1a(.weaviate.internal.cluster.ApplyResponse\"\x00\x12\\\n" +
	"\x05Query\x12'.weaviate.internal.cluster.QueryRequest\x1a(.weaviate.internal.cluster.QueryResponse\"\x00B\xe1\x01\n" +
	"\x1dcom.weaviate.internal.clusterB\fMessageProtoP\x01Z,github.com/weaviate/weaviate/cloud/proto/api\xa2\x02\x03WIC\xaa\x02\x19Weaviate.Internal.Cluster\xca\x02\x19Weaviate\\Internal\\Cluster\xe2\x02%Weaviate\\Internal\\Cluster\\GPBMetadata\xea\x02\x1bWeaviate::Internal::Clusterb\x06proto3"

var (
	file_api_message_proto_rawDescOnce sync.Once
	file_api_message_proto_rawDescData []byte
)

func file_api_message_proto_rawDescGZIP() []byte {
	file_api_message_proto_rawDescOnce.Do(func() {
		file_api_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_api_message_proto_rawDesc), len(file_api_message_proto_rawDesc)))
	})
	return file_api_message_proto_rawDescData
}

var file_api_message_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
var file_api_message_proto_msgTypes = make([]protoimpl.MessageInfo, 24)
var file_api_message_proto_goTypes = []any{
	(ApplyRequest_Type)(0),                             // 0: weaviate.internal.cluster.ApplyRequest.Type
	(QueryRequest_Type)(0),                             // 1: weaviate.internal.cluster.QueryRequest.Type
	(TenantsProcess_Op)(0),                             // 2: weaviate.internal.cluster.TenantsProcess.Op
	(TenantProcessRequest_Action)(0),                   // 3: weaviate.internal.cluster.TenantProcessRequest.Action
	(*JoinPeerRequest)(nil),                            // 4: weaviate.internal.cluster.JoinPeerRequest
	(*JoinPeerResponse)(nil),                           // 5: weaviate.internal.cluster.JoinPeerResponse
	(*RemovePeerRequest)(nil),                          // 6: weaviate.internal.cluster.RemovePeerRequest
	(*RemovePeerResponse)(nil),                         // 7: weaviate.internal.cluster.RemovePeerResponse
	(*NotifyPeerRequest)(nil),                          // 8: weaviate.internal.cluster.NotifyPeerRequest
	(*NotifyPeerResponse)(nil),                         // 9: weaviate.internal.cluster.NotifyPeerResponse
	(*ApplyRequest)(nil),                               // 10: weaviate.internal.cluster.ApplyRequest
	(*ApplyResponse)(nil),                              // 11: weaviate.internal.cluster.ApplyResponse
	(*QueryRequest)(nil),                               // 12: weaviate.internal.cluster.QueryRequest
	(*QueryResponse)(nil),                              // 13: weaviate.internal.cluster.QueryResponse
	(*AddTenantsRequest)(nil),                          // 14: weaviate.internal.cluster.AddTenantsRequest
	(*UpdateTenantsRequest)(nil),                       // 15: weaviate.internal.cluster.UpdateTenantsRequest
	(*TenantsProcess)(nil),                             // 16: weaviate.internal.cluster.TenantsProcess
	(*TenantProcessRequest)(nil),                       // 17: weaviate.internal.cluster.TenantProcessRequest
	(*DeleteTenantsRequest)(nil),                       // 18: weaviate.internal.cluster.DeleteTenantsRequest
	(*Tenant)(nil),                                     // 19: weaviate.internal.cluster.Tenant
	(*AddDistributedTaskRequest)(nil),                  // 20: weaviate.internal.cluster.AddDistributedTaskRequest
	(*RecordDistributedTaskNodeCompletionRequest)(nil), // 21: weaviate.internal.cluster.RecordDistributedTaskNodeCompletionRequest
	(*CancelDistributedTaskRequest)(nil),               // 22: weaviate.internal.cluster.CancelDistributedTaskRequest
	(*CleanUpDistributedTaskRequest)(nil),              // 23: weaviate.internal.cluster.CleanUpDistributedTaskRequest
	(*SyncShardRequest)(nil),                           // 24: weaviate.internal.cluster.SyncShardRequest
	(*CreateAliasRequest)(nil),                         // 25: weaviate.internal.cluster.CreateAliasRequest
	(*ReplaceAliasRequest)(nil),                        // 26: weaviate.internal.cluster.ReplaceAliasRequest
	(*DeleteAliasRequest)(nil),                         // 27: weaviate.internal.cluster.DeleteAliasRequest
}
var file_api_message_proto_depIdxs = []int32{
	0,  // 0: weaviate.internal.cluster.ApplyRequest.type:type_name -> weaviate.internal.cluster.ApplyRequest.Type
	1,  // 1: weaviate.internal.cluster.QueryRequest.type:type_name -> weaviate.internal.cluster.QueryRequest.Type
	19, // 2: weaviate.internal.cluster.AddTenantsRequest.tenants:type_name -> weaviate.internal.cluster.Tenant
	19, // 3: weaviate.internal.cluster.UpdateTenantsRequest.tenants:type_name -> weaviate.internal.cluster.Tenant
	2,  // 4: weaviate.internal.cluster.TenantsProcess.op:type_name -> weaviate.internal.cluster.TenantsProcess.Op
	19, // 5: weaviate.internal.cluster.TenantsProcess.tenant:type_name -> weaviate.internal.cluster.Tenant
	3,  // 6: weaviate.internal.cluster.TenantProcessRequest.action:type_name -> weaviate.internal.cluster.TenantProcessRequest.Action
	16, // 7: weaviate.internal.cluster.TenantProcessRequest.tenants_processes:type_name -> weaviate.internal.cluster.TenantsProcess
	6,  // 8: weaviate.internal.cluster.ClusterService.RemovePeer:input_type -> weaviate.internal.cluster.RemovePeerRequest
	4,  // 9: weaviate.internal.cluster.ClusterService.JoinPeer:input_type -> weaviate.internal.cluster.JoinPeerRequest
	8,  // 10: weaviate.internal.cluster.ClusterService.NotifyPeer:input_type -> weaviate.internal.cluster.NotifyPeerRequest
	10, // 11: weaviate.internal.cluster.ClusterService.Apply:input_type -> weaviate.internal.cluster.ApplyRequest
	12, // 12: weaviate.internal.cluster.ClusterService.Query:input_type -> weaviate.internal.cluster.QueryRequest
	7,  // 13: weaviate.internal.cluster.ClusterService.RemovePeer:output_type -> weaviate.internal.cluster.RemovePeerResponse
	5,  // 14: weaviate.internal.cluster.ClusterService.JoinPeer:output_type -> weaviate.internal.cluster.JoinPeerResponse
	9,  // 15: weaviate.internal.cluster.ClusterService.NotifyPeer:output_type -> weaviate.internal.cluster.NotifyPeerResponse
	11, // 16: weaviate.internal.cluster.ClusterService.Apply:output_type -> weaviate.internal.cluster.ApplyResponse
	13, // 17: weaviate.internal.cluster.ClusterService.Query:output_type -> weaviate.internal.cluster.QueryResponse
	13, // [13:18] is the sub-list for method output_type
	8,  // [8:13] is the sub-list for method input_type
	8,  // [8:8] is the sub-list for extension type_name
	8,  // [8:8] is the sub-list for extension extendee
	0,  // [0:8] is the sub-list for field type_name
}

func init() { file_api_message_proto_init() }
func file_api_message_proto_init() {
	if File_api_message_proto != nil {
		return
	}
	file_api_message_proto_msgTypes[17].OneofWrappers = []any{}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_api_message_proto_rawDesc), len(file_api_message_proto_rawDesc)),
			NumEnums:      4,
			NumMessages:   24,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_api_message_proto_goTypes,
		DependencyIndexes: file_api_message_proto_depIdxs,
		EnumInfos:         file_api_message_proto_enumTypes,
		MessageInfos:      file_api_message_proto_msgTypes,
	}.Build()
	File_api_message_proto = out.File
	file_api_message_proto_goTypes = nil
	file_api_message_proto_depIdxs = nil
}
