git

package

Go to main page

Versions in this module

v0

v0.52.0

Oct 6, 2026

Changes in this version

type BranchWorker

+ func (w *BranchWorker) IntakePaused() <-chan struct{}

+ func (w *BranchWorker) Publication() PublicationStatus

type FinalizeResult

+ Held string

+ type PublicationStatus struct

+ Cause string

+ Failing bool

+ IntakePaused bool

+ ParentUnavailable bool

+ Since time.Time

+ func (p PublicationStatus) Message() string

type WorkerManager

+ func (m *WorkerManager) PublicationEvents() <-chan event.GenericEvent

v0.51.0

Oct 2, 2026

Changes in this version

+ const DefaultCommitWindowMaxDuration

+ var ErrBranchWorkerStopped = errors.New("the GitTarget's branch worker stopped before it finished the CommitRequest")

+ var ErrCommitRequestWithdrawn = errors.New("the CommitRequest was withdrawn before the worker acted on it")

+ var ErrDefaultBranchUnresolved = errors.New("the remote's default branch does not resolve to a branch")

+ var ErrParentBranchNotFound = errors.New("parent branch not found on the remote")

+ func SmartFetchFrom(ctx context.Context, repo *git.Repository, target plumbing.ReferenceName, ...) (plumbing.ReferenceName, error)

type AttachCommitRequest

+ Attach v1alpha3.AttachPolicy

+ AttachTimeout time.Duration

+ CommitEmpty bool

+ IdleTimeout *time.Duration

+ MaxDuration time.Duration

type BranchWorker

+ func (w *BranchWorker) BumpSnapshotRequestForTest(target itypes.ResourceReference)

+ func (w *BranchWorker) EnqueueWithdraw(req *AttachCommitRequest)

+ func (w *BranchWorker) LookupCommitRequestPhase(namespace, name, uid string) CommitRequestPhase

+ func (w *BranchWorker) ParentBranch() string

+ func (w *BranchWorker) ParentRecovery() (bool, bool)

+ func (w *BranchWorker) RecordMissingParentForTest(parent string)

+ func (w *BranchWorker) RecordUnresolvedDefaultBranchForTest(head string)

+ func (w *BranchWorker) SetParentBranch(name string) bool

+ func (w *BranchWorker) SnapshotRequestSeq(target itypes.ResourceReference) uint64

+ type CommitRequestPhase string

+ const PhaseCollectingWindow

+ const PhaseWaitingForPush

+ const PhaseWaitingForWindow

+ const PhaseWaitingForWorker

+ func (p CommitRequestPhase) Held() bool

+ type DefaultBranchUnresolvedError struct

+ Head string

+ func (e *DefaultBranchUnresolvedError) Error() string

+ func (e *DefaultBranchUnresolvedError) Is(target error) bool

type FinalizeResult

+ Phase CommitRequestPhase

+ type ParentState string

+ const ParentFound

+ const ParentMissing

+ const ParentUnborn

type PendingWrite

+ AllowEmpty bool

+ RequestAttribution AttributionOutcome

+ RequestAuthor UserInfo

type PendingWriteKind

+ const PendingWriteRequestRecord

type PullReport

+ ParentBranch string

+ func PrepareBranchFrom(ctx context.Context, repoURL, repoPath, targetBranchName, parentBranch string, ...) (*PullReport, error)

type RemoteObservation

+ ParentBranch string

+ ParentCommit string

+ ParentRequested string

+ ParentState ParentState

+ type RepositoryNotEmptyError struct

+ Refs int

+ func (e *RepositoryNotEmptyError) Error() string

type WorkItem

+ Withdraw *AttachCommitRequest

type WorkerManager

+ func (m *WorkerManager) CommitRequestOwner(namespace, name, uid string) (*BranchWorker, bool)

v0.50.0

Sep 30, 2026

Changes in this version

+ const WorkerSweepInterval

type AttachCommitRequest

+ CloseDelay time.Duration

type BranchWorker

+ func (w *BranchWorker) EnqueueRefresh(req *RefreshRequest)

+ func (w *BranchWorker) LastRemoteObservation() (RemoteObservation, bool)

+ func (w *BranchWorker) SeedRemoteObservationForTest(revision string, at time.Time, by string)

