MCPcopy Create free account

hub / github.com/hashicorp/memberlist / functions

Functions469 in github.com/hashicorp/memberlist

⨍ Functions 469◇ Types & classes 76
MethodNotifyLeave
(n *Node)
event_delegate.go:59
MethodNotifyLeave
NotifyLeave is invoked when a node is detected to have left. The Node argument must not be modified.
state_test.go:1494
MethodNotifyMerge
(nodes []*Node)
memberlist_test.go:958
MethodNotifyMsg
(msg []byte)
memberlist_test.go:118
MethodNotifyPingComplete
(other *Node, rtt time.Duration, payload []byte)
memberlist_test.go:1939
MethodNotifyUpdate
(n *Node)
event_delegate.go:64
MethodNotifyUpdate
NotifyUpdate is invoked when a node is detected to have updated, usually involving the meta data. The Node argument must not be modified.
state_test.go:1505
MethodPacketCh
See Transport.
mock_transport.go:118
MethodPacketCh
See Transport.
net_transport.go:209
MethodRead
(b []byte)
net_test.go:1062
MethodRead
(p []byte)
peeked_conn.go:38
FunctionRun
(t Failer, f func(r *R))
internal/retry/retry.go:91
FunctionRunWith
(r Retryer, t Failer, f func(r *R))
internal/retry/retry.go:95
MethodServeDNS
(w dns.ResponseWriter, r *dns.Msg)
memberlist_test.go:537
MethodShutdown
See Transport.
mock_transport.go:182
MethodShutdown
Shutdown will stop any background maintenance of network activity for this memberlist, causing it to appear "dead". A leave message will not be broadc
memberlist.go:731
MethodStreamCh
See Transport.
mock_transport.go:171
MethodStreamCh
See Transport.
net_transport.go:258
MethodString
()
transport.go:81
FunctionTestAddLabelHeaderToPacket
(t *testing.T)
label_test.go:16
FunctionTestAddLabelHeaderToStream
(t *testing.T)
label_test.go:158
FunctionTestAdvertiseAddr
(t *testing.T)
memberlist_test.go:1847
FunctionTestAwareness
(t *testing.T)
awareness_test.go:11
FunctionTestCompressDecompressPayload
(t *testing.T)
util_test.go:375
FunctionTestCreate
(t *testing.T)
memberlist_test.go:335
FunctionTestCreate_checkBroadcastQueueMetrics
(t *testing.T)
memberlist_test.go:253
FunctionTestCreate_invalidLoggerSettings
(t *testing.T)
memberlist_test.go:322
FunctionTestCreate_keyringAndSecretKey
(t *testing.T)
memberlist_test.go:295
FunctionTestCreate_keyringOnly
(t *testing.T)
memberlist_test.go:274
FunctionTestCreate_protocolVersion
(t *testing.T)
memberlist_test.go:169
FunctionTestCreate_secretKey
(t *testing.T)
memberlist_test.go:203
FunctionTestCreate_secretKeyEmpty
(t *testing.T)
memberlist_test.go:235
FunctionTestDecodeCompoundMessage
(t *testing.T)
util_test.go:314
FunctionTestDecodeCompoundMessage_NumberOfPartsOverflow
(t *testing.T)
util_test.go:341
FunctionTestDecodeCompoundMessage_Trunc
(t *testing.T)
util_test.go:348
FunctionTestDefaultLANConfig_protocolVersion
(t *testing.T)
memberlist_test.go:162
FunctionTestEncodeDecode
(t *testing.T)
util_test.go:43
FunctionTestEncryptDecryptState
(t *testing.T)
net_test.go:750
FunctionTestEncryptDecrypt_V0
(t *testing.T)
security_test.go:38
FunctionTestEncryptDecrypt_V1
(t *testing.T)
security_test.go:42
FunctionTestGossip_MismatchedKeys
(t *testing.T)
net_test.go:961
FunctionTestHandleCommand
(t *testing.T)
net_test.go:1011
FunctionTestHandleCompoundPing
As a regression we left this test very low-level and network-ey, even after we abstracted the transport. We added some basic network-free transport te
net_test.go:28
FunctionTestHandleConn_NilConnAfterRemoveLabelHeaderFromStream
(t *testing.T)
net_test.go:1020
FunctionTestHandleIndirectPing
(t *testing.T)
net_test.go:227
FunctionTestHandlePing
(t *testing.T)
net_test.go:105
FunctionTestHandlePing_WrongNode
(t *testing.T)
net_test.go:177
FunctionTestIngestPacket_CRC
(t *testing.T)
net_test.go:865
FunctionTestIngestPacket_ExportedFunc_EmptyMessage
(t *testing.T)
net_test.go:917
FunctionTestKRandomNodes
(t *testing.T)
util_test.go:242
FunctionTestKeyRing_MultiKeyEncryptDecrypt
(t *testing.T)
keyring_test.go:107
FunctionTestKeyring_AddRemoveUse
(t *testing.T)
keyring_test.go:56
FunctionTestKeyring_EmptyRing
(t *testing.T)
keyring_test.go:17
FunctionTestKeyring_GetPrimaryKey
(t *testing.T)
keyring_test.go:43
FunctionTestKeyring_PrimaryOnly
(t *testing.T)
keyring_test.go:30
FunctionTestLabelOverhead
(t *testing.T)
label_test.go:371
FunctionTestLimitedBroadcastLess
(t *testing.T)
queue_test.go:13
FunctionTestLogging_Address
(t *testing.T)
logging_test.go:12
FunctionTestLogging_Conn
(t *testing.T)
logging_test.go:29
FunctionTestMakeCompoundMessage
(t *testing.T)
util_test.go:299
FunctionTestMemberList_AliveNode_ChangeMeta
Serf Bug: GH-58, Meta data does not update
state_test.go:1514
FunctionTestMemberList_AliveNode_Conflict
(t *testing.T)
state_test.go:1615
FunctionTestMemberList_AliveNode_Idempotent
(t *testing.T)
state_test.go:1422
FunctionTestMemberList_AliveNode_NewNode
(t *testing.T)
state_test.go:1318
FunctionTestMemberList_AliveNode_Refute
(t *testing.T)
state_test.go:1571
FunctionTestMemberList_AliveNode_SuspectNode
(t *testing.T)
state_test.go:1367
FunctionTestMemberList_CreateShutdown
(t *testing.T)
memberlist_test.go:382
FunctionTestMemberList_DeadNode
(t *testing.T)
state_test.go:1990
FunctionTestMemberList_DeadNodeLeft
(t *testing.T)
state_test.go:1912
FunctionTestMemberList_DeadNode_AliveReplay
(t *testing.T)
state_test.go:2105
FunctionTestMemberList_DeadNode_Double
(t *testing.T)
state_test.go:2043
FunctionTestMemberList_DeadNode_NoNode
(t *testing.T)
state_test.go:1897
FunctionTestMemberList_DeadNode_OldDead
(t *testing.T)
state_test.go:2083
FunctionTestMemberList_DeadNode_Refute
(t *testing.T)
state_test.go:2129
FunctionTestMemberList_Members
(t *testing.T)
memberlist_test.go:652
FunctionTestMemberList_MergeState
(t *testing.T)
state_test.go:2172
FunctionTestMemberList_NextSeq
(t *testing.T)
state_test.go:1167
FunctionTestMemberList_Ping
(t *testing.T)
state_test.go:1077
FunctionTestMemberList_Probe
(t *testing.T)
state_test.go:43
FunctionTestMemberList_ProbeNode
(t *testing.T)
state_test.go:1031
FunctionTestMemberList_ProbeNode_Awareness_Degraded
* func TestMemberList_ProbeNode_FallbackTCP(t *testing.T) { addr1 := getBindAddr() addr2 := getBindAddr() addr3 := getBindAddr() addr4 := getBindA
state_test.go:584
FunctionTestMemberList_ProbeNode_Awareness_Improved
(t *testing.T)
state_test.go:752
FunctionTestMemberList_ProbeNode_Awareness_MissedNack
(t *testing.T)
state_test.go:805
FunctionTestMemberList_ProbeNode_Awareness_OldProtocol
(t *testing.T)
state_test.go:888
FunctionTestMemberList_ProbeNode_Buddy
(t *testing.T)
state_test.go:975
FunctionTestMemberList_ProbeNode_Suspect
(t *testing.T)
state_test.go:100
FunctionTestMemberList_ProbeNode_Suspect_Dogpile
(t *testing.T)
state_test.go:162
FunctionTestMemberList_ProbeNode_Wrong_VSN
(t *testing.T)
state_test.go:680
FunctionTestMemberList_ResetNodes
(t *testing.T)
state_test.go:1130
FunctionTestMemberList_ResolveAddr
(t *testing.T)
memberlist_test.go:388
FunctionTestMemberList_ResolveAddr_TCP_First
(t *testing.T)
memberlist_test.go:571
FunctionTestMemberList_SuspectNode
(t *testing.T)
state_test.go:1715
FunctionTestMemberList_SuspectNode_DoubleSuspect
(t *testing.T)
state_test.go:1781
FunctionTestMemberList_SuspectNode_NoNode
(t *testing.T)
state_test.go:1700
FunctionTestMemberList_SuspectNode_OldSuspect
(t *testing.T)
state_test.go:1824
FunctionTestMemberList_SuspectNode_Refute
(t *testing.T)
state_test.go:1854
FunctionTestMemberList_invokeAckHandler
(t *testing.T)
state_test.go:1213
FunctionTestMemberList_invokeAckHandler_Channel_Ack
(t *testing.T)
state_test.go:1232
FunctionTestMemberList_invokeAckHandler_Channel_Nack
(t *testing.T)
state_test.go:1266
FunctionTestMemberList_setAckHandler
(t *testing.T)
state_test.go:1200
← previousnext →301–400 of 469, ranked by callers