// Visitor 即為訪問者這個(gè)對象
type Visitor interface {
	Visit(VisitorFunc) error
}
// VisitorFunc對應(yīng)這個(gè)對象的方法，也就是定義中的“操作”
type VisitorFunc func(*Info, error) error

// VisitorList定義為[]Visitor，又實(shí)現(xiàn)了Visit方法，也就是將多個(gè)[]Visitor封裝為一個(gè)Visitor
type VisitorList []Visitor
// 發(fā)生error就立刻返回，不繼續(xù)遍歷
func (l VisitorList) Visit(fn VisitorFunc) error {
	for i := range l {
		if err := l[i].Visit(fn); err != nil {
			return err
		}
	}
	return nil
}

// EagerVisitorList 也是將多個(gè)[]Visitor封裝為一個(gè)Visitor
type EagerVisitorList []Visitor
// 返回的錯(cuò)誤暫存到[]error中，統(tǒng)一聚合
func (l EagerVisitorList) Visit(fn VisitorFunc) error {
	errs := []error(nil)
	for i := range l {
		if err := l[i].Visit(func(info *Info, err error) error {
			if err != nil {
				errs = append(errs, err)
				return nil
			}
			if err := fn(info, nil); err != nil {
				errs = append(errs, err)
			}
			return nil
		}); err != nil {
			errs = append(errs, err)
		}
	}
	return utilerrors.NewAggregate(errs)
}

// 裝飾器Visitor
type DecoratedVisitor struct {
	visitor    Visitor
	decorators []VisitorFunc
}
// visitor遍歷調(diào)用decorators中所有函數(shù)，有失敗立即返回
func (v DecoratedVisitor) Visit(fn VisitorFunc) error {
	return v.visitor.Visit(func(info *Info, err error) error {
		if err != nil {
			return err
		}
		for i := range v.decorators {
			if err := v.decorators[i](info, nil); err != nil {
				return err
			}
		}
		return fn(info, nil)
	})
}

// 報(bào)錯(cuò)依舊繼續(xù)
type ContinueOnErrorVisitor struct {
	Visitor
}
// 報(bào)錯(cuò)不立即返回，聚合所有錯(cuò)誤后返回
func (v ContinueOnErrorVisitor) Visit(fn VisitorFunc) error {
	errs := []error{}
	err := v.Visitor.Visit(func(info *Info, err error) error {
		if err != nil {
			errs = append(errs, err)
			return nil
		}
		if err := fn(info, nil); err != nil {
			errs = append(errs, err)
		}
		return nil
	})
	if err != nil {
		errs = append(errs, err)
	}
	if len(errs) == 1 {
		return errs[0]
	}
	return utilerrors.NewAggregate(errs)
}

type FlattenListVisitor struct {
	visitor Visitor
	typer   runtime.ObjectTyper
	mapper  *mapper
}

// 過濾的Info
type FilteredVisitor struct {
	visitor Visitor
	filters []FilterFunc
}
func (v FilteredVisitor) Visit(fn VisitorFunc) error {
	return v.visitor.Visit(func(info *Info, err error) error {
		if err != nil {
			return err
		}
		for _, filter := range v.filters {
      // 檢驗(yàn)Info是否滿足條件，出錯(cuò)則退出
			ok, err := filter(info, nil)
			if err != nil {
				return err
			}
			if !ok {
				return nil
			}
		}
		return fn(info, nil)
	})
}

type StreamVisitor struct {
  // 讀取信息的來源，實(shí)現(xiàn)了Read這個(gè)接口，這個(gè)"流式"的概念，包括了常見的HTTP、文件、標(biāo)準(zhǔn)輸入等各類輸入
	io.Reader
	*mapper
	Source string
	Schema ContentValidator
}

type FileVisitor struct {
  // 表示文件路徑或者STDIN
	Path string
	*StreamVisitor
}

type URLVisitor struct {
	URL *url.URL
	*StreamVisitor
  // 提供錯(cuò)誤重試次數(shù)
	HttpAttemptCount int
}

type KustomizeVisitor struct {
	Path string
	*StreamVisitor
}

// 在RunCreate函數(shù)中，關(guān)鍵的發(fā)送函數(shù)
obj, err := resource.
				NewHelper(info.Client, info.Mapping).
				DryRun(o.DryRunStrategy == cmdutil.DryRunServer).
				WithFieldManager(o.fieldManager).
				Create(info.Namespace, true, info.Object)