type Event

+ SourceCollection types.CollectionKey

type FinalizeResult

+ Commit string

type LayoutReport

+ Commit string

+ type ObservationSource string

+ const ObservedByFetch

+ const ObservedByPush

+ type PushOutcome struct

+ Head plumbing.Hash

+ Kind PushOutcomeKind

+ type PushOutcomeKind string

+ const PushAccepted

+ const PushNoBranch

+ const PushUpToDate

+ type RefreshRequest struct

+ MaxAge time.Duration

+ Path string

+ Target itypes.ResourceReference

+ type RemoteObservation struct

+ At time.Time

+ By ObservationSource

+ Commit string

+ Repo RepoIdentity

+ func (o RemoteObservation) Age(now time.Time) time.Duration

+ type RemoteReporter func(observed RemoteObservation)

type RenderFidelityGate

+ func (g *RenderFidelityGate) Invalidate(target types.ResourceReference)

+ type RepoIdentity struct

+ ProviderUID k8stypes.UID

+ URL string

+ func (r RepoIdentity) IsZero() bool

+ func (r RepoIdentity) String() string

type ResyncRequest

+ SourceCollection types.CollectionKey

type ResyncScope

+ Collection types.CollectionKey

+ func (s *ResyncScope) Overlaps(other *ResyncScope) bool

+ type ScanAcceptanceReporter func(target itypes.ResourceReference, ...)

type WorkItem

+ Refresh *RefreshRequest

type WorkerManager

+ func (m *WorkerManager) AcknowledgeReplacement(key BranchKey)

+ func (m *WorkerManager) RemoteForBranch(key BranchKey) (RemoteObservation, bool)

+ func (m *WorkerManager) ReplacementPending(key BranchKey) bool

+ func (m *WorkerManager) SetScanAcceptanceReporter(reporter ScanAcceptanceReporter)

v0.49.1

Sep 22, 2026

v0.49.0

Sep 22, 2026

Changes in this version

type BranchWorker

+ func (w *BranchWorker) BaseTrustEpoch() uint64

+ func (w *BranchWorker) BaseTrustedForTest() bool

+ func (w *BranchWorker) ExpireBaseTrust(maxAge time.Duration) bool

+ func (w *BranchWorker) SeedBaseTrustForTest(at time.Time)

type PendingWriteKind

+ const PendingWriteRefusalTouch

+ type RemoteMovedError struct

+ Advertised plumbing.Hash

+ Branch plumbing.ReferenceName

+ Expected plumbing.Hash

+ Missing bool

+ func (e *RemoteMovedError) Error() string

v0.48.1

Sep 19, 2026

v0.48.0

Sep 16, 2026

Changes in this version

type Event

+ Generation int64

+ ResourceVersion string

type PendingWrite

+ ResourceVersion string

type ReconcileCommitMessageData

+ ResourceVersion string

type ResourceRef

+ Generation int64

+ ResourceVersion string

type ResyncRequest

+ ResourceVersion string

v0.47.0

Sep 16, 2026

Changes in this version

+ const DefaultBranchWorkerQueueDepth

+ type BranchWorkerLimits struct

+ MaxBufferBytes int64

+ QueueDepth int

type CommitMessageConfig

+ RequestTemplate string

type LiveCommitMessageData

+ RequestMessage string

v0.46.0

Sep 14, 2026

Changes in this version

type LiveCommitMessageData

+ func (d LiveCommitMessageData) LabelValue(key string) string

+ func (d LiveCommitMessageData) LabelValues(key string) []string

type ResourceRef

+ Kind string

+ Labels map[string]string

+ func (r ResourceRef) Label(key string) string

v0.45.1

Sep 11, 2026

Changes in this version

+ func CredentialOptionsForProvider(provider *v1alpha3.GitProvider, cred Credential, ...) ([]gitclient.Option, error)

+ type CredentialTransportPolicy struct

+ AllowInsecureGitHTTP bool

type ResyncRequest

+ RefreshRemote bool

type WorkerManager

+ func (m *WorkerManager) SetCredentialTransportPolicy(policy CredentialTransportPolicy)

v0.45.0

Sep 9, 2026

v0.44.0

