Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

application

package

Go to main page

Versions in this module

v1

v1.24.6

Jul 16, 2024

v1.24.5

Apr 28, 2024

v1.24.4

Mar 11, 2024

v1.24.3

Feb 2, 2024

v1.24.2

Dec 18, 2023

v1.24.1

Oct 7, 2023

v1.24.0

Jul 24, 2023

Changes in this version

+ const AnalysisArgNamespace

+ const AnalysisArgServiceName

+ const AnnotationCluster

+ const AnnotationGeneratedByPlatformKey

+ const AnnotationGeneratedByPlatformValueRollouts

+ const AnnotationKeyCreator

+ const AnnotationNamespace

+ const AnnotationRef

+ const BaseEnv

+ const LabelApplication

+ const LabelEnvironment

+ const LabelIstioVersion

+ const LabelKeyFrom

+ const LabelProject

+ const LabelTenant

+ const LabelValueFromApp

+ const LabelValueFromAppStore

+ const MetaFilename

+ const ReadmeFilename

+ const StatusNoArgoApp

+ const TaskAddtionalKeyCommiter

+ const TaskFunction_Application_BatchUpdateImages

+ const TaskFunction_Application_PrepareDeploymentStrategy

+ const TaskFunction_Application_Sync

+ const TaskFunction_Application_Undo

+ const TaskFunction_Application_UpdateImages

+ const TaskFunction_Application_WaitRollouts

+ const TaskGroupApplication

+ var ErrNotManagedRegistry = errors.New("unsupported image")

+ var ForFileContentFunc = git.ForFileContentFunc

+ var KustimizationFilename = konfig.DefaultKustomizationFileName()

+ var ResourceWhileList = []schema.GroupVersionKind

+ func AuthorFromContext(ctx context.Context) *object.Signature

+ func CleanRollout(ctx context.Context, cli GitStore) error

+ func ClusterNamespaceFromCtx(ctx context.Context) (string, string)

+ func DecodeArgoClusterName(full string) string

+ func DecodeManifest(ctx context.Context, fs billy.Filesystem, manifest *Manifest, ...) error

+ func DecodeResource(content []byte) (client.Object, error)

+ func ForManifestFsFunc(fs billy.Filesystem, fun func(string, billy.Filesystem))

+ func GenArgoClusterName(cluster string) string

+ func GenArgoPrjNameFromRef(ref PathRef) string

+ func GetCurrentCanaryStep(rollout *rolloutsv1alpha1.Rollout) (*rolloutsv1alpha1.CanaryStep, *int32)

+ func InitOrUpdateKustomization(fs billy.Filesystem) error

+ func IsPermmitedResource(obj runtime.Object) bool

+ func ObjectPodTemplateFunc(obj client.Object, fun func(template *corev1.PodTemplateSpec))

+ func ParseImagesFrom(obj client.Object) []string

+ func ParseMainDeployment(ctx context.Context, store GitStore) (*appsv1.Deployment, error)

+ func ParseMainStatefulSet(ctx context.Context, store GitStore) (*appsv1.StatefulSet, error)

+ func ParseMainWorkload(ctx context.Context, store GitStore) (client.Object, error)

+ func PromoteRollout(ctx context.Context, cli client.Client, namespace, name string, full bool) (*rolloutsv1alpha1.Rollout, error)

+ func StringsContain(list []string, i string) bool

+ func StringsIn(li []string, i string) bool

+ func TaskNameOf(ref PathRef, taskname string) string

+ func UpdateContentImages(ctx context.Context, store GitStore, images []string, version string) error

+ func UpdateImage(template *corev1.PodTemplateSpec, images []string)

+ func UpdatedReourcesLimits(obj client.Object, suggestion ResourceSuggestion) bool

+ type AppReplicas struct

+ Replicas *int32

+ type AppStoreDeployForm struct

+ Annotations map[string]string

+ Chart string

+ ChartVersion string

+ Labels map[string]string

+ Name string

+ RepoURL string

+ Values json.RawMessage

+ type ApplicationHandler struct

+ Agents *agents.ClientSet

+ ApplicationProcessor *ApplicationProcessor

+ ArgoCD *argo.Client

+ Manifest ManifestHandler

+ Task *TaskHandler

+ func MustNewApplicationDeployHandler(provider git.Provider, argocli *argo.Client, commonbase base.BaseHandler) *ApplicationHandler

+ func (h *ApplicationHandler) Argohistory(c *gin.Context)

