Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventEnqueuer ¶
EventEnqueuer enqueues live events onto a branch worker (allows mocking). Enqueue reports whether the event entered the worker's FIFO; a false return means the queue was full and the event was dropped, so the caller must not advance a durable watch cursor past it.
type GitTargetEventStream ¶
type GitTargetEventStream struct {
// contains filtered or unexported fields
}
GitTargetEventStream forwards a GitTarget's live field-patch events to its branch worker.
With the api-source-of-truth pivot (R3) the resource mirror is the per-type splice reconcile, not a live per-event stream: the long-lived object informers, the RECONCILING handover buffer, and the content-hash deduplication this type used to own are all gone. What remains is a thin route for the events the splice deliberately does not own — the /scale subresource translated into a parent-manifest field patch (redis_audit_consumer.routeScaleFieldPatch). "Newer?" is now answered by the audit stream's RV ordering and "changed?" by the writer's no-op detection (manifestedit.Decide at the commit boundary), so no hash is computed here. See docs/architecture.md (DEC-6, DEC-7).
func NewGitTargetEventStream ¶
func NewGitTargetEventStream( gitTargetName, gitTargetNamespace string, branchWorker EventEnqueuer, logger logr.Logger, ) *GitTargetEventStream
NewGitTargetEventStream creates a new event stream for a GitTarget.
func (*GitTargetEventStream) OnWatchEvent ¶
func (s *GitTargetEventStream) OnWatchEvent(event git.Event) error
OnWatchEvent forwards a live event to the GitTarget's branch worker. An event with no object payload that is neither a DELETE nor a field patch carries nothing to write and is dropped (returns nil — there is nothing to durably hand off). It returns a non-nil error only when the worker's queue is full and a real event was dropped, so the watch loop does not advance its durable cursor past an event the worker never accepted: the watch reconnects from the un-advanced cursor and redelivers, which is safe because the writer's no-op detection at the commit boundary makes redelivery idempotent.
func (*GitTargetEventStream) String ¶
func (s *GitTargetEventStream) String() string
String returns a string representation for debugging.
Source Files