mock

type AuthPlugin struct {
	AuthenticateFunc func(*http.Request) (auth.Caller, error)
	AuthorizeFunc    func(c auth.Caller, op string, req proto.Request) error
}

type IDGenerator struct {
	UIDFunc func() (string, error)
	IDFunc  func() string
}

type JCStore struct {
	GetFunc func(string) (proto.JobChain, error)
}

type JLStore struct {
	CreateFunc  func(string, proto.JobLog) (proto.JobLog, error)
	GetFunc     func(string, string) (proto.JobLog, error)
	GetFullFunc func(string) ([]proto.JobLog, error)
}

type JRClient struct {
	NewJobChainFunc    func(proto.JobChain) error
	ResumeJobChainFunc func(proto.SuspendedJobChain) error
	StartRequestFunc   func(string) error
	StopRequestFunc    func(string) error
	RequestStatusFunc  func(string) (proto.JobChainStatus, error)
	SysStatRunningFunc func() ([]proto.JobStatus, error)
}

type JRStatus struct {
	RunningFunc func() ([]proto.JobStatus, error)
}

type Job struct {
	CreateErr       error
	SerializeBytes  []byte
	SerializeErr    error
	DeserializeErr  error
	RunReturn       job.Return
	RunErr          error
	RunFunc         func(jobData map[string]interface{}) (job.Return, error) // can use this instead of RunErr and RunFunc for more involved mocks
	StopErr         error
	StatusResp      string
	CreatedWithArgs map[string]interface{}
	SetJobArgs      map[string]interface{}
	IdResp          job.Id
}

type JobFactory struct {
	MockJobs map[string]*Job // keyed on type
	MakeErr  error

	Created map[string]*Job // keyed on name not id
	// contains filtered or unexported fields
}

type JobReaper struct {
	RunFunc      func()
	StopFunc     func()
	FinalizeFunc func()
}

type RMClient struct {
	CreateRequestFunc  func(string, map[string]interface{}) (string, error)
	GetRequestFunc     func(string) (proto.Request, error)
	StartRequestFunc   func(string) error
	FinishRequestFunc  func(string, byte) error
	StopRequestFunc    func(string) error
	SuspendRequestFunc func(string, proto.SuspendedJobChain) error
	RequestStatusFunc  func(string) (proto.RequestStatus, error)
	GetJobChainFunc    func(string) (proto.JobChain, error)
	GetJLFunc          func(string) ([]proto.JobLog, error)
	CreateJLFunc       func(string, proto.JobLog) error
	SysStatRunningFunc func() (proto.RunningStatus, error)
}

type RMStatus struct {
	RunningFunc func(status.Filter) (proto.RunningStatus, error)
}

type ReaperFactory struct {
	RunFunc      func()
	StopFunc     func()
	FinalizeFunc func()
}

type RequestManager struct {
	CreateFunc                func(proto.CreateRequestParams) (proto.Request, error)
	GetFunc                   func(string) (proto.Request, error)
	StartFunc                 func(string) error
	StopFunc                  func(string) error
	FinishFunc                func(string, proto.FinishRequestParams) error
	StatusFunc                func(string) (proto.RequestStatus, error)
	IncrementFinishedJobsFunc func(string) error
	SpecsFunc                 func() []proto.RequestSpec
	JobChainFunc              func(string) (proto.JobChain, error)
}

type Runner struct {
	RunReturn    runner.Return
	RunErr       error
	RunFunc      func(jobData map[string]interface{}) byte // can use this instead of RunErr and RunFunc for more involved mocks
	AddedJobData map[string]interface{}                    // Data to add to jobData.
	RunWg        *sync.WaitGroup                           // WaitGroup that gets released from when a runner starts running.
	RunBlock     chan struct{}                             // Channel that runner.Run() will block on, if defined.
	IgnoreStop   bool                                      // false: return immediately after Stop, true: keep running after Stop
	StatusResp   string
	// contains filtered or unexported fields
}

type RunnerFactory struct {
	RunnersToReturn map[string]*Runner // Keyed on job name.
	MakeErr         error
	MakeFunc        func(job proto.Job, requestId string, prevTryNo uint, triesToSkip uint, sequenceRetry uint) (runner.Runner, error)
}

type Traverser struct {
	RunErr     error
	StopErr    error
	StatusResp proto.JobChainStatus
	StatusErr  error
}

type TraverserFactory struct {
	MakeFunc        func(proto.JobChain) (chain.Traverser, error)
	MakeFromSJCFunc func(proto.SuspendedJobChain) (chain.Traverser, error)
}