+ func (h *ApplicationHandler) BatchUpdateImages(c *gin.Context)

+ func (h *ApplicationHandler) Create(c *gin.Context)

+ func (h *ApplicationHandler) CreateAppstoreApp(c *gin.Context)

+ func (h *ApplicationHandler) CreateBatch(c *gin.Context)

+ func (h *ApplicationHandler) DeleteArgoResource(c *gin.Context)

+ func (h *ApplicationHandler) DeleteHPA(c *gin.Context)

+ func (h *ApplicationHandler) DirectUpdateImage(c *gin.Context)

+ func (h *ApplicationHandler) EnableStrategyDeployment(c *gin.Context)

+ func (h *ApplicationHandler) Get(c *gin.Context)

+ func (h *ApplicationHandler) GetAppstoreApp(c *gin.Context)

+ func (h *ApplicationHandler) GetArgoResource(c *gin.Context)

+ func (h *ApplicationHandler) GetHPA(c *gin.Context)

+ func (h *ApplicationHandler) GetImages(c *gin.Context)

+ func (h *ApplicationHandler) GetReplicas(c *gin.Context)

+ func (h *ApplicationHandler) GetStrategyDeployment(c *gin.Context)

+ func (h *ApplicationHandler) GitDiff(c *gin.Context)

+ func (h *ApplicationHandler) GitLog(c *gin.Context)

+ func (h *ApplicationHandler) GitPull(c *gin.Context)

+ func (h *ApplicationHandler) GitRevert(c *gin.Context)

+ func (h *ApplicationHandler) ImageHistory(c *gin.Context)

+ func (h *ApplicationHandler) List(c *gin.Context)

+ func (h *ApplicationHandler) ListAnalysisTemplate(c *gin.Context)

+ func (h *ApplicationHandler) ListAppstoreApp(c *gin.Context)

+ func (h *ApplicationHandler) ListFiles(c *gin.Context)

+ func (h *ApplicationHandler) ListImages(c *gin.Context)

+ func (h *ApplicationHandler) ListRelatedService(c *gin.Context)

+ func (h *ApplicationHandler) LocalAndRemoteCliFunc(c *gin.Context, body interface{}, fun LocalAndRemoteStoreFunc, msg string)

+ func (h *ApplicationHandler) LocalCliFunc(c *gin.Context, body interface{}, fun LocalStoreFunc, msg string)

+ func (h *ApplicationHandler) PutFile(c *gin.Context)

+ func (h *ApplicationHandler) PutFiles(c *gin.Context)

+ func (h *ApplicationHandler) RegistRouter(rg *gin.RouterGroup) error

+ func (h *ApplicationHandler) RemoteCliFunc(c *gin.Context, body interface{}, fun RemoteStoreFunc)

+ func (h *ApplicationHandler) Remove(c *gin.Context)

+ func (h *ApplicationHandler) RemoveAppstoreApp(c *gin.Context)

+ func (h *ApplicationHandler) RemoveFile(c *gin.Context)

+ func (h *ApplicationHandler) ResourceTree(c *gin.Context)

+ func (h *ApplicationHandler) SetHPA(c *gin.Context)

+ func (h *ApplicationHandler) SetReplicas(c *gin.Context)

+ func (h *ApplicationHandler) StrategyDeploymentControl(c *gin.Context)

+ func (h *ApplicationHandler) StrategyDeploymentStatus(c *gin.Context)

+ func (h *ApplicationHandler) SwitchStrategy(c *gin.Context)

+ func (h *ApplicationHandler) Sync(c *gin.Context)

+ func (h *ApplicationHandler) UpdateImages(c *gin.Context)

+ func (h *ApplicationHandler) UpdateWorkloadResources(c *gin.Context)

+ type ApplicationProcessor struct

+ Agents *agents.ClientSet

+ Argo *argo.Client

+ DataBase *DatabseProcessor

+ Manifest *ManifestProcessor

+ Task *TaskProcessor

+ func NewApplicationProcessor(db *database.Database, gitp git.Provider, argo *argo.Client, ...) *ApplicationProcessor

+ func (h *ApplicationProcessor) Create(ctx context.Context, ref PathRef) error

+ func (h *ApplicationProcessor) CreateBatch(ctx context.Context, baseref PathRef, names []string) error

+ func (h *ApplicationProcessor) Get(ctx context.Context, ref PathRef) (*DeploiedManifest, error)

