events

package

Go to main page

Versions in this module

v0

v0.9.0

Oct 30, 2026

v0.8.1

Oct 29, 2026

v0.8.0

Oct 28, 2026

v0.7.0

Oct 20, 2026

Changes in this version

+ const DeploymentCancelReasonEndpointAuthorityChanged

+ const DeploymentCancelReasonTimeout

+ const EventTypeConfigVerdictReplayed

type ConfigInvalidEvent

+ VerdictSequence uint64

type ConfigValidatedEvent

+ VerdictSequence uint64

type ConfigValidationInconclusiveEvent

+ VerdictSequence uint64

+ type ConfigVerdict interface

+ type ConfigVerdictReplayedEvent struct

+ Verdict ConfigVerdict

+ func NewConfigVerdictReplayedEvent(verdict ConfigVerdict) *ConfigVerdictReplayedEvent

+ func (e *ConfigVerdictReplayedEvent) EventType() string

+ func (t *ConfigVerdictReplayedEvent) Timestamp() time.Time

v0.6.0

Oct 18, 2026

Changes in this version

+ const EventTypeBecameLeader

+ const EventTypeConfigAppliedToPod

+ const EventTypeConfigInvalid

+ const EventTypeConfigParsed

+ const EventTypeConfigPublished

+ const EventTypeConfigResourceChanged

+ const EventTypeConfigValidated

+ const EventTypeConfigValidationInconclusive

+ const EventTypeConfigValidationRequest

+ const EventTypeConfigValidationResponse

+ const EventTypeCredentialsUpdated

+ const EventTypeDeployedConfigPublishRequest

+ const EventTypeDeploymentCancelRequest

+ const EventTypeDeploymentCompleted

+ const EventTypeDeploymentScheduled

+ const EventTypeDeploymentSkipped

+ const EventTypeDeploymentStarted

+ const EventTypeDriftPreventionTriggered

+ const EventTypeHAProxyPodRejected

+ const EventTypeHAProxyPodTerminated

+ const EventTypeHAProxyPodsDiscovered

+ const EventTypeHTTPContentAcceptanceRequested

+ const EventTypeHTTPContentRejected

+ const EventTypeHTTPContentRevoked

+ const EventTypeHTTPResourceAccepted

+ const EventTypeHTTPResourceUpdated

+ const EventTypeIndexSynchronized

+ const EventTypeInstanceDeploymentFailed

+ const EventTypeLeaderElectionStarted

+ const EventTypeLibrarySetChanged

+ const EventTypeLostLeadership

+ const EventTypeNewLeaderObserved

+ const EventTypeProposalValidationCompleted

+ const EventTypeProposalValidationRequested

+ const EventTypeReconciliationCompleted

+ const EventTypeReconciliationFailed

+ const EventTypeReconciliationStarted

+ const EventTypeReconciliationTriggered

+ const EventTypeRenderGateCompleted

+ const EventTypeResourceIndexUpdated

+ const EventTypeResourceSyncComplete

+ const EventTypeResourcesApplied

+ const EventTypeResourcesProcessed

+ const EventTypeRetainedConfig

+ const EventTypeSecretResourceChanged

+ const EventTypeStatusUpdateCompleted

+ const EventTypeStatusUpdateFailed

+ const EventTypeTemplateRenderFailed

+ const EventTypeTemplateRendered

+ const EventTypeValidationFailed

+ const EventTypeWatchedInputsRejected

+ const LeadershipLostReasonHandover

+ const LeadershipLostReasonLeaseLost

+ const SkipReasonConfigUnchanged

+ const SkipReasonReloadObserved

+ const TriggerReasonDriftPrevention

+ type BecameLeaderEvent struct

+ Identity string

+ func NewBecameLeaderEvent(identity string) *BecameLeaderEvent

+ func (e *BecameLeaderEvent) EventType() string

+ func (t *BecameLeaderEvent) Timestamp() time.Time

+ type ConfigAppliedToPodEvent struct

+ Checksum string

+ IsDriftCheck bool

+ PodName string

+ PodNamespace string

+ PodRuntimeID string

+ PodUID string

+ RuntimeConfigName string

+ RuntimeConfigNamespace string

+ SyncMetadata *SyncMetadata

+ func NewConfigAppliedToPodEvent(...) *ConfigAppliedToPodEvent

+ func (e *ConfigAppliedToPodEvent) EventType() string

+ func (t *ConfigAppliedToPodEvent) Timestamp() time.Time

