Versions in this module Expand all Collapse all v0 v0.23.2 Feb 12, 2024 Changes in this version + const BulkNormalPri + const HighPri + const LockingNormalPri + const LockingUserHighPri + const LowPri + const NormalPri + const OneAboveHighPri + const TTLLowPri + const UserHighPri + const UserLowPri + var ErrIntOverflowAdmissionStats = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowIoThreshold = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAdmissionStats = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthIoThreshold = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupAdmissionStats = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupIoThreshold = fmt.Errorf("proto: unexpected end of group") + var TestingReverseWorkPriorityDict map[string]WorkPriority + var WorkPriorityDict = map[WorkPriority]string + type AdmissionWorkQueueStats struct + DeadlineExceeded bool + QueueKind string + WaitDurationNanos time.Duration + WorkPriority string + func (*AdmissionWorkQueueStats) Descriptor() ([]byte, []int) + func (*AdmissionWorkQueueStats) ProtoMessage() + func (m *AdmissionWorkQueueStats) Marshal() (dAtA []byte, err error) + func (m *AdmissionWorkQueueStats) MarshalTo(dAtA []byte) (int, error) + func (m *AdmissionWorkQueueStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AdmissionWorkQueueStats) Reset() + func (m *AdmissionWorkQueueStats) Size() (n int) + func (m *AdmissionWorkQueueStats) String() string + func (m *AdmissionWorkQueueStats) Unmarshal(dAtA []byte) error + func (m *AdmissionWorkQueueStats) XXX_DiscardUnknown() + func (m *AdmissionWorkQueueStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AdmissionWorkQueueStats) XXX_Merge(src proto.Message) + func (m *AdmissionWorkQueueStats) XXX_Size() int + func (m *AdmissionWorkQueueStats) XXX_Unmarshal(b []byte) error + type IOThreshold struct + L0MinimumSizePerSubLevel int64 + L0NumFiles int64 + L0NumFilesThreshold int64 + L0NumSubLevels int64 + L0NumSubLevelsThreshold int64 + L0Size int64 + func (*IOThreshold) Descriptor() ([]byte, []int) + func (*IOThreshold) ProtoMessage() + func (iot *IOThreshold) SafeFormat(s interfaces.SafePrinter, _ rune) + func (iot *IOThreshold) Score() (float64, bool) + func (iot *IOThreshold) String() string + func (m *IOThreshold) Marshal() (dAtA []byte, err error) + func (m *IOThreshold) MarshalTo(dAtA []byte) (int, error) + func (m *IOThreshold) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IOThreshold) Reset() + func (m *IOThreshold) Size() (n int) + func (m *IOThreshold) Unmarshal(dAtA []byte) error + func (m *IOThreshold) XXX_DiscardUnknown() + func (m *IOThreshold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IOThreshold) XXX_Merge(src proto.Message) + func (m *IOThreshold) XXX_Size() int + func (m *IOThreshold) XXX_Unmarshal(b []byte) error + type WorkClass int8 + const ElasticWorkClass + const NumWorkClasses + const RegularWorkClass + func WorkClassFromPri(pri WorkPriority) WorkClass + func (w WorkClass) SafeFormat(p redact.SafePrinter, verb rune) + func (w WorkClass) String() string + type WorkPriority int8 + func AdjustedPriorityWhenHoldingLocks(pri WorkPriority) WorkPriority + func (w WorkPriority) SafeFormat(p redact.SafePrinter, verb rune) + func (w WorkPriority) String() string