Versions in this module Expand all Collapse all v1 v1.0.1 May 18, 2017 Changes in this version + const KeyClusterID + const KeyDeadReplicasPrefix + const KeyFirstRangeDescriptor + const KeyNodeIDPrefix + const KeyNodeLivenessPrefix + const KeySentinel + const KeyStorePrefix + const KeySystemConfig + var ErrIntOverflowGossip = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGossip = fmt.Errorf("proto: negative length found during unmarshaling") + var GossipStoresInterval = envutil.EnvOrDefaultDuration("COCKROACH_GOSSIP_STORES_INTERVAL", defaultGossipStoresInterval) + var MetaBytesReceived = metric.Metadata + var MetaBytesSent = metric.Metadata + var MetaConnectionsIncomingGauge = metric.Metadata + var MetaConnectionsOutgoingGauge = metric.Metadata + var MetaConnectionsRefused = metric.Metadata + var MetaInfosReceived = metric.Metadata + var MetaInfosSent = metric.Metadata + func IsNodeIDKey(key string) bool + func MakeDeadReplicasKey(storeID roachpb.StoreID) string + func MakeKey(components ...string) string + func MakeNodeIDKey(nodeID roachpb.NodeID) string + func MakeNodeLivenessKey(nodeID roachpb.NodeID) string + func MakePrefixPattern(prefix string) string + func MakeStoreKey(storeID roachpb.StoreID) string + func NodeIDFromKey(key string) (roachpb.NodeID, error) + func RegisterGossipServer(s *grpc.Server, srv GossipServer) + type BootstrapInfo struct + Addresses []cockroach_util.UnresolvedAddr + Timestamp cockroach_util_hlc.Timestamp + func (*BootstrapInfo) Descriptor() ([]byte, []int) + func (*BootstrapInfo) ProtoMessage() + func (m *BootstrapInfo) Marshal() (dAtA []byte, err error) + func (m *BootstrapInfo) MarshalTo(dAtA []byte) (int, error) + func (m *BootstrapInfo) Reset() + func (m *BootstrapInfo) Size() (n int) + func (m *BootstrapInfo) String() string + func (m *BootstrapInfo) Unmarshal(dAtA []byte) error + type Callback func(string, roachpb.Value) + type Gossip struct + Connected chan struct{} + func New(ambient log.AmbientContext, nodeID *base.NodeIDContainer, ...) *Gossip + func NewTest(nodeID roachpb.NodeID, rpcContext *rpc.Context, grpcServer *grpc.Server, ...) *Gossip + func (g *Gossip) AddInfo(key string, val []byte, ttl time.Duration) error + func (g *Gossip) AddInfoProto(key string, msg proto.Message, ttl time.Duration) error + func (g *Gossip) EnableSimulationCycler(enable bool) + func (g *Gossip) GetInfo(key string) ([]byte, error) + func (g *Gossip) GetInfoProto(key string, msg proto.Message) error + func (g *Gossip) GetInfoStatus() InfoStatus + func (g *Gossip) GetNodeDescriptor(nodeID roachpb.NodeID) (*roachpb.NodeDescriptor, error) + func (g *Gossip) GetNodeIDAddress(nodeID roachpb.NodeID) (*util.UnresolvedAddr, error) + func (g *Gossip) GetNodeMetrics() *Metrics + func (g *Gossip) GetResolvers() []resolver.Resolver + func (g *Gossip) GetSystemConfig() (config.SystemConfig, bool) + func (g *Gossip) Incoming() []roachpb.NodeID + func (g *Gossip) LogStatus() + func (g *Gossip) MaxHops() uint32 + func (g *Gossip) Outgoing() []roachpb.NodeID + func (g *Gossip) RegisterCallback(pattern string, method Callback) func() + func (g *Gossip) RegisterSystemConfigChannel() <-chan struct{} + func (g *Gossip) SetBootstrapInterval(interval time.Duration) + func (g *Gossip) SetCullInterval(interval time.Duration) + func (g *Gossip) SetNodeDescriptor(desc *roachpb.NodeDescriptor) error + func (g *Gossip) SetStallInterval(interval time.Duration) + func (g *Gossip) SetStorage(storage Storage) error + func (g *Gossip) SimulationCycle() + func (g *Gossip) Start(advertAddr net.Addr, resolvers []resolver.Resolver) + func (s Gossip) GetClusterID() uuid.UUID + func (s Gossip) GetNodeAddr() *util.UnresolvedAddr + func (s Gossip) Gossip(stream Gossip_GossipServer) error + func (s Gossip) SetClusterID(clusterID uuid.UUID) + type GossipClient interface + Gossip func(ctx context.Context, opts ...grpc.CallOption) (Gossip_GossipClient, error) + func NewGossipClient(cc *grpc.ClientConn) GossipClient + type GossipServer interface + Gossip func(Gossip_GossipServer) error + type Gossip_GossipClient interface + Recv func() (*Response, error) + Send func(*Request) error + type Gossip_GossipServer interface + Recv func() (*Request, error) + Send func(*Response) error + type Info struct + Hops uint32 + NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID + OrigStamp int64 + PeerID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID + TTLStamp int64 + Value cockroach_roachpb1.Value + func (*Info) Descriptor() ([]byte, []int) + func (*Info) ProtoMessage() + func (m *Info) Marshal() (dAtA []byte, err error) + func (m *Info) MarshalTo(dAtA []byte) (int, error) + func (m *Info) Reset() + func (m *Info) Size() (n int) + func (m *Info) String() string + func (m *Info) Unmarshal(dAtA []byte) error + type InfoStatus struct + Infos map[string]Info + func (*InfoStatus) Descriptor() ([]byte, []int) + func (*InfoStatus) ProtoMessage() + func (m *InfoStatus) Marshal() (dAtA []byte, err error) + func (m *InfoStatus) MarshalTo(dAtA []byte) (int, error) + func (m *InfoStatus) Reset() + func (m *InfoStatus) Size() (n int) + func (m *InfoStatus) String() string + func (m *InfoStatus) Unmarshal(dAtA []byte) error + type Metrics struct + BytesReceived *metric.Counter + BytesSent *metric.Counter + ConnectionsRefused *metric.Counter + InfosReceived *metric.Counter + InfosSent *metric.Counter + func (m Metrics) String() string + type Request struct + Addr cockroach_util.UnresolvedAddr + ClusterID github_com_cockroachdb_cockroach_pkg_util_uuid.UUID + Delta map[string]*Info + HighWaterStamps map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]int64 + NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID + func (*Request) Descriptor() ([]byte, []int) + func (*Request) GetUser() string + func (*Request) ProtoMessage() + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + type Response struct + Addr cockroach_util.UnresolvedAddr + AlternateAddr *cockroach_util.UnresolvedAddr + AlternateNodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID + Delta map[string]*Info + HighWaterStamps map[github_com_cockroachdb_cockroach_pkg_roachpb.NodeID]int64 + NodeID github_com_cockroachdb_cockroach_pkg_roachpb.NodeID + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + type Storage interface + ReadBootstrapInfo func(*BootstrapInfo) error + WriteBootstrapInfo func(*BootstrapInfo) error
Go to main page