+ type ConfigInvalidEvent struct

+ Sources []ConfigSourceRef

+ TemplateConfig any

+ ValidationErrors map[string][]string

+ Version string

+ func NewConfigInvalidEvent(version string, templateConfig any, validationErrors map[string][]string) *ConfigInvalidEvent

+ func (e *ConfigInvalidEvent) EventType() string

+ func (t *ConfigInvalidEvent) Timestamp() time.Time

+ type ConfigParsedEvent struct

+ Config any

+ SecretVersion string

+ Sources []ConfigSourceRef

+ TemplateConfig any

+ Version string

+ func NewConfigParsedEvent(config, templateConfig any, version, secretVersion string) *ConfigParsedEvent

+ func (e *ConfigParsedEvent) EventType() string

+ func (t *ConfigParsedEvent) Timestamp() time.Time

+ type ConfigPublishedEvent struct

+ MapFileCount int

+ RuntimeConfigName string

+ RuntimeConfigNamespace string

+ SecretCount int

+ func NewConfigPublishedEvent(runtimeConfigName, runtimeConfigNamespace string, ...) *ConfigPublishedEvent

+ func (e *ConfigPublishedEvent) EventType() string

+ func (t *ConfigPublishedEvent) Timestamp() time.Time

+ type ConfigResourceChangedEvent struct

+ Resource any

+ func NewConfigResourceChangedEvent(resource any) *ConfigResourceChangedEvent

+ func (e *ConfigResourceChangedEvent) EventType() string

+ func (t *ConfigResourceChangedEvent) Timestamp() time.Time

+ type ConfigSourceRef struct

+ Generation int64

+ Name string

+ Namespace string

+ ResourceVersion string

+ UID types.UID

+ type ConfigValidatedEvent struct

+ ActiveSnapshotRestore bool

+ CandidateGeneration uint64

+ Config any

+ SecretVersion string

+ Sources []ConfigSourceRef

+ TemplateConfig any

+ Version string

+ func NewConfigValidatedEvent(config, templateConfig any, version, secretVersion string) *ConfigValidatedEvent

+ func (e *ConfigValidatedEvent) EventType() string

+ func (t *ConfigValidatedEvent) Timestamp() time.Time

+ type ConfigValidationInconclusiveEvent struct

+ Reasons map[string][]string

+ RetryIn time.Duration

+ Sources []ConfigSourceRef

+ TemplateConfig any

+ Version string

+ func NewConfigValidationInconclusiveEvent(version string, templateConfig any, reasons map[string][]string, ...) *ConfigValidationInconclusiveEvent

+ func (e *ConfigValidationInconclusiveEvent) EventType() string

+ func (t *ConfigValidationInconclusiveEvent) Timestamp() time.Time

+ type ConfigValidationRequest struct

+ Config any

+ Version string

+ func NewConfigValidationRequest(config any, version string) *ConfigValidationRequest

+ func (e *ConfigValidationRequest) EventType() string

+ func (e *ConfigValidationRequest) RequestID() string

+ func (t *ConfigValidationRequest) Timestamp() time.Time

+ type ConfigValidationResponse struct

+ Errors []string

+ Inconclusive bool

+ Valid bool

+ ValidatorName string

+ func NewConfigValidationInconclusiveResponse(requestID, validatorName string, reasons []string) *ConfigValidationResponse

+ func NewConfigValidationResponse(requestID, validatorName string, valid bool, errors []string) *ConfigValidationResponse

+ func (e *ConfigValidationResponse) EventType() string

+ func (e *ConfigValidationResponse) RequestID() string

+ func (e *ConfigValidationResponse) Responder() string

+ func (t *ConfigValidationResponse) Timestamp() time.Time

+ type CorrelatedEvent interface

+ CausationID func() string

+ CorrelationID func() string

+ EventID func() string

+ type Correlation struct

+ func (c *Correlation) CausationID() string

+ func (c *Correlation) CorrelationID() string

+ func (c *Correlation) EventID() string

+ type CorrelationOption struct

+ func PropagateCorrelation(source any) CorrelationOption

+ func WithCorrelation(correlationID, causationID string) CorrelationOption

+ func WithNewCorrelation() CorrelationOption

+ type CredentialsUpdatedEvent struct

+ Credentials any

+ SecretVersion string

+ func NewCredentialsUpdatedEvent(credentials any, secretVersion string) *CredentialsUpdatedEvent

