pb

Documentation

Index

• Variables
• type QueueUsage
  • func (*QueueUsage) Descriptor() ([]byte, []int)
  • func (x *QueueUsage) GetInUseCPU() float64
  • func (x *QueueUsage) GetInUseMemoryMB() float64
  • func (x *QueueUsage) GetPendingCount() int64
  • func (x *QueueUsage) GetPendingDetails() []*QueueUsageItem
  • func (x *QueueUsage) GetProcessingCount() int64
  • func (x *QueueUsage) GetProcessingDetails() []*QueueUsageItem
  • func (x *QueueUsage) GetRemainingCPU() float64
  • func (x *QueueUsage) GetRemainingMemoryMB() float64
  • func (m *QueueUsage) MarshalJSON() ([]byte, error)
  • func (*QueueUsage) ProtoMessage()
  • func (x *QueueUsage) ProtoReflect() protoreflect.Message
  • func (x *QueueUsage) Reset()
  • func (x *QueueUsage) String() string
  • func (m *QueueUsage) UnmarshalJSON(b []byte) error
  • func (m *QueueUsage) UnmarshalURLValues(prefix string, values url.Values) error
  • func (this *QueueUsage) Validate() error
• type QueueUsageItem
  • func (*QueueUsageItem) Descriptor() ([]byte, []int)
  • func (x *QueueUsageItem) GetAddedTime() *timestamppb.Timestamp
  • func (x *QueueUsageItem) GetIndex() int64
  • func (x *QueueUsageItem) GetPipelineID() uint64
  • func (x *QueueUsageItem) GetPriority() int64
  • func (x *QueueUsageItem) GetRequestsCPU() float64
  • func (x *QueueUsageItem) GetRequestsMemoryMB() float64
  • func (m *QueueUsageItem) MarshalJSON() ([]byte, error)
  • func (*QueueUsageItem) ProtoMessage()
  • func (x *QueueUsageItem) ProtoReflect() protoreflect.Message
  • func (x *QueueUsageItem) Reset()
  • func (x *QueueUsageItem) String() string
  • func (m *QueueUsageItem) UnmarshalJSON(b []byte) error
  • func (m *QueueUsageItem) UnmarshalURLValues(prefix string, values url.Values) error
  • func (this *QueueUsageItem) Validate() error

Variables

var File_queue_usage_proto protoreflect.FileDescriptor

Types

type QueueUsage

