K8s源码分析(15)-资源的服务层策略接口实现

//  kubernetes/blob/master/pkg/registry/apps/daemonset/strategy.go
type daemonSetStrategy struct {
  runtime.ObjectTyper
  names.NameGenerator
}

var Strategy = daemonSetStrategy{legacyscheme.Scheme, names.SimpleNameGenerator}

func (daemonSetStrategy) NamespaceScoped() bool{...}
func (daemonSetStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object){...} 
func (daemonSetStrategy) Validate(ctx context.Context, obj runtime.Object) field.ErrorList{...}
func (daemonSetStrategy) Canonicalize(obj runtime.Object){...}
func (daemonSetStrategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList{...} 
func (daemonSetStrategy) AllowCreateOnUpdate(){...}
func (daemonSetStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object){...}

// pkg/registry/apps/daemonset/storage/storage.go
type REST struct {
  *genericregistry.Store
  categories []string
}

type StatusREST struct {
  store *genericregistry.Store
}

func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) {
  store := &genericregistry.Store{
    NewFunc:                  func() runtime.Object { return &apps.DaemonSet{} },
    NewListFunc:              func() runtime.Object { return &apps.DaemonSetList{} },
    DefaultQualifiedResource: apps.Resource("daemonsets"),

    CreateStrategy:      daemonset.Strategy,
    UpdateStrategy:      daemonset.Strategy,
    DeleteStrategy:      daemonset.Strategy,
    ResetFieldsStrategy: daemonset.Strategy,

    TableConvertor: printerstorage.TableConvertor{TableGenerator: printers.NewTableGenerator().With(printersinternal.AddHandlers)},
  }
  options := &generic.StoreOptions{RESTOptions: optsGetter}
  if err := store.CompleteWithOptions(options); err != nil {
    return nil, nil, err
  }

  statusStore := *store
  statusStore.UpdateStrategy = daemonset.StatusStrategy
  statusStore.ResetFieldsStrategy = daemonset.StatusStrategy

  return &REST{store, []string{"all"}}, &StatusREST{store: &statusStore}, nil
}