+ func (e *CredentialsUpdatedEvent) EventType() string

+ func (t *CredentialsUpdatedEvent) Timestamp() time.Time

+ type DeployPhases struct

+ Agent api.ApplyTiming

+ BlobWaitMs int64

+ DiffMs int64

+ Pod string

+ PrepareMs int64

+ SendMs int64

+ SettleMs int64

+ StateMs int64

+ TotalMs int64

+ UploadBytes int64

+ type DeployedConfigPublishRequest struct

+ AuxiliaryFiles *dataplane.AuxiliaryFiles

+ Config string

+ ConfirmedPod *v1.PodDeploymentStatus

+ ContentChecksum string

+ CycleSnapshot *rendercycle.Snapshot

+ OutputSnapshot *renderoutput.Snapshot

+ RuntimeConfigName string

+ RuntimeConfigNamespace string

+ func NewDeployedConfigPublishRequestWithCycle(runtimeConfigName, runtimeConfigNamespace string, ...) (*DeployedConfigPublishRequest, error)

+ func (c DeployedConfigPublishRequest) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c DeployedConfigPublishRequest) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *DeployedConfigPublishRequest) CloneForSubscriber() busevents.Event

+ func (e *DeployedConfigPublishRequest) EventType() string

+ func (t *DeployedConfigPublishRequest) Timestamp() time.Time

+ type DeploymentCancelRequestEvent struct

+ DeploymentID string

+ Reason string

+ func NewDeploymentCancelRequestEvent(deploymentID, reason string, opts ...CorrelationOption) *DeploymentCancelRequestEvent

+ func (e *DeploymentCancelRequestEvent) EventType() string

+ func (t *DeploymentCancelRequestEvent) Timestamp() time.Time

+ type DeploymentCompletedEvent struct

+ BackendDiffFields string

+ ContentChecksum string

+ CycleSnapshot *rendercycle.Snapshot

+ DeploymentID string

+ DurationMs int64

+ Failed int

+ OperationBreakdown map[string]int

+ OutputSnapshot *renderoutput.Snapshot

+ PendingReloadUntil time.Time

+ PendingReloads int

+ Phases *DeployPhases

+ Plan *renderplan.Plan

+ PodSetHash string

+ ReloadsTriggered int

+ RenderProof string

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ Succeeded int

+ Total int

+ TotalAPIOperations int

+ func NewDeploymentCompletedEvent(result *DeploymentResult, opts ...CorrelationOption) *DeploymentCompletedEvent

+ func NewDeploymentCompletedEventWithCycle(result *DeploymentResult, opts ...CorrelationOption) (*DeploymentCompletedEvent, error)

+ func NewDeploymentCompletedEventWithOutputSnapshot(result *DeploymentResult, opts ...CorrelationOption) (*DeploymentCompletedEvent, error)

+ func (c DeploymentCompletedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c DeploymentCompletedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *DeploymentCompletedEvent) CloneForSubscriber() busevents.Event

+ func (e *DeploymentCompletedEvent) Coalescible() bool

+ func (e *DeploymentCompletedEvent) EventType() string

+ func (t *DeploymentCompletedEvent) Timestamp() time.Time

+ type DeploymentResult struct

+ BackendDiffFields string

+ ContentChecksum string

+ CycleSnapshot *rendercycle.Snapshot

+ DeploymentID string

+ DurationMs int64

+ Failed int

+ OperationBreakdown map[string]int

+ OutputSnapshot *renderoutput.Snapshot

+ PendingReloadUntil time.Time

+ PendingReloads int

+ Phases *DeployPhases

+ Plan *renderplan.Plan

+ PodSetHash string

+ ReloadsTriggered int

+ RenderProof string

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ Succeeded int

+ Total int

+ TotalAPIOperations int

+ func NewDeploymentResultWithOccurrence(occurrence *rendercycle.Occurrence) (*DeploymentResult, error)

+ func (c DeploymentResult) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c DeploymentResult) RenderOccurrence() (*rendercycle.Occurrence, error)

+ type DeploymentScheduledEvent struct

+ AuxiliaryFiles *dataplane.AuxiliaryFiles

+ Config string

+ ContentChecksum string

+ CycleSnapshot *rendercycle.Snapshot

+ Endpoints []dataplane.Endpoint

+ OutputSnapshot *renderoutput.Snapshot

+ Plan *renderplan.Plan

+ PlanID string

+ Reason string

+ RenderProof string

+ RuntimeConfigName string

+ RuntimeConfigNamespace string

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ func NewDeploymentScheduledEvent(config string, auxFiles *dataplane.AuxiliaryFiles, ...) *DeploymentScheduledEvent

+ func NewDeploymentScheduledEventWithCycle(occurrence *rendercycle.Occurrence, endpoints []dataplane.Endpoint, ...) (*DeploymentScheduledEvent, error)

+ func NewDeploymentScheduledEventWithOutputSnapshot(occurrence *rendercycle.Occurrence, endpoints []dataplane.Endpoint, ...) (*DeploymentScheduledEvent, error)

+ func NewDeploymentScheduledEventWithStatusSnapshot(config string, auxFiles *dataplane.AuxiliaryFiles, ...) *DeploymentScheduledEvent

+ func (c DeploymentScheduledEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c DeploymentScheduledEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *DeploymentScheduledEvent) CloneForSubscriber() busevents.Event

+ func (e *DeploymentScheduledEvent) Coalescible() bool

+ func (e *DeploymentScheduledEvent) EventType() string

+ func (t *DeploymentScheduledEvent) Timestamp() time.Time

+ type DeploymentSkippedEvent struct

+ ConfigHash string

+ CycleSnapshot *rendercycle.Snapshot

+ OutputSnapshot *renderoutput.Snapshot

+ Plan *renderplan.Plan

+ PodSetHash string

+ Reason string

+ RenderProof string

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ Total int

+ func NewDeploymentSkippedEvent(total int, reason, configHash, podSetHash string, ...) *DeploymentSkippedEvent

+ func NewDeploymentSkippedEventWithCycle(occurrence *rendercycle.Occurrence, total int, reason string, ...) (*DeploymentSkippedEvent, error)

+ func NewDeploymentSkippedEventWithIdentity(total int, reason string, configHash string, podSetHash string, ...) *DeploymentSkippedEvent

+ func NewDeploymentSkippedEventWithOutputSnapshot(occurrence *rendercycle.Occurrence, total int, reason string, ...) (*DeploymentSkippedEvent, error)

+ func NewDeploymentSkippedEventWithStatusSnapshot(total int, reason string, configHash string, podSetHash string, ...) *DeploymentSkippedEvent

+ func (c DeploymentSkippedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c DeploymentSkippedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *DeploymentSkippedEvent) CloneForSubscriber() busevents.Event

+ func (e *DeploymentSkippedEvent) Coalescible() bool

+ func (e *DeploymentSkippedEvent) EventType() string

+ func (t *DeploymentSkippedEvent) Timestamp() time.Time

+ type DeploymentStartedEvent struct

+ EndpointCount int

+ func NewDeploymentStartedEvent(endpointCount int, opts ...CorrelationOption) *DeploymentStartedEvent

+ func (e *DeploymentStartedEvent) EventType() string

+ func (t *DeploymentStartedEvent) Timestamp() time.Time

+ type DriftPreventionTriggeredEvent struct

+ TimeSinceLastDeployment time.Duration

+ func NewDriftPreventionTriggeredEvent(timeSinceLast time.Duration) *DriftPreventionTriggeredEvent

+ func (e *DriftPreventionTriggeredEvent) EventType() string

+ func (t *DriftPreventionTriggeredEvent) Timestamp() time.Time

+ type HAProxyPodRejectedEvent struct

+ PodName string

+ Reason string

+ func NewHAProxyPodRejectedEvent(podName, reason string) *HAProxyPodRejectedEvent

+ func (e *HAProxyPodRejectedEvent) EventType() string

+ func (t *HAProxyPodRejectedEvent) Timestamp() time.Time

+ type HAProxyPodTerminatedEvent struct

+ PodName string

+ PodNamespace string

+ PodUID string

+ func NewHAProxyPodTerminatedEvent(podName, podNamespace, podUID string) *HAProxyPodTerminatedEvent

+ func (e *HAProxyPodTerminatedEvent) EventType() string

+ func (t *HAProxyPodTerminatedEvent) Timestamp() time.Time

+ type HAProxyPodsDiscoveredEvent struct

+ Count int

+ Endpoints []dataplane.Endpoint

+ func NewHAProxyPodsDiscoveredEvent(endpoints []dataplane.Endpoint, count int) *HAProxyPodsDiscoveredEvent

+ func (e *HAProxyPodsDiscoveredEvent) Coalescible() bool

+ func (e *HAProxyPodsDiscoveredEvent) EventType() string