type QueueUsage struct {
	InUseCPU          float64           `protobuf:"fixed64,1,opt,name=inUseCPU,proto3" json:"inUseCPU,omitempty"`
	InUseMemoryMB     float64           `protobuf:"fixed64,2,opt,name=inUseMemoryMB,proto3" json:"inUseMemoryMB,omitempty"`
	RemainingCPU      float64           `protobuf:"fixed64,3,opt,name=remainingCPU,proto3" json:"remainingCPU,omitempty"`
	RemainingMemoryMB float64           `protobuf:"fixed64,4,opt,name=remainingMemoryMB,proto3" json:"remainingMemoryMB,omitempty"`
	ProcessingCount   int64             `protobuf:"varint,5,opt,name=processingCount,proto3" json:"processingCount,omitempty"`
	PendingCount      int64             `protobuf:"varint,6,opt,name=pendingCount,proto3" json:"pendingCount,omitempty"`
	ProcessingDetails []*QueueUsageItem `protobuf:"bytes,7,rep,name=processingDetails,proto3" json:"processingDetails,omitempty"`
	PendingDetails    []*QueueUsageItem `protobuf:"bytes,8,rep,name=pendingDetails,proto3" json:"pendingDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueUsage) Descriptor

func (*QueueUsage) Descriptor() ([]byte, []int)

Deprecated: Use QueueUsage.ProtoReflect.Descriptor instead.

func (*QueueUsage) GetInUseCPU

func (x *QueueUsage) GetInUseCPU() float64

func (*QueueUsage) GetInUseMemoryMB

func (x *QueueUsage) GetInUseMemoryMB() float64

func (*QueueUsage) GetPendingCount

func (x *QueueUsage) GetPendingCount() int64

func (*QueueUsage) GetPendingDetails

func (x *QueueUsage) GetPendingDetails() []*QueueUsageItem

func (*QueueUsage) GetProcessingCount

func (x *QueueUsage) GetProcessingCount() int64

func (*QueueUsage) GetProcessingDetails

func (x *QueueUsage) GetProcessingDetails() []*QueueUsageItem

func (*QueueUsage) GetRemainingCPU

func (x *QueueUsage) GetRemainingCPU() float64

func (*QueueUsage) GetRemainingMemoryMB

func (x *QueueUsage) GetRemainingMemoryMB() float64

func (*QueueUsage) MarshalJSON

func (m *QueueUsage) MarshalJSON() ([]byte, error)

QueueUsage implement json.Marshaler.

func (*QueueUsage) ProtoMessage

func (*QueueUsage) ProtoMessage()

func (*QueueUsage) ProtoReflect

func (x *QueueUsage) ProtoReflect() protoreflect.Message

func (*QueueUsage) Reset

func (x *QueueUsage) Reset()

func (*QueueUsage) String

func (x *QueueUsage) String() string

func (*QueueUsage) UnmarshalJSON

func (m *QueueUsage) UnmarshalJSON(b []byte) error

QueueUsage implement json.Marshaler.

func (*QueueUsage) UnmarshalURLValues

func (m *QueueUsage) UnmarshalURLValues(prefix string, values url.Values) error

QueueUsage implement urlenc.URLValuesUnmarshaler.

func (*QueueUsage) Validate

func (this *QueueUsage) Validate() error

type QueueUsageItem

type QueueUsageItem struct {
	PipelineID       uint64                 `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	RequestsCPU      float64                `protobuf:"fixed64,2,opt,name=requestsCPU,proto3" json:"requestsCPU,omitempty"`
	RequestsMemoryMB float64                `protobuf:"fixed64,3,opt,name=requestsMemoryMB,proto3" json:"requestsMemoryMB,omitempty"`
	Index            int64                  `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
	Priority         int64                  `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	AddedTime        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=addedTime,proto3" json:"addedTime,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueUsageItem) Descriptor

func (*QueueUsageItem) Descriptor() ([]byte, []int)

Deprecated: Use QueueUsageItem.ProtoReflect.Descriptor instead.

func (*QueueUsageItem) GetAddedTime

func (x *QueueUsageItem) GetAddedTime() *timestamppb.Timestamp

func (*QueueUsageItem) GetIndex

func (x *QueueUsageItem) GetIndex() int64

func (*QueueUsageItem) GetPipelineID

func (x *QueueUsageItem) GetPipelineID() uint64

func (*QueueUsageItem) GetPriority

func (x *QueueUsageItem) GetPriority() int64

func (*QueueUsageItem) GetRequestsCPU

func (x *QueueUsageItem) GetRequestsCPU() float64

func (*QueueUsageItem) GetRequestsMemoryMB

func (x *QueueUsageItem) GetRequestsMemoryMB() float64

func (*QueueUsageItem) MarshalJSON

func (m *QueueUsageItem) MarshalJSON() ([]byte, error)

QueueUsageItem implement json.Marshaler.

func (*QueueUsageItem) ProtoMessage

func (*QueueUsageItem) ProtoMessage()

func (*QueueUsageItem) ProtoReflect

func (x *QueueUsageItem) ProtoReflect() protoreflect.Message

func (*QueueUsageItem) Reset

func (x *QueueUsageItem) Reset()

func (*QueueUsageItem) String

func (x *QueueUsageItem) String() string

func (*QueueUsageItem) UnmarshalJSON

func (m *QueueUsageItem) UnmarshalJSON(b []byte) error

QueueUsageItem implement json.Marshaler.

func (*QueueUsageItem) UnmarshalURLValues

func (m *QueueUsageItem) UnmarshalURLValues(prefix string, values url.Values) error

QueueUsageItem implement urlenc.URLValuesUnmarshaler.

func (*QueueUsageItem) Validate

func (this *QueueUsageItem) Validate() error