type Reader … type ResourceNodeSlice … var _ … func (o ResourceNodeSlice) Read() ([]*yaml.RNode, error) { … } type Writer … type WriterFunc … func (fn WriterFunc) Write(o []*yaml.RNode) error { … } type ReaderWriter … type Filter … type TrackableFilter … type FilterFunc … func (fn FilterFunc) Filter(o []*yaml.RNode) ([]*yaml.RNode, error) { … } type Pipeline … // Execute executes each step in the sequence, returning immediately after encountering // any error as part of the Pipeline. func (p Pipeline) Execute() error { … } type PipelineExecuteCallbackFunc … // ExecuteWithCallback executes each step in the sequence, returning immediately after encountering // any error as part of the Pipeline. The callback will be called each time a step succeeds. func (p Pipeline) ExecuteWithCallback(callback PipelineExecuteCallbackFunc) error { … } // FilterAll runs the yaml.Filter against all inputs func FilterAll(filter yaml.Filter) Filter { … } // PreprocessResourcesForInternalAnnotationMigration returns a mapping from id to all // internal annotations, so that we can use it to reconcile the annotations // later. This is necessary because currently both internal-prefixed annotations // and legacy annotations are currently supported, and a change to one must be // reflected in the other if needed. func PreprocessResourcesForInternalAnnotationMigration(result []*yaml.RNode) (map[string]map[string]string, error) { … } func checkMismatchedAnnos(annotations map[string]string) error { … } type nodeAnnotations … // ReconcileInternalAnnotations reconciles the annotation format for path, index and id annotations. // It will ensure the output annotation format matches the format in the input. e.g. if the input // format uses the legacy format and the output will be converted to the legacy format if it's not. func ReconcileInternalAnnotations(result []*yaml.RNode, nodeAnnosMap map[string]map[string]string) error { … } // determineAnnotationsFormat determines if the resources are using one of the internal and legacy annotation format or both of them. func determineAnnotationsFormat(nodeAnnosMap map[string]map[string]string) (bool, bool, error) { … } func missingInternalOrLegacyAnnotations(rn *yaml.RNode) error { … } func missingInternalOrLegacyAnnotation(rn *yaml.RNode, newKey string, legacyKey string) error { … } func checkAnnotationsAltered(rn *yaml.RNode, nodeAnnosMap map[string]map[string]string) error { … } func formatInternalAnnotations(rn *yaml.RNode, useInternal, useLegacy bool) error { … }
Codebase Browser
kubernetes