internal

Documentation

Index

• Constants
• type ActivePlot
  • func (ap *ActivePlot) CheckSpace() bool
  • func (ap *ActivePlot) RunPlot()
  • func (ap *ActivePlot) String(showLog bool) string
• type Client
  • func (client *Client) ProcessLoop(host string, port int)
• type Config
• type Msg
• type PlotConfig
  • func (pc *PlotConfig) ProcessConfig()
• type Server
  • func (server *Server) ProcessLoop(configPath string, port int)
  • func (server *Server) ServeHTTP(resp http.ResponseWriter, req *http.Request)

Constants

const (
	PlotRunning = iota
	PlotError
	PlotFinished
)

const KB = uint64(1024)

Types

type ActivePlot

type ActivePlot struct {
	PlotId      int64
	StartTime   time.Time
	EndTime     time.Time
	TargetDir   string
	PlotDir     string
	Fingerprint string

	Phase string
	Tail  []string
	State int

	Id string
	// contains filtered or unexported fields
}

func (*ActivePlot) CheckSpace

func (ap *ActivePlot) CheckSpace() bool

func (*ActivePlot) RunPlot

func (ap *ActivePlot) RunPlot()

func (*ActivePlot) String

func (ap *ActivePlot) String(showLog bool) string

type Client

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

func (*Client) ProcessLoop

func (client *Client) ProcessLoop(host string, port int)

type Config

type Config struct {
	TargetDirectory       []string
	TempDirectory         []string
	NumberOfParallelPlots int
	Fingerprint           string
	StaggeringDelay       int
	ShowPlotLog           bool
}

type Msg

type Msg struct {
	Actives    []*ActivePlot
	Archived   []*ActivePlot
	TempDirs   map[string]uint64
	TargetDirs map[string]uint64
}

type PlotConfig

type PlotConfig struct {
	ConfigPath    string
	CurrentConfig *Config
	LastMod       time.Time
	Lock          sync.RWMutex
}

func (*PlotConfig) ProcessConfig

func (pc *PlotConfig) ProcessConfig()

type Server

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

func (*Server) ProcessLoop

func (server *Server) ProcessLoop(configPath string, port int)

func (*Server) ServeHTTP

func (server *Server) ServeHTTP(resp http.ResponseWriter, req *http.Request)