Method Fetch

kayak/runtime.go:332–360

Fetch defines entry for missing log startFetch.

(ctx context.Context, index uint64)

// Fetch defines entry for missing log startFetch.
func (r *Runtime) Fetch(ctx context.Context, index uint64) (l *kt.Log, err error) {
	if atomic.LoadUint32(&r.started) != 1 {
		err = kt.ErrStopped
		return
	}

	tm := timer.NewTimer()

	defer func() {
		log.WithField("l", index).
			WithFields(tm.ToLogFields()).
			WithError(err).
			Debug("kayak log startFetch")
	}()

	r.peersLock.RLock()
	defer r.peersLock.RUnlock()

	tm.Add("peers_lock")

	if r.role != proto.Leader {
		// not leader
		err = kt.ErrNotLeader
		return
	}

	// wal get
	return r.wal.Get(index)
}

// FollowerApply defines entry for follower node.
func (r *Runtime) FollowerApply(l *kt.Log) (err error) {