Sep 8, 2026

Changes in this version

+ const DefaultLiveCommitMessageTemplate

+ func ValidateLiteralCommitMessage(message string) error

type CommitMessageConfig

+ LiveTemplate string

+ type LiveCommitMessageData struct

+ Author string

+ Count int

+ GitTarget string

+ Operations map[string]int

+ Resources []ResourceRef

type ResourceRef

+ APIVersion string

+ Operation string

v0.43.0

Sep 3, 2026

Changes in this version

type CommitConfig

+ func (c CommitConfig) WithTargetMessage(spec *v1alpha3.CommitMessageSpec) CommitConfig

+ type LayoutReport struct

+ ResolvedAt time.Time

+ Revision string

+ type LayoutReporter func(target itypes.ResourceReference, report LayoutReport)

type ResolvedTargetMetadata

+ CommitMessage *v1alpha3.CommitMessageSpec

+ Namespaces namespacePolicy

+ Suspend bool

type WorkerManager

+ func (m *WorkerManager) SetLayoutReporter(reporter LayoutReporter)

v0.42.1

Aug 28, 2026

v0.42.0

Aug 28, 2026

Changes in this version

+ var ErrResyncSuperseded = errors.New("resync superseded by a newer request for the same scope")

type Event

+ SourceCell types.CellKey

type RenderFidelityGate

+ func (g *RenderFidelityGate) Reconcile(target types.ResourceReference, scopes []types.CellKey, ...) (RenderFidelityStatus, map[types.CellKey]uint64)

type RenderFidelityStatus

+ Revision uint64

type ResyncRequest

+ SourceCell types.CellKey

type ResyncScope

+ Cell types.CellKey

+ Version string

+ func ResyncScopeFor(gvr schema.GroupVersionResource, namespace string) ResyncScope

v0.41.2

Aug 25, 2026

v0.41.1

Aug 24, 2026

v0.41.0

Jul 30, 2026

Changes in this version

+ func PinExplicitSigningPolicy(repo *git.Repository) error

+ type Credential struct

+ Basic *gogithttp.BasicAuth

+ Bearer *gogithttp.TokenAuth

+ SSH *sshpkg.KeyAuth

+ func CredentialFromSecretData(ctx context.Context, k8sClient client.Client, provider *v1alpha3.GitProvider, ...) (Credential, error)

+ func (c Credential) Options() []gitclient.Option

v0.40.1

Jul 28, 2026

v0.40.0

Jul 27, 2026

v0.39.2

Jul 27, 2026

v0.39.1

Jul 23, 2026

v0.39.0

Jul 22, 2026

Changes in this version

+ const UnresolvedAuthorDisplayName

+ const UnresolvedAuthorEmail

+ const UnresolvedAuthorUsername

type AttachCommitRequest

+ Attribution AttributionOutcome

+ type AttributionOutcome string

+ const AttributionNotAttempted

+ const AttributionResolved

+ const AttributionUnresolved

+ func (o AttributionOutcome) NamesActor() bool

type Event

+ Attribution AttributionOutcome

type PendingWrite

+ Scope *ResyncScope

+ func (p PendingWrite) AttributionOutcome() AttributionOutcome

type ReconcileCommitMessageData

+ Namespace string

type ResolvedTargetMetadata

+ PruneMode v1alpha3.PruneMode

type ResyncRequest

+ Scope *ResyncScope

+ type ResyncScope struct

+ GVR schema.GroupVersionResource

+ Namespace string

+ func (s *ResyncScope) Matches(ri types.ResourceIdentifier) bool

+ func (s *ResyncScope) String() string

type ResyncStats

+ PruneMode v1alpha3.PruneMode

+ Retained int

type UserInfo

+ func UnresolvedAuthor() UserInfo

v0.38.0

Jul 19, 2026

Changes in this version

type Event

+ SourceCluster string

type ResolvedTargetMetadata

+ SourceCluster string

type WorkerManager

+ func (m *WorkerManager) SetClusterMapper(resolver func(clusterID string) typeset.Lookup)

v0.37.0

Jul 16, 2026

Changes in this version

+ type RenderFidelityGate struct

+ func NewRenderFidelityGate() *RenderFidelityGate

