Documentation ¶
Index ¶
- func AssignRequest()
- func BytesIn(val int64)
- func BytesOut(val int64)
- func ConnectionClose()
- func ConnectionOpen()
- func DeleteRequest()
- func ReadRequest()
- func RequestClose()
- func RequestOpen()
- func WriteRequest()
- type Channels
- type DiskStatus
- type DurationCounter
- type MemStatus
- type RoundRobinCounter
- type ServerStats
- type TimedValue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssignRequest ¶
func AssignRequest()
func ConnectionClose ¶
func ConnectionClose()
func ConnectionOpen ¶
func ConnectionOpen()
func DeleteRequest ¶
func DeleteRequest()
func ReadRequest ¶
func ReadRequest()
func RequestClose ¶
func RequestClose()
func RequestOpen ¶
func RequestOpen()
func WriteRequest ¶
func WriteRequest()
Types ¶
type Channels ¶
type Channels struct { Connections chan *TimedValue Requests chan *TimedValue AssignRequests chan *TimedValue ReadRequests chan *TimedValue WriteRequests chan *TimedValue DeleteRequests chan *TimedValue BytesIn chan *TimedValue BytesOut chan *TimedValue }
var (
Chan *Channels
)
type DiskStatus ¶
func NewDiskStatus ¶
func NewDiskStatus(path string) (disk *DiskStatus)
type DurationCounter ¶
type DurationCounter struct { MinuteCounter *RoundRobinCounter HourCounter *RoundRobinCounter DayCounter *RoundRobinCounter WeekCounter *RoundRobinCounter }
func NewDurationCounter ¶
func NewDurationCounter() *DurationCounter
func (*DurationCounter) Add ¶
func (sc *DurationCounter) Add(tv *TimedValue)
Add is for cumulative counts
type MemStatus ¶
type RoundRobinCounter ¶
func NewRoundRobinCounter ¶
func NewRoundRobinCounter(slots int) *RoundRobinCounter
func (*RoundRobinCounter) Add ¶
func (rrc *RoundRobinCounter) Add(index int, val int64)
func (*RoundRobinCounter) Count ¶
func (rrc *RoundRobinCounter) Count() (cnt int64)
func (*RoundRobinCounter) Max ¶
func (rrc *RoundRobinCounter) Max() (max int64)
func (*RoundRobinCounter) Sum ¶
func (rrc *RoundRobinCounter) Sum() (sum int64)
func (*RoundRobinCounter) ToList ¶
func (rrc *RoundRobinCounter) ToList() (ret []int64)
type ServerStats ¶
type ServerStats struct { Requests *DurationCounter Connections *DurationCounter AssignRequests *DurationCounter ReadRequests *DurationCounter WriteRequests *DurationCounter DeleteRequests *DurationCounter BytesIn *DurationCounter BytesOut *DurationCounter }
func NewServerStats ¶
func NewServerStats() *ServerStats
func (*ServerStats) Start ¶
func (ss *ServerStats) Start()
type TimedValue ¶
type TimedValue struct {
// contains filtered or unexported fields
}
func NewTimedValue ¶
func NewTimedValue(t time.Time, val int64) *TimedValue
Click to show internal directories.
Click to hide internal directories.