runtime

type ErrorApiResponse struct {
	ErrMessage string         `json:"errorMessage"`
	Data       []ErrorDetails `json:"data"`
}

type ErrorDetails struct {
	Container string `json:"container"`
	Timestamp int64  `json:"timestamp"`
	Code      string `json:"code"`
	Message   string `json:"message"`
	Details   string `json:"details"`
}

type PipelineRuntimeCache interface {
	// StartCacheRefresher starts the cache refresher to update the local cache with the runtime errors.
	StartCacheRefresher(ctx context.Context) error
	// GetLocalCache returns the local cache of runtime errors for each vertex.
	GetLocalCache() map[string][]ReplicaErrors
}

type PodTracker struct {
	// contains filtered or unexported fields
}

type ReplicaErrors struct {
	Replica         string         `json:"replica"`
	ContainerErrors []ErrorDetails `json:"containerErrors"`
}