Versions in this module Expand all Collapse all v4 v4.2.0 Oct 11, 2024 v4.1.0 Jun 5, 2024 Changes in this version + const Gossip_Read_FullMethodName v4.0.0 Mar 4, 2024 Changes in this version + var File_gossip_proto protoreflect.FileDescriptor + var Gossip_ServiceDesc = grpc.ServiceDesc + var MemberInfo_VNodeState_name = map[int32]string + var MemberInfo_VNodeState_value = map[string]int32 + func RegisterGossipServer(s grpc.ServiceRegistrar, srv GossipServer) + type ClusterInfo struct + Members []*MemberInfo + func (*ClusterInfo) Descriptor() ([]byte, []int) + func (*ClusterInfo) ProtoMessage() + func (x *ClusterInfo) GetMembers() []*MemberInfo + func (x *ClusterInfo) ProtoReflect() protoreflect.Message + func (x *ClusterInfo) Reset() + func (x *ClusterInfo) String() string + type EndPoint struct + Address string + Port uint32 + func (*EndPoint) Descriptor() ([]byte, []int) + func (*EndPoint) ProtoMessage() + func (x *EndPoint) GetAddress() string + func (x *EndPoint) GetPort() uint32 + func (x *EndPoint) ProtoReflect() protoreflect.Message + func (x *EndPoint) Reset() + func (x *EndPoint) String() string + type GossipClient interface + Read func(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*ClusterInfo, error) + func NewGossipClient(cc grpc.ClientConnInterface) GossipClient + type GossipServer interface + Read func(context.Context, *shared.Empty) (*ClusterInfo, error) + type MemberInfo struct + HttpEndPoint *EndPoint + InstanceId *shared.UUID + IsAlive bool + State MemberInfo_VNodeState + TimeStamp int64 + func (*MemberInfo) Descriptor() ([]byte, []int) + func (*MemberInfo) ProtoMessage() + func (x *MemberInfo) GetHttpEndPoint() *EndPoint + func (x *MemberInfo) GetInstanceId() *shared.UUID + func (x *MemberInfo) GetIsAlive() bool + func (x *MemberInfo) GetState() MemberInfo_VNodeState + func (x *MemberInfo) GetTimeStamp() int64 + func (x *MemberInfo) ProtoReflect() protoreflect.Message + func (x *MemberInfo) Reset() + func (x *MemberInfo) String() string + type MemberInfo_VNodeState int32 + const MemberInfo_CatchingUp + const MemberInfo_Clone + const MemberInfo_DiscoverLeader + const MemberInfo_Follower + const MemberInfo_Initializing + const MemberInfo_Leader + const MemberInfo_Manager + const MemberInfo_PreLeader + const MemberInfo_PreReadOnlyReplica + const MemberInfo_PreReplica + const MemberInfo_ReadOnlyLeaderless + const MemberInfo_ReadOnlyReplica + const MemberInfo_ResigningLeader + const MemberInfo_Shutdown + const MemberInfo_ShuttingDown + const MemberInfo_Unknown + func (MemberInfo_VNodeState) Descriptor() protoreflect.EnumDescriptor + func (MemberInfo_VNodeState) EnumDescriptor() ([]byte, []int) + func (MemberInfo_VNodeState) Type() protoreflect.EnumType + func (x MemberInfo_VNodeState) Enum() *MemberInfo_VNodeState + func (x MemberInfo_VNodeState) Number() protoreflect.EnumNumber + func (x MemberInfo_VNodeState) String() string + type UnimplementedGossipServer struct + func (UnimplementedGossipServer) Read(context.Context, *shared.Empty) (*ClusterInfo, error) + type UnsafeGossipServer interface Other modules containing this package github.com/EventStore/EventStore-Client-Go github.com/EventStore/EventStore-Client-Go/v2 github.com/EventStore/EventStore-Client-Go/v3
Go to main page