+ func (g *RenderFidelityGate) AllowsWrites(target types.ResourceReference) bool

+ func (g *RenderFidelityGate) Begin(target types.ResourceReference, scopes []RenderFidelityScope) RenderFidelityStatus

+ func (g *RenderFidelityGate) Fail(target types.ResourceReference, divergence manifestanalyzer.RenderDivergence) RenderFidelityStatus

+ func (g *RenderFidelityGate) Forget(target types.ResourceReference)

+ func (g *RenderFidelityGate) RecordScopeClean(target types.ResourceReference, epoch uint64, scope RenderFidelityScope) (RenderFidelityStatus, bool)

+ func (g *RenderFidelityGate) RecordScopeDivergence(target types.ResourceReference, epoch uint64, scope RenderFidelityScope, ...) (RenderFidelityStatus, bool)

+ func (g *RenderFidelityGate) Status(target types.ResourceReference) RenderFidelityStatus

+ type RenderFidelityScope struct

+ GVR schema.GroupVersionResource

+ Namespace string

+ type RenderFidelityState string

+ const RenderFidelityFalse

+ const RenderFidelityTrue

+ const RenderFidelityUnknown

+ type RenderFidelityStatus struct

+ CleanScopes int

+ Divergence *manifestanalyzer.RenderDivergence

+ Epoch uint64

+ Message string

+ Reason string

+ ScopeCount int

+ State RenderFidelityState

type WorkerManager

+ func (m *WorkerManager) RenderFidelityGate() *RenderFidelityGate

v0.36.0

Jul 14, 2026

Changes in this version

+ const DefaultBranchBufferMaxBytes

+ const DefaultCommitWindow

+ const DefaultCommitterEmail

+ const DefaultCommitterName

+ const DefaultEventCommitMessageTemplate

+ const DefaultGroupCommitMessageTemplate

+ const DefaultReconcileCommitMessageTemplate

+ const EncryptionProviderSOPS

+ const PushCooldown

+ const SigningKeyDataKey

+ const SigningPassphraseDataKey

+ const SigningPublicKeyDataKey

+ var ErrFinalizeQueueFull = errors.New("branch worker event queue full; item dropped")

+ var ErrRemoteRefNotFound = errors.New("remote ref not found")

+ var ErrRemoteRefNotFoundEmptyRepo = errors.New("remote ref not found (empty repo)")

+ func AuthFromSecretData(ctx context.Context, k8sClient client.Client, provider *v1alpha3.GitProvider, ...) (transport.AuthMethod, error)

+ func ConstructSafeEmail(username string, domain string) string

+ func GenerateSSHSigningKeyPair(passphrase []byte) ([]byte, []byte, error)

+ func GetCommitSigner(ctx context.Context, k8sClient client.Client, provider *v1alpha3.GitProvider) (gogit.Signer, error)

+ func GetCurrentBranch(r *git.Repository) (plumbing.ReferenceName, plumbing.Hash, error)

+ func GetHTTPAuthMethod(username, password string) (transport.AuthMethod, error)

+ func GetHTTPTokenAuthMethod(token string) (transport.AuthMethod, error)

+ func IsValidTargetPath(p string) bool

+ func LoadSSHCommitSigner(secret *corev1.Secret) (gogit.Signer, error)

+ func PushAtomic(ctx context.Context, repo *git.Repository, rootHash plumbing.Hash, ...) error

+ func SSHAuthorizedPublicKeyFromSecret(secret *corev1.Secret) (string, error)

+ func SmartFetch(ctx context.Context, repo *git.Repository, target plumbing.ReferenceName, ...) (plumbing.ReferenceName, error)

+ func ValidateCommitConfig(config CommitConfig) error

+ type AttachCommitRequest struct

+ Author string

+ CloseDelaySeconds int32

+ GitTargetName string

+ GitTargetNamespace string

+ Message string

+ Name string

+ Namespace string

+ UID string

+ type BranchInfo struct

+ Sha string

+ ShortName string

+ Unborn bool

+ type BranchKey struct

+ Branch string

+ RepoName string

+ RepoNamespace string

+ func (k BranchKey) String() string

+ type BranchWorker struct

+ Branch string