+ func (h *ApplicationProcessor) List(ctx context.Context, ref PathRef) ([]DeploiedManifest, error)

+ func (h *ApplicationProcessor) Remove(ctx context.Context, ref PathRef) error

+ func (h *ApplicationProcessor) Sync(ctx context.Context, ref PathRef, resources ...v1alpha1.SyncOperationResource) error

+ func (h *ApplicationProcessor) Undo(ctx context.Context, ref PathRef, targetrev string) error

+ func (p *ApplicationProcessor) BatchUpdateImages(ctx context.Context, ref PathRef, args []UpdateImageArgs) error

+ func (p *ApplicationProcessor) CreateIfNotExist(ctx context.Context, cli GitStore, obj client.Object) error

+ func (p *ApplicationProcessor) DeleteHorizontalPodAutoscaler(ctx context.Context, ref PathRef) error

+ func (p *ApplicationProcessor) GetHorizontalPodAutoscaler(ctx context.Context, ref PathRef) (*v2beta1.HorizontalPodAutoscaler, error)

+ func (p *ApplicationProcessor) GetReplicas(ctx context.Context, ref PathRef) (*int32, error)

+ func (p *ApplicationProcessor) PrepareDeploymentStrategy(ctx context.Context, ref PathRef, strategy DeploymentStrategy) error

+ func (p *ApplicationProcessor) PrepareDeploymentStrategyWithImages(ctx context.Context, ref PathRef, strategy DeploymentStrategyWithImages) error

+ func (p *ApplicationProcessor) ProvideFuntions() map[string]interface{}

+ func (p *ApplicationProcessor) SetHorizontalPodAutoscaler(ctx context.Context, ref PathRef, scalerMetrics HPAMetrics) error

+ func (p *ApplicationProcessor) SetReplicas(ctx context.Context, ref PathRef, replicas *int32) error

+ func (p *ApplicationProcessor) UpdateImages(ctx context.Context, ref PathRef, images []string, version string) error

+ func (p *ApplicationProcessor) WaitRollouts(ctx context.Context, ref PathRef) error

+ type ApplicationTask struct

+ Name string

+ Task workflow.Task

+ type ArgoHistory struct

+ Environment string

+ GitVersion string

+ ID string

+ Images []string

+ Name string

+ PublishAt metav1.Time

+ Publisher string

+ Status string

+ Tenant string

+ type ArgoResourceDiff struct

+ Diff interface{}

+ Group string

+ Hook bool

+ Kind string

+ LiveState interface{}

+ Name string

+ Namespace string

+ NormalizedLiveState interface{}

+ PredictedLiveState interface{}

+ TargetState interface{}

+ type ArgoResourceNode struct

+ Sync string

+ type ArgoResourceTree struct

+ Children []*ArgoResourceTree

+ LiveState interface{}

+ type BaseHandler struct

+ func (h *BaseHandler) BindNameRefFunc(c *gin.Context, ref *PathRef) error

+ func (h *BaseHandler) BindTenantProjectedRefFunc(c *gin.Context, ref *PathRef) error

+ func (h *BaseHandler) DirectNamedRefFunc(c *gin.Context, body interface{}, ...)

+ func (h *BaseHandler) DirectRefNameFunc(c *gin.Context, ref *PathRef) error

+ func (h *BaseHandler) MayBindEnvRefFunc(c *gin.Context, ref *PathRef) error

+ func (h *BaseHandler) NamedRefFunc(c *gin.Context, body interface{}, ...)

+ func (h *BaseHandler) NoNameRefFunc(c *gin.Context, body interface{}, ...)

+ type BlueGreenDeploymentStrategy struct

+ type Cache struct

+ func (c *Cache) Get(key string) (interface{}, error)

+ func (c *Cache) Set(key string, value interface{})

+ type CanaryDeploymentStrategy struct

+ type ClusterNamespace struct

+ Cluster string

+ Namespace string

+ type CommitImageDetails struct

+ CreatedAt metav1.Time

+ Creator string

+ Images []string

+ type Container struct

+ Name string

+ Resources corev1.ResourceRequirements

+ type DatabseProcessor struct

+ DB *gorm.DB

+ func (p *DatabseProcessor) GetEnvironmentWithCluster(ref PathRef) (*EnvironmentDetails, error)

+ func (p *DatabseProcessor) RemoveDeploy(ctx context.Context, ref PathRef, deploy DeploiedManifest) error

