Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

applier

package

Go to main page

Versions in this module

v0

v0.53.0

Oct 20, 2026

Changes in this version

+ const ArgoCDInitiator

+ const DefaultAttemptTimeout

+ const DefaultOperationWait

+ const DefaultPollInterval

+ const DefaultStatusRetryInterval

+ const DefaultUnresolvedAfter

+ const DefaultUnresolvedPollMax

+ const EventReasonApplyFailed

+ const EventReasonApplyRequestFailed

+ const EventReasonApplyRequested

+ const EventReasonApplyUnresolved

+ const ReasonApplierNotFound

+ const ReasonAutomatedSyncEnabled

+ const ReasonCheckFailed

+ const ReasonForbidden

+ const ReasonHeldByAnotherTrigger

+ const ReasonNotBound

+ const ReasonNotReferenced

+ const ReasonSourceMismatch

+ const ReasonSucceeded

+ const ReasonSuspendOwnedElsewhere

+ const ReasonUnsupportedSource

+ const SuspendFieldManager

+ const TriggerConditionHeld

+ func BindingMismatch(trigger v1alpha3.ApplyTrigger, want Binding) string

+ func DescribeCommit(commit string) string

+ func HeldByAnother(ctx context.Context, reader client.Reader, trigger v1alpha3.ApplyTrigger) (v1alpha3.ApplyTrigger, error)

+ func HeldByAnotherMessage(trigger, holder v1alpha3.ApplyTrigger) string

+ func Holding(trigger v1alpha3.ApplyTrigger) bool

+ func ListApplyTriggers(ctx context.Context, reader client.Reader, kind string, ...) ([]v1alpha3.ApplyTrigger, error)

+ func Names(target *v1alpha3.GitTarget, trigger v1alpha3.ApplyTrigger) bool

+ func NamingTargets(ctx context.Context, reader client.Reader, trigger v1alpha3.ApplyTrigger) ([]*v1alpha3.GitTarget, error)

+ func TriggersOfApplier(ctx context.Context, reader client.Reader, trigger v1alpha3.ApplyTrigger) ([]v1alpha3.ApplyTrigger, error)

+ type AccessCheck func(ctx context.Context, attrs authorizationv1.ResourceAttributes) (bool, error)

+ func SelfSubjectAccessCheck(client dynamic.Interface) AccessCheck

+ type ArgoCD struct

+ CanI AccessCheck

+ Now func() time.Time

+ OperationWait time.Duration

+ PollInterval time.Duration

+ func NewArgoCD(client dynamic.Interface) *ArgoCD

+ func (a *ArgoCD) Progress(ctx context.Context, ref types.NamespacedName, s *Started) (Progress, error)

+ func (a *ArgoCD) Request(ctx context.Context, ref types.NamespacedName, ask Ask) (Started, error)

+ func (a *ArgoCD) Validate(ctx context.Context, ref types.NamespacedName) Verdict

+ type Ask struct

+ Commit string

+ Current func() bool

+ Held func(ctx context.Context) error

+ Reason v1alpha3.ApplyReason

+ Record func(ctx context.Context) error

+ Token string

+ Want Binding

+ type Binding struct

+ Branch string

+ RepositoryURL string

+ type Client interface

+ Progress func(ctx context.Context, ref types.NamespacedName, s *Started) (Progress, error)

+ Request func(ctx context.Context, ref types.NamespacedName, ask Ask) (Started, error)

+ Validate func(ctx context.Context, ref types.NamespacedName) Verdict

+ func NewClient(kind string, client dynamic.Interface) Client

+ type Clients func(ctx context.Context, clusterID string) (dynamic.Interface, error)

+ type Dispatcher struct

+ APIReader client.Reader

+ AttemptTimeout time.Duration

+ Now func() time.Time

+ OperationWait time.Duration

+ PollInterval time.Duration

+ UnresolvedAfter time.Duration

+ UnresolvedPollMax time.Duration

+ func NewDispatcher(reader client.Reader, applierClients Clients, recorder record.EventRecorder, ...) *Dispatcher

+ func (d *Dispatcher) Following(trigger git.TriggerRef, token string) bool

+ func (d *Dispatcher) NeedLeaderElection() bool

+ func (d *Dispatcher) PrefetchSource(req git.PrefetchRequest)

+ func (d *Dispatcher) RequestApply(req git.ApplyRequest)

+ func (d *Dispatcher) Start(ctx context.Context) error

+ type Flux struct

+ CanI AccessCheck

+ Now func() time.Time

+ PollInterval time.Duration

+ func NewFlux(client dynamic.Interface) *Flux

+ func (f *Flux) Consumers(ctx context.Context, source types.NamespacedName) ([]fluxmeta.NamespacedObjectKindReference, error)

+ func (f *Flux) Prefetch(ctx context.Context, ref, checked types.NamespacedName, commit string) error

+ func (f *Flux) Progress(ctx context.Context, ref types.NamespacedName, s *Started) (Progress, error)

+ func (f *Flux) Release(ctx context.Context, ref types.NamespacedName) (string, error)

+ func (f *Flux) Request(ctx context.Context, ref types.NamespacedName, ask Ask) (Started, error)

+ func (f *Flux) Suspend(ctx context.Context, ref types.NamespacedName) (string, error)

+ func (f *Flux) Suspension(ctx context.Context, ref types.NamespacedName) (Suspension, error)

+ func (f *Flux) Validate(ctx context.Context, ref types.NamespacedName) Verdict

+ type Outcome string

+ const OutcomeCurrent

+ const OutcomeResumed

+ const OutcomeSyncRequested

+ type Progress struct

+ AppliedRevision string

+ Message string

+ Outcome git.ApplyOutcome

+ SuspendToken string

+ type Reference struct

+ Message string

+ Reason string

+ State ReferenceState

+ Target types.NamespacedName

+ type ReferenceState int

+ const ReferenceEligible

+ const ReferenceRefused

+ const ReferenceUndecided

+ type References []Reference

+ func JudgeReferences(ctx context.Context, reader client.Reader, trigger v1alpha3.ApplyTrigger, ...) (References, error)

+ func (refs References) Eligible() bool

+ func (refs References) Message() string

+ func (refs References) Named() bool

+ func (refs References) Reason() string

+ func (refs References) Refused() bool

+ type Source struct

+ GitRepository types.NamespacedName

+ Revision string

+ URL string

+ type Started struct

+ Commit string

+ Outcome Outcome

+ Overdue bool

+ Recovered bool

+ RequestedAt time.Time

+ SuspendToken string

+ Token string

+ Unconfirmed error

+ type StatusWriter struct

+ RetryInterval time.Duration

+ func NewStatusWriter(reader client.Reader, writer client.StatusClient, log logr.Logger) *StatusWriter

+ func (w *StatusWriter) NeedLeaderElection() bool

+ func (w *StatusWriter) PublishApplyTriggerStatus(trigger git.TriggerRef, status git.ApplyTriggerStatus)

+ func (w *StatusWriter) RecordApplyOperation(ctx context.Context, ref git.TriggerRef, operation *v1alpha3.ApplyOperation) error

+ func (w *StatusWriter) Start(ctx context.Context) error

+ type Suspension struct

+ Applied Progress

+ Handled bool

+ Held bool

+ Suspended bool

+ type Verdict struct

+ Err error

+ Message string

+ OK bool

+ Reason string

+ Source *Source