Lines Matching defs:peer
101 type peer struct { struct
102 lg *zap.Logger
104 localID types.ID
106 id types.ID
108 r Raft
110 status *peerStatus
112 picker *urlPicker
114 msgAppV2Writer *streamWriter
115 writer *streamWriter
116 pipeline *pipeline
117 snapSender *snapshotSender // snapshot sender to send v3 snapshot messages
118 msgAppV2Reader *streamReader
119 msgAppReader *streamReader
121 recvc chan raftpb.Message
122 propc chan raftpb.Message
124 mu sync.Mutex
125 paused bool
127 cancel context.CancelFunc // cancel pending works in go routine created by peer.
128 stopc chan struct{}
236 func (p *peer) send(m raftpb.Message) {
282 func (p *peer) sendSnap(m snap.Message) {
286 func (p *peer) update(urls types.URLs) {
290 func (p *peer) attachOutgoingConn(conn *outgoingConn) {
307 func (p *peer) activeSince() time.Time { return p.status.activeSince() }
311 func (p *peer) Pause() {
320 func (p *peer) Resume() {
328 func (p *peer) stop() {
351 func (p *peer) pick(m raftpb.Message) (writec chan<- raftpb.Message, picked string) {