tools

Documentation

Index

• Constants
• Variables
• func NewAdmin(serverconf conf.Config, flags *flag.FlagSet, cnf srv.ConfigLoader) (ipPort *srv.IpPort, server srv.Server, logger srv.LowLevelLogger, err error)
• func NewDriveWatch(logger srv.LowLevelLogger, metricsScope tally.Scope, serverconf conf.Config, ...) *driveWatch
• func Nodes(flags *flag.FlagSet, cnf srv.ConfigLoader)
• func ObjectInfo(flags *flag.FlagSet, cnf srv.ConfigLoader)
• func PrintDevs(devs []*ring.RingBuilderDevice)
• func ReconClient(flags *flag.FlagSet, cnf srv.ConfigLoader) bool
• func RingBuildCmd(flags *flag.FlagSet)
• type AutoAdmin
  • func (server *AutoAdmin) Background(flags *flag.FlagSet) chan struct{}
  • func (server *AutoAdmin) Finalize()
  • func (server *AutoAdmin) GetHandler(config conf.Config, metricsPrefix string) http.Handler
  • func (server *AutoAdmin) HealthcheckHandler(writer http.ResponseWriter, request *http.Request)
  • func (server *AutoAdmin) LogRequest(next http.Handler) http.Handler
  • func (a *AutoAdmin) Run()
  • func (a *AutoAdmin) RunForever()
  • func (server *AutoAdmin) Type() string
• type ReportData
• type ReportDevice

Constants

const AdminAccount = ".admin"

Variables

var DB_NAME = "andrewd.db"

var RING_LOCK_DIR = "ringUpdateLock"

Functions

func NewAdmin

func NewAdmin(serverconf conf.Config, flags *flag.FlagSet, cnf srv.ConfigLoader) (ipPort *srv.IpPort, server srv.Server, logger srv.LowLevelLogger, err error)

func NewDriveWatch

func NewDriveWatch(logger srv.LowLevelLogger,
	metricsScope tally.Scope, serverconf conf.Config, cnf srv.ConfigLoader, certFile, keyFile string) *driveWatch

func Nodes

func Nodes(flags *flag.FlagSet, cnf srv.ConfigLoader)

func ObjectInfo

func ObjectInfo(flags *flag.FlagSet, cnf srv.ConfigLoader)

func PrintDevs

func PrintDevs(devs []*ring.RingBuilderDevice)

func ReconClient

func ReconClient(flags *flag.FlagSet, cnf srv.ConfigLoader) bool

func RingBuildCmd

func RingBuildCmd(flags *flag.FlagSet)

Types

type AutoAdmin

type AutoAdmin struct {
	// contains filtered or unexported fields
}

func (*AutoAdmin) Background

func (server *AutoAdmin) Background(flags *flag.FlagSet) chan struct{}

func (*AutoAdmin) Finalize

func (server *AutoAdmin) Finalize()

func (*AutoAdmin) GetHandler

func (server *AutoAdmin) GetHandler(config conf.Config, metricsPrefix string) http.Handler

func (*AutoAdmin) HealthcheckHandler

func (server *AutoAdmin) HealthcheckHandler(writer http.ResponseWriter, request *http.Request)

func (*AutoAdmin) LogRequest

func (server *AutoAdmin) LogRequest(next http.Handler) http.Handler

func (*AutoAdmin) Run

func (a *AutoAdmin) Run()

func (*AutoAdmin) RunForever

func (a *AutoAdmin) RunForever()

func (*AutoAdmin) Type

func (server *AutoAdmin) Type() string

type ReportData

type ReportData struct {
	TotalDevices      int
	TotalWeight       float64
	LastSuccessfulRun time.Time
	UnmountedDevices  []ReportDevice
	LastRingZeroes    []ReportDevice
}

type ReportDevice

type ReportDevice struct {
	Ip         string
	Port       int
	Device     string
	Weight     float64
	Mounted    bool
	Reachable  bool
	LastUpdate time.Time
}