Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tocpb

package

Go to main page

Versions in this module

v0

v0.11.0

Mar 30, 2026

v0.10.0

Mar 30, 2026

v0.9.0

Mar 29, 2026

v0.8.0

Mar 29, 2026

v0.7.0

Mar 29, 2026

v0.6.0

Mar 29, 2026

v0.5.1

Mar 29, 2026

v0.5.0

Mar 29, 2026

v0.4.0

Mar 29, 2026

Changes in this version

+ var ConstraintSource_name = map[int32]string

+ var ConstraintSource_value = map[string]int32

+ var ConstraintState_name = map[int32]string

+ var ConstraintState_value = map[string]int32

+ type ConstraintSource int32

+ const ConstraintSource_CONSTRAINT_SOURCE_INFERRED

+ const ConstraintSource_CONSTRAINT_SOURCE_MANUAL_OVERRIDE

+ const ConstraintSource_CONSTRAINT_SOURCE_UNSPECIFIED

+ func (ConstraintSource) Descriptor() protoreflect.EnumDescriptor

+ func (ConstraintSource) EnumDescriptor() ([]byte, []int)

+ func (ConstraintSource) Type() protoreflect.EnumType

+ func (x ConstraintSource) Enum() *ConstraintSource

+ func (x ConstraintSource) Number() protoreflect.EnumNumber

+ func (x ConstraintSource) String() string

+ type ConstraintState int32

+ const ConstraintState_CONSTRAINT_STATE_AMBIGUOUS

+ const ConstraintState_CONSTRAINT_STATE_EMERGING

+ const ConstraintState_CONSTRAINT_STATE_IDENTIFIED

+ const ConstraintState_CONSTRAINT_STATE_UNCONSTRAINED

+ const ConstraintState_CONSTRAINT_STATE_UNKNOWN

+ const ConstraintState_CONSTRAINT_STATE_UNSPECIFIED

+ func (ConstraintState) Descriptor() protoreflect.EnumDescriptor

+ func (ConstraintState) EnumDescriptor() ([]byte, []int)

+ func (ConstraintState) Type() protoreflect.EnumType

+ func (x ConstraintState) Enum() *ConstraintState

+ func (x ConstraintState) Number() protoreflect.EnumNumber

+ func (x ConstraintState) String() string

type Diagnosis

+ CandidateConstraint string

+ ConstraintSource ConstraintSource

+ ConstraintState ConstraintState

+ SupportFreshness float64

+ UnsupportedCount int32

+ func (x *Diagnosis) GetCandidateConstraint() string

+ func (x *Diagnosis) GetConstraintSource() ConstraintSource

+ func (x *Diagnosis) GetConstraintState() ConstraintState

+ func (x *Diagnosis) GetSupportFreshness() float64

+ func (x *Diagnosis) GetUnsupportedCount() int32

v0.3.0

Mar 28, 2026

v0.2.2

Mar 28, 2026

v0.2.1

Mar 28, 2026

v0.2.0

Mar 27, 2026

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