Method leaderCommitResult

kayak/commit.go:32–59

(ctx context.Context, tm *timer.Timer, reqPayload interface{}, prepareLog *kt.Log)

)

func (r *Runtime) leaderCommitResult(ctx context.Context, tm *timer.Timer, reqPayload interface{}, prepareLog *kt.Log) (res *commitFuture) {
	defer trace.StartRegion(ctx, "leaderCommitResult").End()

	// decode log and send to commit channel to process
	res = newCommitFuture()

	if prepareLog == nil {
		res.Set(&commitResult{err: errors.Wrap(kt.ErrInvalidLog, "nil prepare log in commit")})
		return
	}

	// decode prepare log
	req := &commitReq{
		ctx:    ctx,
		data:   reqPayload,
		index:  prepareLog.Index,
		result: res,
		tm:     tm,
	}

	select {
	case <-ctx.Done():
		res = nil
	case r.commitCh <- req:
	}

	return
}

func (r *Runtime) followerCommitResult(ctx context.Context, tm *timer.Timer, commitLog *kt.Log, prepareLog *kt.Log, lastCommit uint64) (res *commitFuture) {
	defer trace.StartRegion(ctx, "followerCommitResult").End()