runtime

Jun 18, 2025

Changes in this version

+ type ErrorApiResponse struct

+ Data []ErrorDetails

+ ErrMessage string

+ type ErrorDetails struct

+ Code string

+ Container string

+ Details string

+ Message string

+ Timestamp int64

+ type PipelineRuntimeCache interface

+ GetLocalCache func() map[string][]ReplicaErrors

+ StartCacheRefresher func(ctx context.Context) error

+ func NewRuntime(ctx context.Context, pl *v1alpha1.Pipeline) PipelineRuntimeCache

+ type PodTracker struct

+ func NewPodTracker(ctx context.Context, pl *v1alpha1.Pipeline) *PodTracker

+ func (pt *PodTracker) GetActivePodsCountForVertex(vertexName string) int

+ func (pt *PodTracker) Start(ctx context.Context) error

+ type ReplicaErrors struct

+ ContainerErrors []ErrorDetails

+ Replica string