+ func (p *DatabseProcessor) SyncDeploies(ctx context.Context, ref PathRef, deploies []DeploiedManifest) error

+ func (p *DatabseProcessor) SyncDeploy(ctx context.Context, ref PathRef, deploy DeploiedManifest) error

+ type DeploiedHelm struct

+ Runtime ManifestRuntime

+ type DeploiedManifest struct

+ Runtime ManifestRuntime

+ func CompleteDeploiedManifestRuntime(app *v1alpha1.Application, status *DeploiedManifest) *DeploiedManifest

+ type DeployImage struct

+ Publish string

+ Running string

+ type DeployImages struct

+ Images map[string]*DeployImage

+ IstioVersion string

+ Kind string

+ Name string

+ PublishAt *metav1.Time

+ Published bool

+ func ConvertDeploiedManifestToView(dm DeploiedManifest) DeployImages

+ func (d *DeployImages) PublishImages() []string

+ type DeploymentStrategy struct

+ BlueGreen *BlueGreenDeploymentStrategy

+ Canary *CanaryDeploymentStrategy

+ Recreat *RecreatDeploymentStrategy

+ Rolling *appsv1.RollingUpdateDeployment

+ Type DeploymentStrategyType

+ type DeploymentStrategyType string

+ const BlueGreenDeploymentStrategyType

+ const CanaryDeploymentStrategyType

+ const RecreatDeploymentStrategyType

+ const RollingUpdateDeploymentStrategyType

+ type DeploymentStrategyWithDeployment struct

+ Deployment *appsv1.Deployment

+ Strategy DeploymentStrategy

+ func ParseUpdateStrategyAndDeployment(ctx context.Context, store GitStore) (*DeploymentStrategyWithDeployment, error)

+ type DeploymentStrategyWithImages struct

+ Strategy DeploymentStrategy

+ type EnvironmentDetails struct

+ ClusterKubeConfig []byte

+ ClusterName string

+ EnvironmentName string

+ EnvironmentType string

+ Namespace string

+ type ExtendCanaryStrategy struct

+ TrafficRouting *RolloutTrafficRouting

+ func ExtendCanaryStrategyFromCanaryStrategy(from *rolloutsv1alpha1.CanaryStrategy) *ExtendCanaryStrategy

+ func (s *ExtendCanaryStrategy) ToCanaryStrategy() *rolloutsv1alpha1.CanaryStrategy

+ type FileContent struct

+ Content string

+ Name string

+ type FsStore struct

+ func NewGitFsStore(fs billy.Filesystem) *FsStore

+ func (c *FsStore) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

+ func (c *FsStore) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

+ func (c *FsStore) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

+ func (c *FsStore) Get(ctx context.Context, key client.ObjectKey, into client.Object) error

+ func (c *FsStore) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

+ func (c *FsStore) ListAll(ctx context.Context) ([]client.Object, error)

+ func (c *FsStore) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error

+ func (c *FsStore) RESTMapper() meta.RESTMapper

+ func (c *FsStore) Scheme() *runtime.Scheme

+ func (c *FsStore) Status() client.StatusWriter

+ func (c *FsStore) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

+ type GVKN struct

+ Group string

+ Kind string

+ Name string

+ Version string

+ func (g GVKN) GVK() schema.GroupVersionKind

+ type GitLog struct

+ Author string

+ Hash string

+ Message string

+ Timestamp string

+ type GitStore = *FsStore

+ type HPAMetrics struct

+ Cpu int32

+ MaxReplicas int32

+ Memory int32

+ MinReplicas *int32

+ type HarborFunc func(ctx context.Context, cli *harbor.Client, image string) (interface{}, error)

+ type HelmManifest struct

+ Chart string

+ ChartVersion string

+ CreateAt metav1.Time

+ Creator string

+ Description string

+ Kind string

+ Name string

+ RepoURL string

+ Values string

+ type ImageDetails struct

+ Publish string

+ Running string

+ type ImageHandler struct

+ func (h *ImageHandler) ImageTags(c *gin.Context)

+ func (h *ImageHandler) OnHarborFunc(c *gin.Context, harborfun HarborFunc, ocifunc OCIFunc)

+ func (h *ImageHandler) Scan(c *gin.Context)

+ func (h *ImageHandler) Summary(c *gin.Context)

+ func (h *ImageHandler) Unpublishable(c *gin.Context)

+ func (h *ImageHandler) Vulnerabilities(c *gin.Context)