+ func (t *HAProxyPodsDiscoveredEvent) Timestamp() time.Time

+ type HTTPContentAcceptanceRequestedEvent struct

+ func NewHTTPContentAcceptanceRequestedEvent() *HTTPContentAcceptanceRequestedEvent

+ func (e *HTTPContentAcceptanceRequestedEvent) EventType() string

+ func (t *HTTPContentAcceptanceRequestedEvent) Timestamp() time.Time

+ type HTTPContentRejectedEvent struct

+ URL string

+ func NewHTTPContentRejectedEvent(url string) *HTTPContentRejectedEvent

+ func (e *HTTPContentRejectedEvent) EventType() string

+ func (t *HTTPContentRejectedEvent) Timestamp() time.Time

+ type HTTPContentRevokedEvent struct

+ ContentChecksum string

+ Critical bool

+ Restored bool

+ URL string

+ func NewHTTPContentRevokedEvent(url, checksum string, restored, critical bool) *HTTPContentRevokedEvent

+ func (e *HTTPContentRevokedEvent) EventType() string

+ func (t *HTTPContentRevokedEvent) Timestamp() time.Time

+ type HTTPResourceAcceptedEvent struct

+ ContentChecksum string

+ ContentSize int

+ URL string

+ func NewHTTPResourceAcceptedEvent(url, checksum string, size int) *HTTPResourceAcceptedEvent

+ func (e *HTTPResourceAcceptedEvent) EventType() string

+ func (t *HTTPResourceAcceptedEvent) Timestamp() time.Time

+ type HTTPResourceUpdatedEvent struct

+ ContentChecksum string

+ ContentSize int

+ URL string

+ func NewHTTPResourceUpdatedEvent(url, checksum string, size int) *HTTPResourceUpdatedEvent

+ func (e *HTTPResourceUpdatedEvent) Coalescible() bool

+ func (e *HTTPResourceUpdatedEvent) EventType() string

+ func (t *HTTPResourceUpdatedEvent) Timestamp() time.Time

+ type IndexSynchronizedEvent struct

+ ResourceCounts map[string]int

+ func NewIndexSynchronizedEvent(resourceCounts map[string]int) *IndexSynchronizedEvent

+ func (e *IndexSynchronizedEvent) EventType() string

+ func (t *IndexSynchronizedEvent) Timestamp() time.Time

+ type InputRejection struct

+ Deleted bool

+ Object corev1.ObjectReference

+ Reason string

+ type InstanceDeploymentFailedEvent struct

+ Endpoint any

+ Error string

+ Retryable bool

+ func NewInstanceDeploymentFailedEvent(endpoint any, err string, retryable bool, opts ...CorrelationOption) *InstanceDeploymentFailedEvent

+ func (e *InstanceDeploymentFailedEvent) EventType() string

+ func (t *InstanceDeploymentFailedEvent) Timestamp() time.Time

+ type LeaderElectionStartedEvent struct

+ Identity string

+ LeaseName string

+ LeaseNamespace string

+ func NewLeaderElectionStartedEvent(identity, leaseName, leaseNamespace string) *LeaderElectionStartedEvent

+ func (e *LeaderElectionStartedEvent) EventType() string

+ func (t *LeaderElectionStartedEvent) Timestamp() time.Time

+ type LibrarySetChangedEvent struct

+ Snippets []any

+ func NewLibrarySetChangedEvent(snippets []any) *LibrarySetChangedEvent

+ func (e *LibrarySetChangedEvent) EventType() string

+ func (t *LibrarySetChangedEvent) Timestamp() time.Time

+ type LostLeadershipEvent struct

+ Identity string

+ Reason string

+ func NewLostLeadershipEvent(identity, reason string) *LostLeadershipEvent

+ func (e *LostLeadershipEvent) EventType() string

+ func (t *LostLeadershipEvent) Timestamp() time.Time

+ type NewLeaderObservedEvent struct

+ IsSelf bool

+ NewLeaderIdentity string

+ func NewNewLeaderObservedEvent(newLeaderIdentity string, isSelf bool) *NewLeaderObservedEvent

+ func (e *NewLeaderObservedEvent) EventType() string

+ func (t *NewLeaderObservedEvent) Timestamp() time.Time

+ type OperationCounts struct

+ BackendsAdded int

+ BackendsModified int

+ BackendsRemoved int

+ FrontendsAdded int

+ FrontendsModified int

+ FrontendsRemoved int

+ GeneralFilesAdded int

+ GeneralFilesModified int

+ GeneralFilesRemoved int

+ MapsAdded int

+ MapsModified int

+ MapsRemoved int

+ SSLCertsAdded int

+ SSLCertsModified int

+ SSLCertsRemoved int

+ ServersAdded int

+ ServersModified int

+ ServersRemoved int

+ TotalAPIOperations int

+ type ProposalValidationCompletedEvent struct

+ DurationMs int64

+ Error string

+ Phase string

+ RequestID string

+ Valid bool

+ func NewProposalValidationCompletedEvent(requestID string, durationMs int64) *ProposalValidationCompletedEvent

+ func NewProposalValidationFailedEvent(requestID, phase string, err error, durationMs int64) *ProposalValidationCompletedEvent

+ func (e *ProposalValidationCompletedEvent) EventType() string

+ func (t *ProposalValidationCompletedEvent) Timestamp() time.Time

+ type ProposalValidationRequestedEvent struct

+ HTTPOverlay stores.HTTPContentOverlay

+ ID string

+ Overlays map[string]*stores.StoreOverlay

+ Source string

+ SourceContext string

+ func NewProposalValidationRequestedEvent(overlays map[string]*stores.StoreOverlay, ...) *ProposalValidationRequestedEvent

+ func (e *ProposalValidationRequestedEvent) EventType() string

+ func (e *ProposalValidationRequestedEvent) RequestID() string

+ func (t *ProposalValidationRequestedEvent) Timestamp() time.Time

+ type ReconciliationCompletedEvent struct

+ CycleSnapshot *rendercycle.Snapshot

+ DurationMs int64

+ EventSnapshot *templating.RenderedEventSnapshot

+ Events []templating.RenderedEvent

+ PlanID string

+ ProfileCount int

+ RenderProof string

+ RenderedResourceSnapshot *templating.RenderedResourceSnapshot

+ RenderedResources []templating.RenderedResource

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ func NewReconciliationCompletedEvent(durationMs int64, planID string, ...) *ReconciliationCompletedEvent

+ func NewReconciliationCompletedEventWithCycle(durationMs int64, occurrence *rendercycle.Occurrence, ...) (*ReconciliationCompletedEvent, error)

+ func NewReconciliationCompletedEventWithStatusSnapshot(durationMs int64, planID string, ...) *ReconciliationCompletedEvent

+ func (c ReconciliationCompletedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c ReconciliationCompletedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *ReconciliationCompletedEvent) CloneForSubscriber() busevents.Event

+ func (e *ReconciliationCompletedEvent) Coalescible() bool

+ func (e *ReconciliationCompletedEvent) EventType() string

+ func (t *ReconciliationCompletedEvent) Timestamp() time.Time

+ type ReconciliationFailedEvent struct

+ DurationMs int64

+ Error string

+ Phase string

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ func NewReconciliationFailedEvent(err, phase string, statusPatches []templating.StatusPatch, ...) *ReconciliationFailedEvent

+ func NewReconciliationFailedEventWithStatusSnapshot(err, phase string, durationMs int64, ...) *ReconciliationFailedEvent

+ func (e *ReconciliationFailedEvent) EventType() string

+ func (t *ReconciliationFailedEvent) Timestamp() time.Time

+ type ReconciliationStartedEvent struct

+ Trigger string

+ func NewReconciliationStartedEvent(trigger string, opts ...CorrelationOption) *ReconciliationStartedEvent

+ func (e *ReconciliationStartedEvent) EventType() string

+ func (t *ReconciliationStartedEvent) Timestamp() time.Time

+ type ReconciliationTriggeredEvent struct

+ Reason string

+ func NewReconciliationTriggeredEvent(reason string, coalescible bool, opts ...CorrelationOption) *ReconciliationTriggeredEvent

+ func (e *ReconciliationTriggeredEvent) Coalescible() bool

+ func (e *ReconciliationTriggeredEvent) EventType() string

+ func (t *ReconciliationTriggeredEvent) Timestamp() time.Time

+ type RenderGateCompletedEvent struct

+ CycleSnapshot *rendercycle.Snapshot

+ DurationMs int64

+ Message string

+ Newest bool

+ OK bool

+ OutputSnapshot *renderoutput.Snapshot

+ Pinned bool

+ Plan *renderplan.Plan

+ PlanID string

+ Refused bool

+ RenderProof string

