lustreserver

package
v0.0.0-...-59d166e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 21, 2016 License: GPL-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package lustreserver exposes oss and mds performance counters over rpc this includes for OSS number of read and write requests and number of bytes written and read for MDT it delivers total number of requests only (to be extended and precised down to single requests) TODO

 fix mds for differences
 offer difference + absolute mode for OST as for MDS
	offer inquire rpc function if mdt or ost

Index

Constants

View Source
const Procdir = "/proc/fs/lustre/"

path to lustre proc (used for testing, should start with / for production!!)

Variables

View Source
var (
	IsOST bool
	IsMDT bool
)

flags to show status

Functions

func MakeMdsRPC

func MakeMdsRPC()

MakeMdsRPC registers RPC server for MDS

func MakeOssRPC

func MakeOssRPC()

MakeOssRPC registers RPC server for OSS

func MakeServerRPC

func MakeServerRPC()

MakeServerRPC register RPC server for inquiries like OST/MDT

func StartServer

func StartServer()

StartServer starts the HTTP RPC server

Types

type MdsRpcT

type MdsRpcT int64

MdsRpcT type

func (*MdsRpcT) GetValues

func (*MdsRpcT) GetValues(arg int, result *MdsValues) error

GetValues RPC call for OST, return all performance counters

func (*MdsRpcT) GetValuesDiff

func (*MdsRpcT) GetValuesDiff(init bool, result *MdsValues) error

GetValuesDiff RPC call for MDS, return counters which are not zero

type MdsValues

type MdsValues struct {
	Timestamp int32 // will be filled by aggregator and is used to transfer difference
	Delta     int32 // time difference
	MdsTotal  map[string]int64
	NidValues map[string]map[string]int64
}

MdsValues contains maps with total values for each MDT and for values each nid for each MDT

type OssRpcT

type OssRpcT int

OssRpcT type

func (*OssRpcT) GetRandomValues

func (*OssRpcT) GetRandomValues(init bool, result *OstValues) error

GetRandomValues RPC call for OST, returns random values for testing

func (*OssRpcT) GetValuesDiff

func (*OssRpcT) GetValuesDiff(init bool, result *OstValues) error

GetValuesDiff RPC call for OST, return all performance counters which are not zero FIXME no absolute version yet

type OstStats

type OstStats struct {
	WRqs, WBs, RRqs, RBs int64
}

OstStats gives write and read requests and bytes read and written

type OstValues

type OstValues struct {
	Timestamp int32 // will be filled by aggregator
	Delta     int32 // time difference
	OstTotal  map[string]OstStats
	NidValues map[string]map[string]OstStats
}

OstValues contains maps with total values for each OST and for values for each nid for each OST

type ServerRpcT

type ServerRpcT int

ServerRpcT type, for inquiries lile server type

func (*ServerRpcT) IsMDT

func (*ServerRpcT) IsMDT(in int, result *bool) error

IsMDT RPC call returns if this is a MDT

func (*ServerRpcT) IsOST

func (*ServerRpcT) IsOST(in int, result *bool) error

IsOST RPC call returns if this is a OST

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL