minotaur-Go资源

// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.36.1 // protoc (unknown) // source: engine/vivid/cluster/internal/gossip/v1/gossip.proto package gossipv1 import ( v1 "github.com/kercylan98/minotaur/engine/prc/v1" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" anypb "google.golang.org/protobuf/types/known/anypb" reflect "reflect" sync "sync" ) 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 GossipNodeStatus int32 const ( GossipNodeStatus_GOSSIP_NODE_STATUS_UNSPECIFIED GossipNodeStatus = 0 GossipNodeStatus_GOSSIP_NODE_STATUS_JOINING GossipNodeStatus = 1 // 加入中 GossipNodeStatus_GOSSIP_NODE_STATUS_ALIVE GossipNodeStatus = 2 // 活跃 GossipNodeStatus_GOSSIP_NODE_STATUS_LEAVING GossipNodeStatus = 3 // 正在离开 GossipNodeStatus_GOSSIP_NODE_STATUS_EXITING GossipNodeStatus = 4 // 退出中 GossipNodeStatus_GOSSIP_NODE_STATUS_EXITED GossipNodeStatus = 5 // 已退出 GossipNodeStatus_GOSSIP_NODE_STATUS_REMOVED GossipNodeStatus = 6 // 移除 GossipNodeStatus_GOSSIP_NODE_STATUS_UNREACHABLE GossipNodeStatus = 7 // 不可达 GossipNodeStatus_GOSSIP_NODE_STATUS_REACHABLE GossipNodeStatus = 8 // 可达（网络恢复期间缓冲） GossipNodeStatus_GOSSIP_NODE_STATUS_DOWN GossipNodeStatus = 9 // 宕机 ) // Enum value maps for GossipNodeStatus. var ( GossipNodeStatus_name = map[int32]string{ 0: "GOSSIP_NODE_STATUS_UNSPECIFIED", 1: "GOSSIP_NODE_STATUS_JOINING", 2: "GOSSIP_NODE_STATUS_ALIVE", 3: "GOSSIP_NODE_STATUS_LEAVING", 4: "GOSSIP_NODE_STATUS_EXITING", 5: "GOSSIP_NODE_STATUS_EXITED", 6: "GOSSIP_NODE_STATUS_REMOVED", 7: "GOSSIP_NODE_STATUS_UNREACHABLE", 8: "GOSSIP_NODE_STATUS_REACHABLE", 9: "GOSSIP_NODE_STATUS_DOWN", } GossipNodeStatus_value = map[string]int32{ "GOSSIP_NODE_STATUS_UNSPECIFIED": 0, "GOSSIP_NODE_STATUS_JOINING": 1, "GOSSIP_NODE_STATUS_ALIVE": 2, "GOSSIP_NODE_STATUS_LEAVING": 3, "GOSSIP_NODE_STATUS_EXITING": 4, "GOSSIP_NODE_STATUS_EXITED": 5, "GOSSIP_NODE_STATUS_REMOVED": 6, "GOSSIP_NODE_STATUS_UNREACHABLE": 7, "GOSSIP_NODE_STATUS_REACHABLE": 8, "GOSSIP_NODE_STATUS_DOWN": 9, } ) func (x GossipNodeStatus) Enum() *GossipNodeStatus { p := new(GossipNodeStatus) *p = x return p } func (x GossipNodeStatus) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (GossipNodeStatus) Descriptor() protoreflect.EnumDescriptor { return file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_enumTypes[0].Descriptor() } func (GossipNodeStatus) Type() protoreflect.EnumType { return &file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_enumTypes[0] } func (x GossipNodeStatus) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use GossipNodeStatus.Descriptor instead. func (GossipNodeStatus) EnumDescriptor() ([]byte, []int) { return file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_rawDescGZIP(), []int{0} } type VectorClockOrdering int32 const ( VectorClockOrdering_VECTOR_CLOCK_ORDERING_UNSPECIFIED VectorClockOrdering = 0 VectorClockOrdering_VECTOR_CLOCK_ORDERING_CONCURRENT VectorClockOrdering = 1 // 并行 VectorClockOrdering_VECTOR_CLOCK_ORDERING_AFTER VectorClockOrdering = 2 // 之后 VectorClockOrdering_VECTOR_CLOCK_ORDERING_BEFORE VectorClockOrdering = 3 // 之前 VectorClockOrdering_VECTOR_CLOCK_ORDERING_SAME VectorClockOrdering = 4 // 相同 ) // Enum value maps for VectorClockOrdering. var ( VectorClockOrdering_name = map[int32]string{ 0: "VECTOR_CLOCK_ORDERING_UNSPECIFIED", 1: "VECTOR_CLOCK_ORDERING_CONCURRENT", 2: "VECTOR_CLOCK_ORDERING_AFTER", 3: "VECTOR_CLOCK_ORDERING_BEFORE", 4: "VECTOR_CLOCK_ORDERING_SAME", } VectorClockOrdering_value = map[string]int32{ "VECTOR_CLOCK_ORDERING_UNSPECIFIED": 0, "VECTOR_CLOCK_ORDERING_CONCURRENT": 1, "VECTOR_CLOCK_ORDERING_AFTER": 2, "VECTOR_CLOCK_ORDERING_BEFORE": 3, "VECTOR_CLOCK_ORDERING_SAME": 4, } ) func (x VectorClockOrdering) Enum() *VectorClockOrdering { p := new(VectorClockOrdering) *p = x return p } func (x VectorClockOrdering) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (VectorClockOrdering) Descriptor() protoreflect.EnumDescriptor { return file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_enumTypes[1].Descriptor() } func (VectorClockOrdering) Type() protoreflect.EnumType { return &file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_enumTypes[1] } func (x VectorClockOrdering) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use VectorClockOrdering.Descriptor instead. func (VectorClockOrdering) EnumDescriptor() ([]byte, []int) { return file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_rawDescGZIP(), []int{1} } // 初始化集群，此刻节点准备尝试加入其他集群或创建集群 type GossipActorInitClusterMessage struct { state protoimpl.MessageState `protogen:"open.v1"` RetryIntervalDuration int64 `protobuf:"varint,1,opt,name=retry_interval_duration,json=retryIntervalDuration,proto3" json:"retry_interval_duration,omitempty"` // 重试间隔 unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *GossipActorInitClusterMessage) Reset() { *x = GossipActorInitClusterMessage{} mi := &file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *GossipActorInitClusterMessage) String() string { return protoimpl.X.MessageStringOf(x) } func (*GossipActorInitClusterMessage) ProtoMessage() {} func (x *GossipActorInitClusterMessage) ProtoReflect() protoreflect.Message { mi := &file_engine_vivid_cluster_internal_gossip_v1_gossip_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 GossipActorInitClusterMessage.ProtoReflect.Descriptor instead. func (*GossipActorInitClusterMessage) Descriptor() ([]byte, []int) { return file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_rawDescGZIP(), []int{0} } func (x *GossipActorInitClusterMessage) GetRetryIntervalDuration() int64 { if x != nil { return x.RetryIntervalDuration } return 0 } // 节点携带自身信息尝试加入集群，在收到 GossipActorTryJoinClusterAckMessage type GossipActorTryJoinClusterMessage struct { state protoimpl.MessageState `protogen:"open.v1"` Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // 加入者节点信息 unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *GossipActorTryJoinClusterMessage) Reset() { *x = GossipActorTryJoinClusterMessage{} mi := &file_engine_vivid_cluster_internal_gossip_v1_gossip_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *GossipActorTryJoinClusterMessage) String() string { return protoimpl.X.MessageStringOf(x) } func (*GossipActorTryJoinClusterMessage) ProtoMessage() {} func (x *GossipActorTryJoinClusterMessage) ProtoReflect() protoreflect.Message { mi := &file_engine_vivid_cluster_internal_gossip_v1_gossip_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) } // Deprecate