Documentation
¶
Index ¶
Constants ¶
View Source
const ( // SubmitterStorage Requests SubmitReq = iota SubmitFileReq StatusReq InfoReq ListReq ListWithPriorityReq DeleteReq DescribeReq // WorkerStorage requests. Note that Next is not implemented via a request. Instead the next task is read from the scheduler channel RetrieveFileReq SuccessReq ErrorReq RequeueReq FatalReq HeartbeatReq // ActivateReq marks a task as active ActivateReq )
The request codes
Variables ¶
View Source
var ( ErrNilScheduler = errors.New("illegal nil *scheduler") ErrClosed = errors.New("the scheduler is closed") )
Errors
Functions ¶
Types ¶
type Config ¶
type Config struct {
*ir.Config
Fs fs.Interface // the fs storage on which files and directories in the manifest live
}
Config describes the configuration options we allow a user to set on an inmem instance.
func DefaultConfig ¶
func DefaultConfig() *Config
DefaultConfig returns a new client configuration initialised with the default values.
func SetDefaultConfig ¶
SetDefaultConfig sets the default configuration to c and returns the old default configuration. This change will be reflected in future calls to DefaultConfig.
Source Files
Click to show internal directories.
Click to hide internal directories.