loader

Documentation

Index

• Constants
• func GetCommitFileReader(path string, commit *object.Commit) pkgio.Reader[*yaml.RNode]
• func GetFSReader(path string) pkgio.Reader[[]byte]
• func GetFSReconcilerReader(path string) pkgio.Reader[[]byte]
• func GetFSStarReader(path string) pkgio.Reader[[]byte]
• func GetFSYAMLReader(path string, matchgvks []schema.GroupVersionKind) pkgio.Reader[*yaml.RNode]
• func GetRunningConfigReader(path string) pkgio.Reader[[]byte]
• type DataLoader
  • func (r *DataLoader) Load(ctx context.Context) error
• type DataLoaderUpstream
  • func (r *DataLoaderUpstream) Load(ctx context.Context, commit *object.Commit) error
• type DevLoader
  • func (r *DevLoader) LoadLibraries(ctx context.Context) error
  • func (r *DevLoader) LoadReconcilers(ctx context.Context) error
• type InputLoader
  • func (r *InputLoader) Clean(ctx context.Context) error
  • func (r *InputLoader) Load(ctx context.Context, reader pkgio.Reader[*yaml.RNode]) error
• type RunningConfigLoader
  • func (r *RunningConfigLoader) Load(ctx context.Context) error
• type SchemaLoader
  • func (r *SchemaLoader) Load(ctx context.Context) error
• type UpstreamCallBackFn
• type UpstreamLoader
  • func (r *UpstreamLoader) Load(ctx context.Context) error

Constants

const (
	ManagedFieldManagerInput = "inputfileloader"
)

Functions

func GetCommitFileReader

func GetCommitFileReader(path string, commit *object.Commit) pkgio.Reader[*yaml.RNode]

func GetFSReader

func GetFSReader(path string) pkgio.Reader[[]byte]

func GetFSReconcilerReader

func GetFSReconcilerReader(path string) pkgio.Reader[[]byte]

func GetFSStarReader

func GetFSStarReader(path string) pkgio.Reader[[]byte]

func GetFSYAMLReader

func GetFSYAMLReader(path string, matchgvks []schema.GroupVersionKind) pkgio.Reader[*yaml.RNode]

func GetRunningConfigReader

func GetRunningConfigReader(path string) pkgio.Reader[[]byte]

Types

type DataLoader

type DataLoader struct {
	Cfg        *genericclioptions.ChoreoConfig
	Client     resourceclient.Client
	Branch     string
	GVKs       []schema.GroupVersionKind
	RepoPth    string
	PathInRepo string
	// used to clean reasources
	//APIStore       *api.APIStore
	InternalAPISet sets.Set[schema.GroupVersionKind]
	Annotation     string
}

func (*DataLoader) Load

func (r *DataLoader) Load(ctx context.Context) error

type DataLoaderUpstream

type DataLoaderUpstream struct {
	Cfg        *genericclioptions.ChoreoConfig
	PathInRepo string
	//UpstreamClient          resourceclient.Client // used to read data from commit from upstream repo
	Client                  resourceclient.Client
	Branch                  string
	ChildGVKSet             sets.Set[schema.GroupVersionKind]
	UpstreamAnnotationValue string
	NewUpstreamData         sets.Set[corev1.ObjectReference]
}

func (*DataLoaderUpstream) Load

func (r *DataLoaderUpstream) Load(ctx context.Context, commit *object.Commit) error

type DevLoader

type DevLoader struct {
	Cfg         *genericclioptions.ChoreoConfig
	RepoPath    string
	PathInRepo  string
	Libraries   []*choreov1alpha1.Library
	Reconcilers []*choreov1alpha1.Reconciler
}

func (*DevLoader) LoadLibraries

func (r *DevLoader) LoadLibraries(ctx context.Context) error

func (*DevLoader) LoadReconcilers

func (r *DevLoader) LoadReconcilers(ctx context.Context) error

type InputLoader

type InputLoader struct {
	Client   resourceclient.Client
	Branch   string
	NewInput sets.Set[corev1.ObjectReference]
	//APIStore       *api.APIStore
	GVKs           []schema.GroupVersionKind
	InternalAPISet sets.Set[schema.GroupVersionKind]
	Annotation     string
}

func (*InputLoader) Clean

func (r *InputLoader) Clean(ctx context.Context) error

func (*InputLoader) Load

func (r *InputLoader) Load(ctx context.Context, reader pkgio.Reader[*yaml.RNode]) error

type RunningConfigLoader

type RunningConfigLoader struct {
	Cfg *genericclioptions.ChoreoConfig
	//Client     resourceclient.Client
	//Branch     string
	RepoPath       string
	PathInRepo     string
	RunningConfigs map[string]any
}

UpstreamLoader

func (*RunningConfigLoader) Load

func (r *RunningConfigLoader) Load(ctx context.Context) error

type SchemaLoader

type SchemaLoader struct {
	Parent instance.ChoreoInstance
	Cfg    *genericclioptions.ChoreoConfig
	//Client     resourceclient.Client
	//Branch     string
	RepoPath   string
	PathInRepo string
	TempDir    string
}

UpstreamLoader

func (*SchemaLoader) Load

func (r *SchemaLoader) Load(ctx context.Context) error

type UpstreamCallBackFn

type UpstreamCallBackFn func(ctx context.Context, parentName string, repo repository.Repository, upstreamRef *choreov1alpha1.UpstreamRef, cfg *genericclioptions.ChoreoConfig, commit *object.Commit, annotationVal string) error

type UpstreamLoader

type UpstreamLoader struct {
	Parent     instance.ChoreoInstance
	Cfg        *genericclioptions.ChoreoConfig
	Client     resourceclient.Client
	Branch     string
	RepoPath   string
	PathInRepo string
	TempDir    string
	ProgressFn func(string)
}

UpstreamLoader

func (*UpstreamLoader) Load

func (r *UpstreamLoader) Load(ctx context.Context) error