+ Client client.Client

+ GitProviderNamespace string

+ GitProviderRef string

+ Log logr.Logger

+ func NewBranchWorker(client client.Client, log logr.Logger, providerName, providerNamespace string, ...) *BranchWorker

+ func (w *BranchWorker) Enqueue(event Event) bool

+ func (w *BranchWorker) EnqueueAttach(req *AttachCommitRequest)

+ func (w *BranchWorker) EnqueueRequest(request *WriteRequest)

+ func (w *BranchWorker) EnqueueResync(request *ResyncRequest) bool

+ func (w *BranchWorker) EnsurePathBootstrapped(path, targetName, targetNamespace string) error

+ func (w *BranchWorker) GetBranchMetadata() (bool, string, time.Time)

+ func (w *BranchWorker) LookupCommitRequestOutcome(namespace, name, uid string) (FinalizeResult, bool)

+ func (w *BranchWorker) Start(parentCtx context.Context) error

+ func (w *BranchWorker) Stop()

+ func (w *BranchWorker) SyncAndGetMetadata(ctx context.Context) (*PullReport, error)

+ type CommitConfig struct

+ Committer CommitterConfig

+ Message CommitMessageConfig

+ func ResolveCommitConfig(spec *v1alpha3.CommitSpec) CommitConfig

+ type CommitFile struct

+ Content []byte

+ Path string

+ type CommitMessageConfig struct

+ EventTemplate string

+ GroupTemplate string

+ ReconcileTemplate string

+ type CommitMessageData struct

+ APIVersion string

+ GitTarget string

+ Group string

+ Name string

+ Namespace string

+ Operation string

+ Resource string

+ Username string

+ Version string

+ type CommitMessageKind string

+ const CommitMessageGrouped

+ const CommitMessagePerEvent

+ const CommitMessageReconcile

+ type CommitMode string

+ const CommitModeAtomic

+ const CommitModePerEvent

+ type CommitterConfig struct

+ Email string

+ Name string

+ type Encryptor interface

+ Encrypt func(ctx context.Context, plain []byte, meta ResourceMeta) ([]byte, error)

+ type Event struct

+ AuditStreamID string

+ BootstrapOptions pathBootstrapOptions

+ FieldPatch *FieldPatch

+ GitTargetName string

+ GitTargetNamespace string

+ Identifier types.ResourceIdentifier

+ Object *unstructured.Unstructured

+ Operation string

+ Path string

+ UserInfo UserInfo

+ func (e Event) IsFieldPatch() bool

+ type FieldPatch struct

+ Assignments []manifestedit.FieldAssignment

+ Source string

+ type FinalizeOutcome string

+ const FinalizeAlreadyPresent

+ const FinalizeCommitted

+ const FinalizeNoOpenWindow

+ const FinalizeWindowMismatch

+ type FinalizeResult struct

+ Branch string

+ Err error

+ Outcome FinalizeOutcome

+ SHA string

+ type GroupedCommitMessageData struct

+ Author string

+ Count int

+ GitTarget string

+ Operations map[string]int

+ Resources []ResourceRef

+ type PathRefusalReporter func(target itypes.ResourceReference, ...)

+ type PendingWrite struct

+ ByteSize int64

+ CommitConfig CommitConfig

+ CommitMessage string

+ CommitRequest *commitRequestID

+ CommitSHA plumbing.Hash

+ Committed *bool

+ Desired []manifestanalyzer.DesiredResource

+ Events []Event

+ GitTargetName string

+ GitTargetNamespace string

+ Kind PendingWriteKind

+ ResyncStats *ResyncStats

+ Revision string

+ ScopeGVR *schema.GroupVersionResource

+ Signer gogit.Signer

+ Targets map[pendingTargetKey]ResolvedTargetMetadata

+ func (p PendingWrite) Author() string

+ func (p PendingWrite) AuthorUserInfo() UserInfo

+ func (p PendingWrite) MessageKind() CommitMessageKind

+ func (p PendingWrite) Target() ResolvedTargetMetadata

+ type PendingWriteKind string

+ const PendingWriteAtomic

+ const PendingWriteCommit

+ const PendingWriteResync

+ type PullReport struct

+ ExistsOnRemote bool

