Function registerResumableStepName

resumable.go:162–170

(state *rivermiddleware.ResumableState, name string)

}

func registerResumableStepName(state *rivermiddleware.ResumableState, name string) bool {
	if _, ok := state.AllStepNames[name]; ok {
		state.Err = fmt.Errorf("river: duplicate resumable step name %q", name)
		return false
	}

	state.AllStepNames[name] = struct{}{}
	return true
}

func resumableStateFromContext(ctx context.Context) (*rivermiddleware.ResumableState, bool) {
	state := ctx.Value(rivermiddleware.ResumableContextKey{})