+ func NewRenderGateCompletedEvent(planID string, ok, refused, newest bool, message string, pinned bool, ...) *RenderGateCompletedEvent

+ func NewRenderGateCompletedEventWithCycle(occurrence *rendercycle.Occurrence, ok, refused, newest bool, message string, ...) (*RenderGateCompletedEvent, error)

+ func NewRenderGateCompletedEventWithIdentity(planID, renderProof string, plan *renderplan.Plan, ok, refused, newest bool, ...) *RenderGateCompletedEvent

+ func (c RenderGateCompletedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c RenderGateCompletedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *RenderGateCompletedEvent) CloneForSubscriber() busevents.Event

+ func (e *RenderGateCompletedEvent) EventType() string

+ func (t *RenderGateCompletedEvent) Timestamp() time.Time

+ type ResourceIndexUpdatedEvent struct

+ ChangeStats types.ChangeStats

+ ResourceTypeName string

+ func NewResourceIndexUpdatedEvent(resourceTypeName string, changeStats types.ChangeStats) *ResourceIndexUpdatedEvent

+ func (e *ResourceIndexUpdatedEvent) CoalesceWith(prev events.Event) events.Event

+ func (e *ResourceIndexUpdatedEvent) EventType() string

+ func (e *ResourceIndexUpdatedEvent) PreStartCoalesceKey() string

+ func (t *ResourceIndexUpdatedEvent) Timestamp() time.Time

+ type ResourceSyncCompleteEvent struct

+ InitialCount int

+ ResourceTypeName string

+ func NewResourceSyncCompleteEvent(resourceTypeName string, initialCount int) *ResourceSyncCompleteEvent

+ func (e *ResourceSyncCompleteEvent) EventType() string

+ func (t *ResourceSyncCompleteEvent) Timestamp() time.Time

+ type ResourcesAppliedEvent struct

+ CycleSnapshot *rendercycle.Snapshot

+ RenderProof string

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ func NewResourcesAppliedEvent(statusPatches []templating.StatusPatch, opts ...CorrelationOption) *ResourcesAppliedEvent

+ func NewResourcesAppliedEventWithCycle(occurrence *rendercycle.Occurrence, opts ...CorrelationOption) (*ResourcesAppliedEvent, error)

+ func NewResourcesAppliedEventWithStatusSnapshot(statusPatchSnapshot *templating.StatusPatchSnapshot, opts ...CorrelationOption) *ResourcesAppliedEvent

+ func (c ResourcesAppliedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c ResourcesAppliedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *ResourcesAppliedEvent) CloneForSubscriber() busevents.Event

+ func (e *ResourcesAppliedEvent) Coalescible() bool

+ func (e *ResourcesAppliedEvent) EventType() string

+ func (t *ResourcesAppliedEvent) Timestamp() time.Time

+ type ResourcesProcessedEvent struct

+ func NewResourcesProcessedEvent(occurrence *rendercycle.Occurrence, opts ...CorrelationOption) (*ResourcesProcessedEvent, error)

+ func (c ResourcesProcessedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c ResourcesProcessedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *ResourcesProcessedEvent) CloneForSubscriber() busevents.Event

+ func (e *ResourcesProcessedEvent) EventType() string

+ func (t *ResourcesProcessedEvent) Timestamp() time.Time

+ type RetainedConfigEvent struct

+ Message string

+ Name string

+ Namespace string

+ Reason string

+ UID string

+ func NewRetainedConfigEvent(namespace, name, uid, reason, message string) *RetainedConfigEvent

+ func (e *RetainedConfigEvent) EventType() string

+ func (t *RetainedConfigEvent) Timestamp() time.Time

+ type SecretResourceChangedEvent struct

+ Resource any

+ func NewSecretResourceChangedEvent(resource any) *SecretResourceChangedEvent

+ func (e *SecretResourceChangedEvent) EventType() string

+ func (t *SecretResourceChangedEvent) Timestamp() time.Time

+ type StatusPatchPhase string

+ const StatusPatchPhaseDeployFailed

+ const StatusPatchPhaseDeployed

+ const StatusPatchPhaseRenderFailed

+ const StatusPatchPhaseRendered

+ const StatusPatchPhaseValidateFailed

+ type StatusUpdateCompletedEvent struct

+ AppliedCount int

+ DurationMs int64

+ Phase StatusPatchPhase

+ SkippedCount int