+ HEAD BranchInfo

+ IncomingChanges bool

+ func PrepareBranch(ctx context.Context, repoURL, repoPath, targetBranchName string, ...) (*PullReport, error)

+ type ReconcileCommitMessageData struct

+ APIVersion string

+ Count int

+ GitTarget string

+ Group string

+ Resource string

+ Revision string

+ Version string

+ type RepoInfo struct

+ DefaultBranch *BranchInfo

+ RemoteBranchCount int

+ func CheckRepo(ctx context.Context, repoURL string, auth transport.AuthMethod) (*RepoInfo, error)

+ type ResolvedEncryptionConfig struct

+ AgeRecipients []string

+ Provider string

+ func ResolveTargetEncryption(ctx context.Context, k8sClient client.Client, target *v1alpha3.GitTarget) (*ResolvedEncryptionConfig, error)

+ type ResolvedTargetMetadata struct

+ BootstrapOptions pathBootstrapOptions

+ EncryptionConfig *ResolvedEncryptionConfig

+ Name string

+ Namespace string

+ Path string

+ Placement *manifestanalyzer.PlacementPolicy

+ type ResourceMeta struct

+ Generation int64

+ Identifier itypes.ResourceIdentifier

+ ResourceVersion string

+ UID string

+ type ResourceRef struct

+ Group string

+ Name string

+ Namespace string

+ Resource string

+ Version string

+ func (r ResourceRef) String() string

+ type ResyncRequest struct

+ Desired []manifestanalyzer.DesiredResource

+ GitTargetName string

+ GitTargetNamespace string

+ Heal bool

+ Result chan ResyncResult

+ Revision string

+ ScopeGVR *schema.GroupVersionResource

+ type ResyncResult struct

+ Err error

+ Stats ResyncStats

+ type ResyncStats struct

+ Created int

+ Deleted int

+ PlacementSkipped int

+ Skipped int

+ Updated int

+ type SOPSEncryptor struct

+ func NewSOPSEncryptor(binaryPath, configPath string) *SOPSEncryptor

+ func NewSOPSEncryptorWithEnv(binaryPath, configPath, workDir string, env map[string]string) *SOPSEncryptor

+ func (e *SOPSEncryptor) Encrypt(ctx context.Context, plain []byte, meta ResourceMeta) ([]byte, error)

+ type SSHHostKeyConfig struct

+ AllowMissingKnownHosts bool

+ ControllerNamespace string

+ DefaultKnownHostsConfigMap string

+ type UserInfo struct

+ DisplayName string

+ Email string

+ UID string

+ Username string

+ type WorkItem struct

+ Attach *AttachCommitRequest

+ Request *WriteRequest

+ Resync *ResyncRequest

+ type WorkerManager struct

+ Client client.Client

+ Log logr.Logger

+ func NewWorkerManager(client client.Client, log logr.Logger, branchBufferMaxBytes int64, ...) *WorkerManager

+ func (m *WorkerManager) EnsureWorker(_ context.Context, providerName, providerNamespace string, branch string) error

+ func (m *WorkerManager) GetWorkerForTarget(providerName, providerNamespace string, branch string) (*BranchWorker, bool)

+ func (m *WorkerManager) NeedLeaderElection() bool

+ func (m *WorkerManager) ReconcileWorkers(ctx context.Context) error

+ func (m *WorkerManager) RegisterTarget(ctx context.Context, targetName, targetNamespace string, ...) error

+ func (m *WorkerManager) SetMapper(mapper typeset.Lookup)

+ func (m *WorkerManager) SetPathRefusalReporter(reporter PathRefusalReporter)

+ func (m *WorkerManager) SetSSHHostKeyConfig(cfg SSHHostKeyConfig)

+ func (m *WorkerManager) Start(ctx context.Context) error

+ func (m *WorkerManager) UnregisterTarget(_, _ string, providerName, providerNamespace string, branch string) error

+ type WriteRequest struct

+ BootstrapOptions pathBootstrapOptions

+ CommitConfig *CommitConfig

+ CommitMessage string

+ CommitMode CommitMode

+ Events []Event

+ GitTargetName string

+ GitTargetNamespace string

+ Signer gogit.Signer

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL