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(string, proto.JobChain) (*url.URL, error)
	ResumeJobChainFunc func(string, proto.SuspendedJobChain) (*url.URL, error)
	StartRequestFunc   func(string, string) error
	StopRequestFunc    func(string, string) error
	RequestStatusFunc  func(string, string) (proto.JobChainStatus, error)
	SysStatRunningFunc func(string) ([]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, time.Time) 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)
	RequestListFunc    func() ([]proto.RequestSpec, 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)
	GetWithJCFunc             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 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   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)
}