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 IDGeneratorFactory struct {
	MakeFunc func() id.Generator
}

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(string, proto.JobChain) (*url.URL, error)
	ResumeJobChainFunc func(string, proto.SuspendedJobChain) (*url.URL, error)
	StartRequestFunc   func(string, string) error
	StopRequestFunc    func(string, string) error
	RunningFunc        func(string, proto.StatusFilter) ([]proto.JobStatus, error)
}

type JRStatus struct {
	RunningFunc func(proto.StatusFilter) ([]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
	StopFunc        func() error
	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)
	FindRequestsFunc   func(proto.RequestFilter) ([]proto.Request, error)
	StartRequestFunc   func(string) error
	FinishRequestFunc  func(proto.FinishRequest) error
	StopRequestFunc    func(string) error
	SuspendRequestFunc func(string, proto.SuspendedJobChain) error
	GetJobChainFunc    func(string) (proto.JobChain, error)
	GetJLFunc          func(string) ([]proto.JobLog, error)
	CreateJLFunc       func(string, proto.JobLog) error
	RunningFunc        func(proto.StatusFilter) (proto.RunningStatus, error)
	RequestListFunc    func() ([]proto.RequestSpec, error)
	UpdateProgressFunc func(proto.RequestProgress) error
}

type RMStatus struct {
	RunningFunc        func(proto.StatusFilter) (proto.RunningStatus, error)
	UpdateProgressFunc func(proto.RequestProgress) error
}

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

type RequestManager struct {
	CreateFunc      func(proto.CreateRequest) (proto.Request, error)
	GetFunc         func(string) (proto.Request, error)
	GetWithJCFunc   func(string) (proto.Request, error)
	StartFunc       func(string) error
	StopFunc        func(string) error
	FinishFunc      func(string, proto.FinishRequest) error
	FailPendingFunc func(string) error
	SpecsFunc       func() []proto.RequestSpec
	JobChainFunc    func(string) (proto.JobChain, error)
	FindFunc        func(proto.RequestFilter) ([]proto.Request, error)
}

type RequestResumer struct {
	ResumeAllFunc func()
	CleanupFunc   func()
	ResumeFunc    func(string) error
	SuspendFunc   func(proto.SuspendedJobChain) 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   runner.Status
	// 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, prevTries uint, totalTries uint) (runner.Runner, error)
}

type RunnerRepo struct {
	SetFunc    func(jobId string, runner runner.Runner)
	GetFunc    func(jobId string) runner.Runner
	RemoveFunc func(jobId string)
	ItemsFunc  func() (map[string]runner.Runner, error)
	CountFunc  func() int
}

type Traverser struct {
	RunErr    error
	StopErr   error
	StatusErr error
	JobStatus []proto.JobStatus
}

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