+ func NewStatusUpdateCompletedEvent(phase StatusPatchPhase, appliedCount int, skippedCount int, durationMs int64, ...) *StatusUpdateCompletedEvent

+ func (e *StatusUpdateCompletedEvent) EventType() string

+ func (t *StatusUpdateCompletedEvent) Timestamp() time.Time

+ type StatusUpdateFailedEvent struct

+ Error string

+ GVR string

+ Name string

+ Namespace string

+ Retriable bool

+ func NewStatusUpdateFailedEvent(namespace string, name string, gvr string, err string, retriable bool, ...) *StatusUpdateFailedEvent

+ func (e *StatusUpdateFailedEvent) EventType() string

+ func (t *StatusUpdateFailedEvent) Timestamp() time.Time

+ type SyncMetadata struct

+ AppliedPlanID string

+ AppliedPlanProof string

+ AppliedRenderProof string

+ Error string

+ Mode string

+ OperationCounts OperationCounts

+ Reasons []string

+ ReloadTriggered bool

+ RunningPlanID string

+ RunningPlanProof string

+ SyncDuration time.Duration

+ type TemplateRenderFailedEvent struct

+ Error string

+ StackTrace string

+ TemplateName string

+ func NewTemplateRenderFailedEvent(templateName, err, stackTrace string, opts ...CorrelationOption) *TemplateRenderFailedEvent

+ func (e *TemplateRenderFailedEvent) EventType() string

+ func (t *TemplateRenderFailedEvent) Timestamp() time.Time

+ type TemplateRenderedEvent struct

+ AuxiliaryFileCount int

+ AuxiliaryFileSnapshot *renderartifact.Snapshot

+ AuxiliaryFiles *dataplane.AuxiliaryFiles

+ ConfigBytes int

+ ContentChecksum string

+ CycleSnapshot *rendercycle.Snapshot

+ DurationMs int64

+ HAProxyConfig string

+ OutputSnapshot *renderoutput.Snapshot

+ Plan *renderplan.Plan

+ PlanID string

+ RenderProof string

+ RenderedResources []templating.RenderedResource

+ StatusPatchSnapshot *templating.StatusPatchSnapshot

+ StatusPatches []templating.StatusPatch

+ TriggerReason string

+ func NewTemplateRenderedEvent(haproxyConfig string, auxiliaryFiles *dataplane.AuxiliaryFiles, ...) *TemplateRenderedEvent

+ func NewTemplateRenderedEventWithCycle(cycleSnapshot *rendercycle.Snapshot, durationMs int64, triggerReason string, ...) (*TemplateRenderedEvent, error)

+ func NewTemplateRenderedEventWithOccurrence(occurrence *rendercycle.Occurrence, durationMs int64, triggerReason string, ...) (*TemplateRenderedEvent, error)

+ func NewTemplateRenderedEventWithSnapshots(haproxyConfig string, auxiliaryFileSnapshot *renderartifact.Snapshot, ...) (*TemplateRenderedEvent, error)

+ func NewTemplateRenderedEventWithStatusSnapshot(haproxyConfig string, auxiliaryFiles *dataplane.AuxiliaryFiles, ...) *TemplateRenderedEvent

+ func (c TemplateRenderedEvent) AuthenticatedRenderIdentity() (*rendercycle.Snapshot, string, error)

+ func (c TemplateRenderedEvent) RenderOccurrence() (*rendercycle.Occurrence, error)

+ func (e *TemplateRenderedEvent) CloneForSubscriber() busevents.Event

+ func (e *TemplateRenderedEvent) Coalescible() bool

+ func (e *TemplateRenderedEvent) EventType() string

+ func (t *TemplateRenderedEvent) Timestamp() time.Time

+ type ValidationFailedEvent struct

+ DurationMs int64

+ Errors []string

+ TriggerReason string

+ func NewValidationFailedEvent(errors []string, durationMs int64, triggerReason string, ...) *ValidationFailedEvent

+ func (e *ValidationFailedEvent) EventType() string

+ func (t *ValidationFailedEvent) Timestamp() time.Time

+ type WatchedInputsRejectedEvent struct

+ Rejections []InputRejection

+ func NewWatchedInputsRejectedEvent(rejections []InputRejection) *WatchedInputsRejectedEvent

+ func (e *WatchedInputsRejectedEvent) EventType() string

+ func (t *WatchedInputsRejectedEvent) Timestamp() time.Time

v0.6.0-rc.2

Oct 17, 2026

v0.6.0-rc.1

Oct 17, 2026

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