// 進(jìn)入create函數(shù)，查看到
m.createResource(m.RESTClient, m.Resource, namespace, obj, options)
// 對應(yīng)的實(shí)現(xiàn)為
func (m *Helper) createResource(c RESTClient, resource, namespace string, obj runtime.Object, options *metav1.CreateOptions) (runtime.Object, error) {
	return c.Post().
		NamespaceIfScoped(namespace, m.NamespaceScoped).
		Resource(resource).
		VersionedParams(options, metav1.ParameterCodec).
		Body(obj).
		Do(context.TODO()).
		Get()
}
/*
到這里，我們發(fā)現(xiàn)了2個(gè)關(guān)鍵性的定義:
1. RESTClient 與kube-apiserver交互的RESTful風(fēng)格的客戶端 這個(gè)RESTClient是來自于Builder時(shí)的傳入，生成的Result，底層是一個(gè)NewClientWithOptions生成的
2. runtime.Object 資源對象的抽象，包括Pod/Deployment/Service等各類資源
3. 我們是傳入的文件，是FileVisitor來執(zhí)行的，底層Builder.mapper調(diào)用Decode來生成obj(Unstructured())
*/

// 從傳入?yún)?shù)來看，數(shù)據(jù)來源于Info這個(gè)結(jié)構(gòu)
r.Visit(func(info *resource.Info, err error) error{})
// 而info來源于前面的Builder，前面部分都是將Builder參數(shù)化，核心的生成為Do函數(shù)
r := f.NewBuilder().
		Unstructured().
		Schema(schema).
		ContinueOnError().
		NamespaceParam(cmdNamespace).DefaultNamespace().
		FilenameParam(enforceNamespace, &o.FilenameOptions).
		LabelSelectorParam(o.Selector).
		Flatten().
		Do()
// 大致看一下這些函數(shù)，我們可以在Unstructured()中看到getClient函數(shù)，其實(shí)這就是我們要找的函數(shù)
func (b *Builder) getClient(gv schema.GroupVersion) (RESTClient, error) 
// 從返回值來看，client包括默認(rèn)的REST client和配置選項(xiàng)
NewClientWithOptions(client, b.requestTransforms...)
// 這個(gè)Client會(huì)在kubernetes項(xiàng)目中大量出現(xiàn)，它是與kube-apiserver交互的核心組件，以后再深入。

func (v *FileVisitor) Visit(fn VisitorFunc) error {
	// 省略讀取這塊的代碼，底層調(diào)用的是StreamVisitor的邏輯
	return v.StreamVisitor.Visit(fn)
}
func (v *StreamVisitor) Visit(fn VisitorFunc) error {
	d := yaml.NewYAMLOrJSONDecoder(v.Reader, 4096)
	for {
		// 這里就是返回info的地方
		info, err := v.infoForData(ext.Raw, v.Source)
  }
}
// 再往下一層看，來到mapper層，也就是kubernetes的資源對象映射關(guān)系
func (m *mapper) infoForData(data []byte, source string) (*Info, error){
  // 這里就是我們返回Object的地方，其中GVK是Group/Version/Kind的縮寫，后續(xù)我們會(huì)涉及
  obj, gvk, err := m.decoder.Decode(data, nil, nil)
}

// 在Builder初始化中，我們就找到了
func (b *Builder) Unstructured() *Builder {
	b.mapper = &mapper{
		localFn:      b.isLocal,
		restMapperFn: b.restMapperFn,
		clientFn:     b.getClient,
    // 我們查找資源用到的是這個(gè)decoder
		decoder:      &metadataValidatingDecoder{unstructured.UnstructuredJSONScheme},
	}
	return b
}
// 逐層往下找，對應(yīng)的Decode方法的實(shí)現(xiàn)，就是對應(yīng)的數(shù)據(jù)解析成data：
func (s unstructuredJSONScheme) decode(data []byte) (runtime.Object, error) {
	// 細(xì)節(jié)暫時(shí)忽略
}

// RESTful接口風(fēng)格中，POST請求對應(yīng)的就是CREATE方法
c.Post().
		NamespaceIfScoped(namespace, m.NamespaceScoped).
		Resource(resource).
		VersionedParams(options, metav1.ParameterCodec).
		Body(obj).
		Do(context.TODO()). 
		Get() 
// Do方法，發(fā)送請求
err := r.request(ctx, func(req *http.Request, resp *http.Response) {
		result = r.transformResponse(resp, req)
	})
// Get方法，獲取請求的返回結(jié)果，用來打印狀態(tài)
switch t := out.(type) {
	case *metav1.Status:
		if t.Status != metav1.StatusSuccess {
			return nil, errors.FromObject(t)
		}
	}