MCPcopy Index your code

hub / github.com/Jille/raft-grpc-transport / functions

Functions257 in github.com/Jille/raft-grpc-transport

⨍ Functions 257◇ Types & classes 35
↓ 13 callersFunctionfile_transport_proto_rawDescGZIP
()
proto/transport.pb.go:1162
↓ 10 callersFunctiondecodeRPCHeader
(m *pb.RPCHeader)
fromproto.go:20
↓ 10 callersFunctiondoFuzz
(rm interface{}, i int)
completeness_test.go:16
↓ 10 callersFunctionencodeRPCHeader
(s raft.RPCHeader)
toproto.go:21
↓ 10 callersFunctionverify
(t *testing.T, rm1, rm2 interface{})
completeness_test.go:21
↓ 7 callersMethodgetPeer
(target raft.ServerAddress)
raftapi.go:41
↓ 6 callersMethodhandleRPC
(command interface{}, data io.Reader)
grpcapi.go:20
↓ 4 callersMethodAppendEntries
AppendEntries performs a single append entries request / response.
proto/transport_grpc.pb.go:28
↓ 4 callersMethodGetData
()
proto/transport.pb.go:211
↓ 4 callersMethodRecv
()
proto/transport_grpc.pb.go:288
↓ 4 callersMethodSend
(*InstallSnapshotRequest)
proto/transport_grpc.pb.go:115
↓ 3 callersMethodClose
()
raftapi.go:305
↓ 3 callersMethodInstallSnapshot
InstallSnapshot is the command sent to a Raft peer to bootstrap its log (and state machine) from a snapshot on another peer.
proto/transport_grpc.pb.go:34
↓ 3 callersMethodRequestPreVote
RequestPreVote is the command used by a candidate to ask a Raft peer for a vote in an election.
proto/transport_grpc.pb.go:36
↓ 3 callersMethodRequestVote
RequestVote is the command used by a candidate to ask a Raft peer for a vote in an election.
proto/transport_grpc.pb.go:30
↓ 3 callersMethodTimeoutNow
TimeoutNow is used to start a leadership transfer to the target node.
proto/transport_grpc.pb.go:32
↓ 3 callersFunctiondecodeAppendEntriesRequest
(m *pb.AppendEntriesRequest)
fromproto.go:8
↓ 3 callersFunctiondecodeAppendEntriesResponse
(m *pb.AppendEntriesResponse)
fromproto.go:66
↓ 3 callersFunctionencodeAppendEntriesRequest
(s *raft.AppendEntriesRequest)
toproto.go:9
↓ 3 callersFunctionencodeAppendEntriesResponse
(s *raft.AppendEntriesResponse)
toproto.go:67
↓ 2 callersMethodAppendEntriesPipeline
AppendEntriesPipeline opens an AppendEntries message stream.
proto/transport_grpc.pb.go:26
↓ 2 callersMethodConsumer
Consumer returns a channel that can be used to consume and respond to RPC requests.
raftapi.go:32
↓ 2 callersMethodRead
(b []byte)
grpcapi.go:105
↓ 2 callersMethodRegister
Register the RaftTransport gRPC service on a gRPC server.
transport.go:54
↓ 2 callersMethodTransport
Transport returns a raft.Transport that communicates over gRPC.
transport.go:59
↓ 2 callersFunctiondecodeInstallSnapshotRequest
(m *pb.InstallSnapshotRequest)
fromproto.go:96
↓ 2 callersFunctiondecodeInstallSnapshotResponse
(m *pb.InstallSnapshotResponse)
fromproto.go:111
↓ 2 callersFunctiondecodeRequestPreVoteRequest
(m *pb.RequestPreVoteRequest)
fromproto.go:131
↓ 2 callersFunctiondecodeRequestPreVoteResponse
(m *pb.RequestPreVoteResponse)
fromproto.go:140
↓ 2 callersFunctiondecodeRequestVoteRequest
(m *pb.RequestVoteRequest)
fromproto.go:76
↓ 2 callersFunctiondecodeRequestVoteResponse
(m *pb.RequestVoteResponse)
fromproto.go:87
↓ 2 callersFunctiondecodeTimeoutNowRequest
(m *pb.TimeoutNowRequest)
fromproto.go:119
↓ 2 callersFunctiondecodeTimeoutNowResponse
(m *pb.TimeoutNowResponse)
fromproto.go:125
↓ 2 callersMethoddisconnectAll
()
transport.go:76
↓ 2 callersFunctionencodeInstallSnapshotRequest
(s *raft.InstallSnapshotRequest)
toproto.go:97
↓ 2 callersFunctionencodeInstallSnapshotResponse
(s *raft.InstallSnapshotResponse)
toproto.go:112
↓ 2 callersFunctionencodeRequestPreVoteRequest
(s *raft.RequestPreVoteRequest)
toproto.go:132
↓ 2 callersFunctionencodeRequestPreVoteResponse
(s *raft.RequestPreVoteResponse)
toproto.go:141
↓ 2 callersFunctionencodeRequestVoteRequest
(s *raft.RequestVoteRequest)
toproto.go:77
↓ 2 callersFunctionencodeRequestVoteResponse
(s *raft.RequestVoteResponse)
toproto.go:88
↓ 2 callersFunctionencodeTimeoutNowRequest
(s *raft.TimeoutNowRequest)
toproto.go:120
↓ 2 callersFunctionencodeTimeoutNowResponse
(s *raft.TimeoutNowResponse)
toproto.go:126
↓ 2 callersFunctionisHeartbeat
(command interface{})
grpcapi.go:140
↓ 2 callersFunctionmakeTestPair
(ctx context.Context, t *testing.T)
pair_test.go:19
↓ 1 callersMethodClose
()
transport.go:63
↓ 1 callersMethodCloseAndRecv
()
proto/transport_grpc.pb.go:116
↓ 1 callersMethodDescriptor
()
proto/transport.pb.go:65
↓ 1 callersMethodDescriptor
Deprecated: Use Log.ProtoReflect.Descriptor instead.
proto/transport.pb.go:186
↓ 1 callersMethodSendAndClose
(*InstallSnapshotResponse)
proto/transport_grpc.pb.go:287
↓ 1 callersFunctiondecodeLog
(m *pb.Log)
fromproto.go:36
↓ 1 callersFunctiondecodeLogType
(m pb.Log_LogType)
fromproto.go:47
↓ 1 callersFunctiondecodeLogs
(m []*pb.Log)
fromproto.go:28
↓ 1 callersFunctionencodeLog
(s *raft.Log)
toproto.go:37
↓ 1 callersFunctionencodeLogType
(s raft.LogType)
toproto.go:48
↓ 1 callersFunctionencodeLogs
(s []*raft.Log)
toproto.go:29
↓ 1 callersFunctionfile_transport_proto_init
()
proto/transport.pb.go:1221
↓ 1 callersMethodreceiver
()
raftapi.go:232
MethodAppendEntries
AppendEntries sends the appropriate RPC to the target node.
raftapi.go:66
MethodAppendEntries
AppendEntries is used to add another request to the pipeline. The send may block which is an effective form of back-pressure.
raftapi.go:198
MethodAppendEntries
(ctx context.Context, req *pb.AppendEntriesRequest)
grpcapi.go:55
MethodAppendEntries
(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption)
proto/transport_grpc.pb.go:78
MethodAppendEntries
AppendEntries performs a single append entries request / response.
proto/transport_grpc.pb.go:155
MethodAppendEntries
(context.Context, *AppendEntriesRequest)
proto/transport_grpc.pb.go:174
MethodAppendEntriesPipeline
AppendEntriesPipeline returns an interface that can be used to pipeline AppendEntries requests.
raftapi.go:166
MethodAppendEntriesPipeline
(s pb.RaftTransport_AppendEntriesPipelineServer)
grpcapi.go:122
MethodAppendEntriesPipeline
(ctx context.Context, opts ...grpc.CallOption)
proto/transport_grpc.pb.go:47
MethodAppendEntriesPipeline
AppendEntriesPipeline opens an AppendEntries message stream.
proto/transport_grpc.pb.go:153
MethodAppendEntriesPipeline
(RaftTransport_AppendEntriesPipelineServer)
proto/transport_grpc.pb.go:171
MethodClose
Close closes the pipeline and cancels all inflight RPCs
raftapi.go:224
MethodCloseAndRecv
()
proto/transport_grpc.pb.go:128
MethodConnect
(target raft.ServerAddress, t raft.Transport)
raftapi.go:309
MethodConsumer
Consumer returns a channel that can be used to consume response futures when they are ready.
raftapi.go:219
MethodDecodePeer
DecodePeer is used to deserialize a peer's address.
raftapi.go:291
MethodDescriptor
Deprecated: Use RPCHeader.ProtoReflect.Descriptor instead.
proto/transport.pb.go:120
MethodDescriptor
Deprecated: Use AppendEntriesRequest.ProtoReflect.Descriptor instead.
proto/transport.pb.go:274
MethodDescriptor
Deprecated: Use AppendEntriesResponse.ProtoReflect.Descriptor instead.
proto/transport.pb.go:367
MethodDescriptor
Deprecated: Use RequestVoteRequest.ProtoReflect.Descriptor instead.
proto/transport.pb.go:447
MethodDescriptor
Deprecated: Use RequestVoteResponse.ProtoReflect.Descriptor instead.
proto/transport.pb.go:532
MethodDescriptor
Deprecated: Use TimeoutNowRequest.ProtoReflect.Descriptor instead.
proto/transport.pb.go:600
MethodDescriptor
Deprecated: Use TimeoutNowResponse.ProtoReflect.Descriptor instead.
proto/transport.pb.go:647
MethodDescriptor
Deprecated: Use InstallSnapshotRequest.ProtoReflect.Descriptor instead.
proto/transport.pb.go:706
MethodDescriptor
Deprecated: Use InstallSnapshotResponse.ProtoReflect.Descriptor instead.
proto/transport.pb.go:825
MethodDescriptor
Deprecated: Use RequestPreVoteRequest.ProtoReflect.Descriptor instead.
proto/transport.pb.go:889
MethodDescriptor
Deprecated: Use RequestPreVoteResponse.ProtoReflect.Descriptor instead.
proto/transport.pb.go:959
MethodDisconnect
(target raft.ServerAddress)
raftapi.go:313
MethodDisconnectAll
()
raftapi.go:327
MethodEncodePeer
EncodePeer is used to serialize a peer's address.
raftapi.go:286
MethodEnum
()
proto/transport.pb.go:55
MethodEnumDescriptor
Deprecated: Use Log_LogType.Descriptor instead.
proto/transport.pb.go:78
MethodError
Error blocks until the future arrives and then returns the error status of the future. This may be called any number of times - all calls will return
raftapi.go:261
MethodGetAddr
()
proto/transport.pb.go:138
MethodGetAppendedAt
()
proto/transport.pb.go:225
MethodGetCandidate
()
proto/transport.pb.go:465
MethodGetConfiguration
()
proto/transport.pb.go:759
MethodGetConfigurationIndex
()
proto/transport.pb.go:766
MethodGetData
()
proto/transport.pb.go:780
MethodGetEntries
()
proto/transport.pb.go:313
MethodGetExtensions
()
proto/transport.pb.go:218
MethodGetGranted
()
proto/transport.pb.go:557
MethodGetGranted
()
proto/transport.pb.go:977
next →1–100 of 257, ranked by callers