tasks/api/cluster/v1/message.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// plugins:
// 	protoc-gen-go
// 	protoc
// source: temporal/server/api/cluster/v1/message.proto

package cluster

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"
	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

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

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

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

func (*HostInfo) ProtoMessage() {}

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

func (x *HostInfo) GetIdentity() string {
	if x != nil {
		return x.Identity
	}
	return ""
}

type RingInfo struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Role          string                 `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	MemberCount   int32                  `protobuf:"varint,2,opt,name=member_count,json=memberCount,proto3" json:"member_count,omitempty"`
	Members       []*HostInfo            `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*RingInfo) ProtoMessage() {}

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

func (x *RingInfo) GetRole() string {
	if x != nil {
		return x.Role
	}
	return ""
}

func (x *RingInfo) GetMemberCount() int32 {
	if x != nil {
		return x.MemberCount
	}
	return 0
}

func (x *RingInfo) GetMembers() []*HostInfo {
	if x != nil {
		return x.Members
	}
	return nil
}

type MembershipInfo struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	CurrentHost      *HostInfo              `protobuf:"bytes,1,opt,name=current_host,json=currentHost,proto3" json:"current_host,omitempty"`
	ReachableMembers []string               `protobuf:"bytes,2,rep,name=reachable_members,json=reachableMembers,proto3" json:"reachable_members,omitempty"`
	Rings            []*RingInfo            `protobuf:"bytes,3,rep,name=rings,proto3" json:"rings,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*MembershipInfo) ProtoMessage() {}

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

func (x *MembershipInfo) GetCurrentHost() *HostInfo {
	if x != nil {
		return x.CurrentHost
	}
	return nil
}

func (x *MembershipInfo) GetReachableMembers() []string {
	if x != nil {
		return x.ReachableMembers
	}
	return nil
}

func (x *MembershipInfo) GetRings() []*RingInfo {
	if x != nil {
		return x.Rings
	}
	return nil
}

type ClusterMember struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	Role             v1.ClusterMemberRole   `protobuf:"varint,1,opt,name=role,proto3,enum=temporal.server.api.enums.v1.ClusterMemberRole" json:"role,omitempty"`
	HostId           string                 `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	RpcAddress       string                 `protobuf:"bytes,3,opt,name=rpc_address,json=rpcAddress,proto3" json:"rpc_address,omitempty"`
	RpcPort          int32                  `protobuf:"varint,4,opt,name=rpc_port,json=rpcPort,proto3" json:"rpc_port,omitempty"`
	SessionStartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=session_start_time,json=sessionStartTime,proto3" json:"session_start_time,omitempty"`
	LastHeartbitTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_heartbit_time,json=lastHeartbitTime,proto3" json:"last_heartbit_time,omitempty"`
	RecordExpiryTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=record_expiry_time,json=recordExpiryTime,proto3" json:"record_expiry_time,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*ClusterMember) ProtoMessage() {}

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

func (x *ClusterMember) GetRole() v1.ClusterMemberRole {
	if x != nil {
		return x.Role
	}
	return v1.ClusterMemberRole(0)
}

func (x *ClusterMember) GetHostId() string {
	if x != nil {
		return x.HostId
	}
	return ""
}

func (x *ClusterMember) GetRpcAddress() string {
	if x != nil {
		return x.RpcAddress
	}
	return ""
}

func (x *ClusterMember) GetRpcPort() int32 {
	if x != nil {
		return x.RpcPort
	}
	return 0
}

func (x *ClusterMember) GetSessionStartTime() *timestamppb.Timestamp {
	if x != nil {
		return x.SessionStartTime
	}
	return nil
}

func (x *ClusterMember) GetLastHeartbitTime() *timestamppb.Timestamp {
	if x != nil {
		return x.LastHeartbitTime
	}
	return nil
}

func (x *ClusterMember) GetRecordExpiryTime() *timestamppb.Timestamp {
	if x != nil {
		return x.RecordExpiryTime
	}
	return nil
}

var File_temporal_server_api_cluster_v1_message_proto protoreflect.FileDescriptor

