termite

type AnnotatingFS struct {
	pathfs.FileSystem
	// contains filtered or unexported fields
}

type Coordinator struct {
	Mux *http.ServeMux
	// contains filtered or unexported fields
}

type CoordinatorOptions struct {
	// Secret is the password for coordinator, workers and master
	// to authenticate.
	Secret []byte

	// Password should be passed in the kill/restart URLs to make
	// sure web scrapers don't randomly shutdown workers.
	WebPassword string
}

type CoordinatorService Coordinator

type CreateMirrorRequest struct {
	// Ids of connections to use for RPC
	RpcId        string
	RevRpcId     string
	ContentId    string
	RevContentId string

	// The writable root for the mirror.
	WritableRoot string

	// Max number of processes to reserve.
	MaxJobCount int
}

type CreateMirrorResponse struct {
	GrantedJobCount int
}

type Empty struct{}

type FuseFsStatus struct {
	Id    string
	Tasks []string
	Mem   string
}

type GetoptResult struct {
	Long  map[string]string
	Short map[byte]string
	Args  []string
}

type ListRequest struct {
	// Return changes after this time stamp.  Will halt if no
	// changes to report.
	Latest time.Time
}

type ListResponse struct {
	Registrations []Registration
	LastChange    time.Time
}

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

type LocalRule struct {
	Regexp      string
	Local       bool
	Recurse     bool
	SkipRefresh bool
	Debug       bool
}

type LogRequest struct {
	Whence int
	Off    int64
	Size   int64
}

type LogResponse struct {
	Data []byte
}

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

type MasterOptions struct {
	cba.StoreOptions

	WritableRoot string
	SourceRoot   string

	// How often a failed should be retried on another worker.
	RetryCount int

	// List of files that should not be served
	Excludes []string

	// If set, also serve files that have no group/other permissions
	ExposePrivate bool

	// Address of the coordinator.
	Coordinator string

	Secret []byte

	MaxJobs int

	// Turns on internal consistency checks. Expensive.
	Paranoia bool

	// On startup, fault-in all files.
	FetchAll bool

	// How often to do periodic householding work.
	Period time.Duration

	// How long to keep mirrors alive.
	KeepAlive time.Duration

	// Cache hashes in filesystem extended attributes.
	XAttrCache bool

	Uid int

	// The log file.  This is to ensure we don't export or hash
	// the log file.
	LogFile string

	// Path to the socket file.
	Socket string

	// Dump action graph data into this directory
	AnalysisDir string
}

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

type MirrorStatusRequest struct {
}

type MirrorStatusResponse struct {
	Root         string
	Granted      int
	Fses         []FuseFsStatus
	Accepting    bool
	WaitingTasks int
	IdleFses     int
	RpcTimings   []string
}

type Registration struct {
	Address        string
	Name           string
	Version        string
	HttpStatusPort int
}

type RegistrationRequest Registration

type RpcFs struct {
	pathfs.FileSystem
	// contains filtered or unexported fields
}

type ShutdownRequest struct {
	Restart bool
	Kill    bool
}

type ShutdownResponse struct {
}

type Timing struct {
	Name string
	Dt   float64
}

type UpdateRequest struct {
	Files []*attr.FileAttr
}

type UpdateResponse struct {
}

type User struct {
	Uid int
	Gid int
}

type WorkRequest struct {
	// Unique id of this request.
	TaskId int

	// Id of connection streaming stdin.
	StdinId string

	// TODO - don't abuse RPC message for transporting this.
	StdinConn io.ReadWriteCloser

	Debug  bool
	Binary string
	Argv   []string
	Env    []string
	Dir    string

	// Signal that a command ran locally.  Used for logging in the master.
	RanLocally bool

	// if TrackReads is set, the worker will return files read by the task.
	TrackReads bool

	// If set, must run on this worker. Used for debugging.
	Worker string

	// The following is used with TrackReads and can be injected from the Makefile.
	DeclaredDeps   []string
	DeclaredTarget string
}

type WorkResponse struct {
	Exit   syscall.WaitStatus
	Stderr string
	Stdout string

	Timings []Timing

	// Reaped files, if any
	*attr.FileSet

	// Task ids for which the fileset contains data.
	TaskIds []int

	// Files from the backing store that were read.
	Reads []string

	// Worker where this was processed.
	WorkerId string
}

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

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

type WorkerOptions struct {
	cba.StoreOptions

	// Address of the coordinator.
	Coordinator string

	// (starting) port to listen to.
	Port int

	// How many other ports try.
	PortRetry int

	Paranoia bool

	Secret  []byte
	TempDir string
	Jobs    int

	// If set, change user to this for running.
	User *User

	// How often to reap filesystems. If 1, use 1 FS per task.
	ReapCount int

	// Delay between contacting the coordinator for making reports.
	ReportInterval time.Duration
	LogFileName    string

	// If set, we restart once the heap usage passes this
	// threshold.
	HeapLimit uint64

	// How long to wait between the last task exit, and shutting
	// down the server.
	LameDuckPeriod time.Duration

	// full path to mkbox binary
	Mkbox string
}

type WorkerRegistration struct {
	Registration
	LastReported time.Time
}

type WorkerService Worker

type WorkerStatusRequest struct {
}

type WorkerStatusResponse struct {
	MirrorStatus []MirrorStatusResponse
	Version      string
	MaxJobCount  int
	Accepting    bool

	// In chronological order.
	CpuStats  []stats.CpuStat
	TotalCpu  stats.CpuStat
	DiskStats []stats.DiskStat

	PhaseNames  []string
	PhaseCounts []int
	MemStat     stats.MemStat
}

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