+ type ImageHistory struct

+ Environment string

+ ID string

+ Image string

+ PublishAt metav1.Time

+ Publisher string

+ Type string

+ type ImageSummaryItem struct

+ Image string

+ IsHarborRegistry bool

+ Labels []harbor.Label

+ Report interface{}

+ ScanStatus string

+ Severity vuln.Severity

+ Status string

+ Unpublishable bool

+ UpdatedAt *metav1.Time

+ type ImageTag struct

+ Image string

+ TagName string

+ Unpublishable bool

+ type IngressPorts struct

+ Host string

+ IngressClassName *string

+ IngressPort int

+ ServicePort string

+ type IstioTrafficRouting struct

+ VirtualService IstioVirtualService

+ type IstioVirtualService struct

+ Headers map[string]*istionetworkingv1alpha3.StringMatch

+ IgnoreUriCase bool

+ Uri *istionetworkingv1alpha3.StringMatch

+ type LocalAndRemoteStoreFunc func(ctx context.Context, local GitStore, remote agents.Client, namespace string, ...) (interface{}, error)

+ type LocalStoreFunc func(ctx context.Context, store GitStore, ref PathRef) (interface{}, error)

+ type Manifest struct

+ Annotations map[string]string

+ CreateAt metav1.Time

+ Creator string

+ Description string

+ Images []string

+ IstioVersion string

+ Kind string

+ Labels map[string]string

+ Name string

+ Ref PathRef

+ type ManifestDeploy struct

+ Cluster string

+ Contents []unstructured.Unstructured

+ Name string

+ Namespace string

+ type ManifestHandler struct

+ func (h *ManifestHandler) CreateManifest(c *gin.Context)

+ func (h *ManifestHandler) CreateResource(c *gin.Context)

+ func (h *ManifestHandler) DeleteResource(c *gin.Context)

+ func (h *ManifestHandler) GetManifest(c *gin.Context)

+ func (h *ManifestHandler) GetResource(c *gin.Context)

+ func (h *ManifestHandler) GitDiff(c *gin.Context)

+ func (h *ManifestHandler) GitLog(c *gin.Context)

+ func (h *ManifestHandler) GitPull(c *gin.Context)

+ func (h *ManifestHandler) GitRevert(c *gin.Context)

+ func (h *ManifestHandler) ListFiles(c *gin.Context)

+ func (h *ManifestHandler) ListManifest(c *gin.Context)

+ func (h *ManifestHandler) ListManifestAdmin(c *gin.Context)

+ func (h *ManifestHandler) ListResource(c *gin.Context)

+ func (h *ManifestHandler) Metas(c *gin.Context)

+ func (h *ManifestHandler) PutFile(c *gin.Context)

+ func (h *ManifestHandler) PutFiles(c *gin.Context)

+ func (h *ManifestHandler) RemoveFile(c *gin.Context)

+ func (h *ManifestHandler) RemoveManifest(c *gin.Context)

+ func (h *ManifestHandler) UpdateManifest(c *gin.Context)

+ func (h *ManifestHandler) UpdateResource(c *gin.Context)

+ type ManifestListOption func(*ManifestListOptions)

+ func WithImages() ManifestListOption

+ type ManifestListOptions struct

+ WithImages bool

+ type ManifestProcessor struct

+ GitProvider git.Provider

+ func NewManifestProcessor(GitProvider *git.SimpleLocalProvider) (*ManifestProcessor, error)

+ func (h *ManifestProcessor) Create(ctx context.Context, ref PathRef, manifest Manifest) error

+ func (h *ManifestProcessor) Func(ctx context.Context, ref PathRef, funcs ...RepositoryFunc) error

+ func (h *ManifestProcessor) Get(ctx context.Context, ref PathRef) (*Manifest, error)

+ func (h *ManifestProcessor) List(ctx context.Context, ref PathRef, options ...ManifestListOption) ([]Manifest, error)

+ func (h *ManifestProcessor) Remove(ctx context.Context, ref PathRef) error

+ func (h *ManifestProcessor) StoreFunc(ctx context.Context, ref PathRef, ...) error

+ func (h *ManifestProcessor) StoreUpdateFunc(ctx context.Context, ref PathRef, ...) error

+ func (h *ManifestProcessor) Update(ctx context.Context, ref PathRef, manifest Manifest) error

+ func (h *ManifestProcessor) UpdateContentFunc(ctx context.Context, ref PathRef, fun RepositoryFileSystemFunc, ...) error

