Versions in this module Expand all Collapse all v0 v0.1.0 Mar 25, 2026 Changes in this version + var File_toc_v1_toc_proto protoreflect.FileDescriptor + var StageState_name = map[int32]string + var StageState_value = map[string]int32 + func DiagnosisFromProto(pb *Diagnosis) (core.Diagnosis, error) + func ObservationFromProto(pb *StageObservation) (core.StageObservation, error) + type DecodedBatch struct + Observations []core.StageObservation + PipelineID string + TimestampUnixNano int64 + WindowDurationNano int64 + func BatchFromProto(pb *ObservationBatch) (DecodedBatch, error) + type Diagnosis struct + Confidence float64 + Constraint string + Stages []*StageDiagnosis + StarvationCount int64 + func DiagnosisToProto(d core.Diagnosis) *Diagnosis + func (*Diagnosis) Descriptor() ([]byte, []int) + func (*Diagnosis) ProtoMessage() + func (x *Diagnosis) GetConfidence() float64 + func (x *Diagnosis) GetConstraint() string + func (x *Diagnosis) GetStages() []*StageDiagnosis + func (x *Diagnosis) GetStarvationCount() int64 + func (x *Diagnosis) ProtoReflect() protoreflect.Message + func (x *Diagnosis) Reset() + func (x *Diagnosis) String() string + type ObservationBatch struct + Observations []*StageObservation + PipelineId string + TimestampUnixNano int64 + WindowDurationNano int64 + func BatchToProto(pipelineID string, timestampUnixNano, windowDurationNano int64, ...) *ObservationBatch + func (*ObservationBatch) Descriptor() ([]byte, []int) + func (*ObservationBatch) ProtoMessage() + func (x *ObservationBatch) GetObservations() []*StageObservation + func (x *ObservationBatch) GetPipelineId() string + func (x *ObservationBatch) GetTimestampUnixNano() int64 + func (x *ObservationBatch) GetWindowDurationNano() int64 + func (x *ObservationBatch) ProtoReflect() protoreflect.Message + func (x *ObservationBatch) Reset() + func (x *ObservationBatch) String() string + type StageDiagnosis struct + Arrivals int64 + BlockedRatio *float64 + Completions int64 + ErrorRate float64 + Failures int64 + IdleRatio *float64 + QueueGrowth int64 + Stage string + State StageState + Utilization float64 + func (*StageDiagnosis) Descriptor() ([]byte, []int) + func (*StageDiagnosis) ProtoMessage() + func (x *StageDiagnosis) GetArrivals() int64 + func (x *StageDiagnosis) GetBlockedRatio() float64 + func (x *StageDiagnosis) GetCompletions() int64 + func (x *StageDiagnosis) GetErrorRate() float64 + func (x *StageDiagnosis) GetFailures() int64 + func (x *StageDiagnosis) GetIdleRatio() float64 + func (x *StageDiagnosis) GetQueueGrowth() int64 + func (x *StageDiagnosis) GetStage() string + func (x *StageDiagnosis) GetState() StageState + func (x *StageDiagnosis) GetUtilization() float64 + func (x *StageDiagnosis) ProtoReflect() protoreflect.Message + func (x *StageDiagnosis) Reset() + func (x *StageDiagnosis) String() string + type StageObservation struct + Arrivals int64 + BlockedWork *uint64 + BusyWork uint64 + CapacityWork uint64 + Completions *int64 + Failures *int64 + IdleWork *uint64 + QueueDepth *int64 + Stage string + Workers int32 + func ObservationToProto(o core.StageObservation) *StageObservation + func (*StageObservation) Descriptor() ([]byte, []int) + func (*StageObservation) ProtoMessage() + func (x *StageObservation) GetArrivals() int64 + func (x *StageObservation) GetBlockedWork() uint64 + func (x *StageObservation) GetBusyWork() uint64 + func (x *StageObservation) GetCapacityWork() uint64 + func (x *StageObservation) GetCompletions() int64 + func (x *StageObservation) GetFailures() int64 + func (x *StageObservation) GetIdleWork() uint64 + func (x *StageObservation) GetQueueDepth() int64 + func (x *StageObservation) GetStage() string + func (x *StageObservation) GetWorkers() int32 + func (x *StageObservation) ProtoReflect() protoreflect.Message + func (x *StageObservation) Reset() + func (x *StageObservation) String() string + type StageState int32 + const StageState_STAGE_STATE_BLOCKED + const StageState_STAGE_STATE_BROKEN + const StageState_STAGE_STATE_HEALTHY + const StageState_STAGE_STATE_SATURATED + const StageState_STAGE_STATE_STARVED + const StageState_STAGE_STATE_UNSPECIFIED + func (StageState) Descriptor() protoreflect.EnumDescriptor + func (StageState) EnumDescriptor() ([]byte, []int) + func (StageState) Type() protoreflect.EnumType + func (x StageState) Enum() *StageState + func (x StageState) Number() protoreflect.EnumNumber + func (x StageState) String() string
Go to main page