Documentation ¶
Index ¶
- Variables
- type GfSpLimit
- func (m *GfSpLimit) Add(x rcmgr.Limit)
- func (*GfSpLimit) Descriptor() ([]byte, []int)
- func (m *GfSpLimit) Equal(x rcmgr.Limit) bool
- func (m *GfSpLimit) GetConnLimit(direction rcmgr.Direction) int
- func (m *GfSpLimit) GetConnTotalLimit() int
- func (m *GfSpLimit) GetConns() int32
- func (m *GfSpLimit) GetConnsInbound() int32
- func (m *GfSpLimit) GetConnsOutbound() int32
- func (m *GfSpLimit) GetFDLimit() int
- func (m *GfSpLimit) GetFd() int32
- func (m *GfSpLimit) GetMemory() int64
- func (m *GfSpLimit) GetMemoryLimit() int64
- func (m *GfSpLimit) GetTaskLimit(priority rcmgr.ReserveTaskPriority) int
- func (m *GfSpLimit) GetTaskTotalLimit() int
- func (m *GfSpLimit) GetTasks() int32
- func (m *GfSpLimit) GetTasksHighPriority() int32
- func (m *GfSpLimit) GetTasksLowPriority() int32
- func (m *GfSpLimit) GetTasksMediumPriority() int32
- func (m *GfSpLimit) Marshal() (dAtA []byte, err error)
- func (m *GfSpLimit) MarshalTo(dAtA []byte) (int, error)
- func (m *GfSpLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *GfSpLimit) NotLess(x rcmgr.Limit) bool
- func (*GfSpLimit) ProtoMessage()
- func (m *GfSpLimit) Reset()
- func (m *GfSpLimit) ScopeStat() *rcmgr.ScopeStat
- func (m *GfSpLimit) Size() (n int)
- func (m *GfSpLimit) String() string
- func (m *GfSpLimit) Sub(x rcmgr.Limit) bool
- func (m *GfSpLimit) Unmarshal(dAtA []byte) error
- func (m *GfSpLimit) XXX_DiscardUnknown()
- func (m *GfSpLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GfSpLimit) XXX_Merge(src proto.Message)
- func (m *GfSpLimit) XXX_Size() int
- func (m *GfSpLimit) XXX_Unmarshal(b []byte) error
- type GfSpLimiter
- func (*GfSpLimiter) Descriptor() ([]byte, []int)
- func (m *GfSpLimiter) GetServiceLimit() map[string]*GfSpLimit
- func (m *GfSpLimiter) GetServiceLimits(svc string) rcmgr.Limit
- func (m *GfSpLimiter) GetSystem() *GfSpLimit
- func (m *GfSpLimiter) GetSystemLimits() rcmgr.Limit
- func (m *GfSpLimiter) GetTransient() *GfSpLimit
- func (m *GfSpLimiter) GetTransientLimits() rcmgr.Limit
- func (m *GfSpLimiter) Marshal() (dAtA []byte, err error)
- func (m *GfSpLimiter) MarshalTo(dAtA []byte) (int, error)
- func (m *GfSpLimiter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GfSpLimiter) ProtoMessage()
- func (m *GfSpLimiter) Reset()
- func (m *GfSpLimiter) Size() (n int)
- func (m *GfSpLimiter) String() string
- func (m *GfSpLimiter) Unmarshal(dAtA []byte) error
- func (m *GfSpLimiter) XXX_DiscardUnknown()
- func (m *GfSpLimiter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GfSpLimiter) XXX_Merge(src proto.Message)
- func (m *GfSpLimiter) XXX_Size() int
- func (m *GfSpLimiter) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type GfSpLimit ¶
type GfSpLimit struct { Memory int64 `protobuf:"varint,1,opt,name=memory,proto3" json:"memory,omitempty"` Tasks int32 `protobuf:"varint,2,opt,name=tasks,proto3" json:"tasks,omitempty"` TasksHighPriority int32 `protobuf:"varint,3,opt,name=tasks_high_priority,json=tasksHighPriority,proto3" json:"tasks_high_priority,omitempty"` TasksMediumPriority int32 `protobuf:"varint,4,opt,name=tasks_medium_priority,json=tasksMediumPriority,proto3" json:"tasks_medium_priority,omitempty"` TasksLowPriority int32 `protobuf:"varint,5,opt,name=tasks_low_priority,json=tasksLowPriority,proto3" json:"tasks_low_priority,omitempty"` Fd int32 `protobuf:"varint,6,opt,name=fd,proto3" json:"fd,omitempty"` Conns int32 `protobuf:"varint,7,opt,name=conns,proto3" json:"conns,omitempty"` ConnsInbound int32 `protobuf:"varint,8,opt,name=conns_inbound,json=connsInbound,proto3" json:"conns_inbound,omitempty"` ConnsOutbound int32 `protobuf:"varint,9,opt,name=conns_outbound,json=connsOutbound,proto3" json:"conns_outbound,omitempty"` }
func (*GfSpLimit) Descriptor ¶
func (*GfSpLimit) GetConnTotalLimit ¶
func (*GfSpLimit) GetConnsInbound ¶
func (*GfSpLimit) GetConnsOutbound ¶
func (*GfSpLimit) GetFDLimit ¶
func (*GfSpLimit) GetMemoryLimit ¶
func (*GfSpLimit) GetTaskLimit ¶
func (m *GfSpLimit) GetTaskLimit(priority rcmgr.ReserveTaskPriority) int
func (*GfSpLimit) GetTaskTotalLimit ¶
func (*GfSpLimit) GetTasksHighPriority ¶
func (*GfSpLimit) GetTasksLowPriority ¶
func (*GfSpLimit) GetTasksMediumPriority ¶
func (*GfSpLimit) MarshalToSizedBuffer ¶
func (*GfSpLimit) ProtoMessage ¶
func (*GfSpLimit) ProtoMessage()
func (*GfSpLimit) XXX_DiscardUnknown ¶
func (m *GfSpLimit) XXX_DiscardUnknown()
func (*GfSpLimit) XXX_Marshal ¶
func (*GfSpLimit) XXX_Unmarshal ¶
type GfSpLimiter ¶
type GfSpLimiter struct { System *GfSpLimit `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"` Transient *GfSpLimit `protobuf:"bytes,2,opt,name=transient,proto3" json:"transient,omitempty"` ServiceLimit map[string]*GfSpLimit `` /* 185-byte string literal not displayed */ }
func (*GfSpLimiter) Descriptor ¶
func (*GfSpLimiter) Descriptor() ([]byte, []int)
func (*GfSpLimiter) GetServiceLimit ¶
func (m *GfSpLimiter) GetServiceLimit() map[string]*GfSpLimit
func (*GfSpLimiter) GetServiceLimits ¶
func (m *GfSpLimiter) GetServiceLimits(svc string) rcmgr.Limit
func (*GfSpLimiter) GetSystem ¶
func (m *GfSpLimiter) GetSystem() *GfSpLimit
func (*GfSpLimiter) GetSystemLimits ¶
func (m *GfSpLimiter) GetSystemLimits() rcmgr.Limit
func (*GfSpLimiter) GetTransient ¶
func (m *GfSpLimiter) GetTransient() *GfSpLimit
func (*GfSpLimiter) GetTransientLimits ¶
func (m *GfSpLimiter) GetTransientLimits() rcmgr.Limit
func (*GfSpLimiter) Marshal ¶
func (m *GfSpLimiter) Marshal() (dAtA []byte, err error)
func (*GfSpLimiter) MarshalToSizedBuffer ¶
func (m *GfSpLimiter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GfSpLimiter) ProtoMessage ¶
func (*GfSpLimiter) ProtoMessage()
func (*GfSpLimiter) Reset ¶
func (m *GfSpLimiter) Reset()
func (*GfSpLimiter) Size ¶
func (m *GfSpLimiter) Size() (n int)
func (*GfSpLimiter) String ¶
func (m *GfSpLimiter) String() string
func (*GfSpLimiter) Unmarshal ¶
func (m *GfSpLimiter) Unmarshal(dAtA []byte) error
func (*GfSpLimiter) XXX_DiscardUnknown ¶
func (m *GfSpLimiter) XXX_DiscardUnknown()
func (*GfSpLimiter) XXX_Marshal ¶
func (m *GfSpLimiter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GfSpLimiter) XXX_Merge ¶
func (m *GfSpLimiter) XXX_Merge(src proto.Message)
func (*GfSpLimiter) XXX_Size ¶
func (m *GfSpLimiter) XXX_Size() int
func (*GfSpLimiter) XXX_Unmarshal ¶
func (m *GfSpLimiter) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.