const file_temporal_server_api_cluster_v1_message_proto_rawDesc = "" +
	"\n" +
	",temporal/server/api/cluster/v1/message.proto\x12\x1etemporal.server.api.cluster.v1\x1a\x1fgoogle/protobuf/timestamp.proto\x1a*temporal/server/api/enums/v1/cluster.proto\"&\n" +
	"\bHostInfo\x12\x1a\n" +
	"\bidentity\x18\x01 \x01(\tR\bidentity\"\x85\x01\n" +
	"\bRingInfo\x12\x12\n" +
	"\x04role\x18\x01 \x01(\tR\x04role\x12!\n" +
	"\fmember_count\x18\x02 \x01(\x05R\vmemberCount\x12B\n" +
	"\amembers\x18\x03 \x03(\v2(.temporal.server.api.cluster.v1.HostInfoR\amembers\"\xca\x01\n" +
	"\x0eMembershipInfo\x12K\n" +
	"\fcurrent_host\x18\x01 \x01(\v2(.temporal.server.api.cluster.v1.HostInfoR\vcurrentHost\x12+\n" +
	"\x11reachable_members\x18\x02 \x03(\tR\x10reachableMembers\x12>\n" +
	"\x05rings\x18\x03 \x03(\v2(.temporal.server.api.cluster.v1.RingInfoR\x05rings\"\x87\x03\n" +
	"\rClusterMember\x12C\n" +
	"\x04role\x18\x01 \x01(\x0e2/.temporal.server.api.enums.v1.ClusterMemberRoleR\x04role\x12\x17\n" +
	"\ahost_id\x18\x02 \x01(\tR\x06hostId\x12\x1f\n" +
	"\vrpc_address\x18\x03 \x01(\tR\n" +
	"rpcAddress\x12\x19\n" +
	"\brpc_port\x18\x04 \x01(\x05R\arpcPort\x12H\n" +
	"\x12session_start_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\x10sessionStartTime\x12H\n" +
	"\x12last_heartbit_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\x10lastHeartbitTime\x12H\n" +
	"\x12record_expiry_time\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\x10recordExpiryTimeB.Z,go.temporal.io/server/api/cluster/v1;clusterb\x06proto3"

var (
	file_temporal_server_api_cluster_v1_message_proto_rawDescOnce sync.Once
	file_temporal_server_api_cluster_v1_message_proto_rawDescData []byte
)

func file_temporal_server_api_cluster_v1_message_proto_rawDescGZIP() []byte {
	file_temporal_server_api_cluster_v1_message_proto_rawDescOnce.Do(func() {
		file_temporal_server_api_cluster_v1_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_cluster_v1_message_proto_rawDesc), len(file_temporal_server_api_cluster_v1_message_proto_rawDesc)))
	})
	return file_temporal_server_api_cluster_v1_message_proto_rawDescData
}

var file_temporal_server_api_cluster_v1_message_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_temporal_server_api_cluster_v1_message_proto_goTypes = []any{
	(*HostInfo)(nil),              // 0: temporal.server.api.cluster.v1.HostInfo
	(*RingInfo)(nil),              // 1: temporal.server.api.cluster.v1.RingInfo
	(*MembershipInfo)(nil),        // 2: temporal.server.api.cluster.v1.MembershipInfo
	(*ClusterMember)(nil),         // 3: temporal.server.api.cluster.v1.ClusterMember
	(v1.ClusterMemberRole)(0),     // 4: temporal.server.api.enums.v1.ClusterMemberRole
	(*timestamppb.Timestamp)(nil), // 5: google.protobuf.Timestamp
}
var file_temporal_server_api_cluster_v1_message_proto_depIdxs = []int32{
	0, // 0: temporal.server.api.cluster.v1.RingInfo.members:type_name -> temporal.server.api.cluster.v1.HostInfo
	0, // 1: temporal.server.api.cluster.v1.MembershipInfo.current_host:type_name -> temporal.server.api.cluster.v1.HostInfo
	1, // 2: temporal.server.api.cluster.v1.MembershipInfo.rings:type_name -> temporal.server.api.cluster.v1.RingInfo
	4, // 3: temporal.server.api.cluster.v1.ClusterMember.role:type_name -> temporal.server.api.enums.v1.ClusterMemberRole
	5, // 4: temporal.server.api.cluster.v1.ClusterMember.session_start_time:type_name -> google.protobuf.Timestamp
	5, // 5: temporal.server.api.cluster.v1.ClusterMember.last_heartbit_time:type_name -> google.protobuf.Timestamp
	5, // 6: temporal.server.api.cluster.v1.ClusterMember.record_expiry_time:type_name -> google.protobuf.Timestamp
	7, // [7:7] is the sub-list for method output_type
	7, // [7:7] is the sub-list for method input_type
	7, // [7:7] is the sub-list for extension type_name
	7, // [7:7] is the sub-list for extension extendee
	0, // [0:7] is the sub-list for field type_name
}

func init() { file_temporal_server_api_cluster_v1_message_proto_init() }
func file_temporal_server_api_cluster_v1_message_proto_init() {
	if File_temporal_server_api_cluster_v1_message_proto != nil {
		return
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_cluster_v1_message_proto_rawDesc), len(file_temporal_server_api_cluster_v1_message_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   4,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_temporal_server_api_cluster_v1_message_proto_goTypes,
		DependencyIndexes: file_temporal_server_api_cluster_v1_message_proto_depIdxs,
		MessageInfos:      file_temporal_server_api_cluster_v1_message_proto_msgTypes,
	}.Build()
	File_temporal_server_api_cluster_v1_message_proto = out.File
	file_temporal_server_api_cluster_v1_message_proto_goTypes = nil
	file_temporal_server_api_cluster_v1_message_proto_depIdxs = nil
}