+ func (p *ManifestProcessor) ContentFunc(ctx context.Context, ref PathRef, fun RepositoryFileSystemFunc) error

+ type ManifestRuntime struct

+ Annotations map[string]string

+ CreateAt metav1.Time

+ Creator string

+ DeployStatus string

+ Images []string

+ IstioVersion string

+ Kind string

+ Labels map[string]string

+ Message string

+ Raw interface{}

+ Status string

+ WorkloadName string

+ type OCIFunc func(ctx context.Context, cli *harbor.OCIDistributionClient, image string) (interface{}, error)

+ type PathRef struct

+ Env string

+ Name string

+ Project string

+ Tenant string

+ func (p *PathRef) DecodeFrom(str string) error

+ func (p *PathRef) FromAnnotations(annotations map[string]string)

+ func (p *PathRef) FromArgoLabel(labels map[string]string)

+ func (p *PathRef) FromJsonBase64(str string)

+ func (p PathRef) Encode() string

+ func (p PathRef) FullName() string

+ func (p PathRef) GitBranch() string

+ func (p PathRef) GitRef() git.RepositoryRef

+ func (p PathRef) IsEmpty() bool

+ func (p PathRef) JsonStringBase64() string

+ func (p PathRef) Path() string

+ type PodSpec struct

+ Containers []Container

+ EphemeralContainers []Container

+ InitContainers []Container

+ type PodTemplateSpec struct

+ Spec PodSpec

+ type RecreatDeploymentStrategy struct

+ WaitShutdown bool

+ type RefCompleteFunc func(*gin.Context, *PathRef) error

+ type RegistryOptions struct

+ Password string

+ URL string

+ Username string

+ type RelatedService struct

+ IngressPorts []IngressPorts

+ Ports []corev1.ServicePort

+ ServiceIP string

+ type RemoteStoreFunc func(ctx context.Context, remote agents.Client, namespace string, ref PathRef) (interface{}, error)

+ type Repository struct

+ func (r *Repository) Diff(ctx context.Context, hash string) ([]git.FileDiff, error)

+ func (r *Repository) FS(ctx context.Context) (billy.Filesystem, error)

+ func (r *Repository) HistoryFiles(ctx context.Context, hash string) (*git.Commit, error)

+ func (r *Repository) HistoryFunc(ctx context.Context, fun git.ContentVistitFunc) error

+ type RepositoryFileSystemFunc func(ctx context.Context, fs billy.Filesystem) error

+ func FSStoreFunc(funcs ...func(ctx context.Context, store GitStore) error) RepositoryFileSystemFunc

+ type RepositoryFunc func(ctx context.Context, repository Repository) error

+ func Commit(msg string) RepositoryFunc

+ func FsFunc(funcs ...RepositoryFileSystemFunc) RepositoryFunc

+ func Pull() RepositoryFunc

+ func Revert(rev string) RepositoryFunc

+ func UpdateKustomizeCommit(msg string) RepositoryFunc

+ type ResourceSuggestion struct

+ Spec ResourceSuggestionSpec

+ func (r *ResourceSuggestion) DeepCopyObject() runtime.Object

+ type ResourceSuggestionSpec struct

+ Template PodTemplateSpec

+ type RolloutTrafficRouting struct

+ Istio *IstioTrafficRouting

+ type StrategyDeploymentControl struct

+ Args map[string]interface{}

+ Command string

+ type SyncRequest struct

+ Resources []v1alpha1.SyncOperationResource

+ type TaskHandler struct

+ Processor *TaskProcessor

+ func NewTaskHandler(base BaseHandler) *TaskHandler

+ func (h *TaskHandler) BatchList(c *gin.Context)

+ func (h *TaskHandler) List(c *gin.Context)

+ type TaskProcessor struct

+ Workflowcli *workflow.Client

+ func (p *TaskProcessor) GetTaskLatest(ctx context.Context, ref PathRef, typ string) (*workflow.Task, error)

+ func (p *TaskProcessor) ListTasks(ctx context.Context, ref PathRef, typ string) ([]workflow.Task, error)

+ func (p *TaskProcessor) SubmitTask(ctx context.Context, ref PathRef, typ string, steps []workflow.Step) error

+ func (p *TaskProcessor) WatchTasks(ctx context.Context, ref PathRef, typ string, ...) error

+ type UpdateImageArgs struct

+ Images []string

+ IstioVersion string

+ Name string