Documentation
¶
Index ¶
- func MockBasicGet(rw http.ResponseWriter, req *http.Request)
- func MockBasicPrintHeaders(rw http.ResponseWriter, req *http.Request)
- func MockBasicUrlParams(rw http.ResponseWriter, req *http.Request)
- func MockBasicWait(rw http.ResponseWriter, req *http.Request)
- func NewDiskJob(j job.Job) job.Job
- func NewFileJob(j job.Job) job.Job
- type MockHttpServer
- type MockJob
- type MockProvider
- func (m *MockProvider) Close() error
- func (m *MockProvider) ConfigStruct() interface{}
- func (m *MockProvider) ConfirmJob(j job.Job) error
- func (m *MockProvider) Init(i interface{}) error
- func (m *MockProvider) Name() string
- func (m *MockProvider) RequestWork(numJobs int, j chan job.Job) error
- func (m *MockProvider) Target() float64
- func (m *MockProvider) WaitTime(target float64) time.Duration
- type MockWorker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MockBasicGet ¶
func MockBasicGet(rw http.ResponseWriter, req *http.Request)
MockBasicGet is an http.handlerfunc that sends back hello world
func MockBasicPrintHeaders ¶
func MockBasicPrintHeaders(rw http.ResponseWriter, req *http.Request)
MockBasicPrintHeaders
func MockBasicUrlParams ¶
func MockBasicUrlParams(rw http.ResponseWriter, req *http.Request)
MockBasicUrlParams
func MockBasicWait ¶
func MockBasicWait(rw http.ResponseWriter, req *http.Request)
MockBasicWait this handler waits indeffinitly
func NewDiskJob ¶
NewDiskJob wrap a job in a disk job to be written to disk
Types ¶
type MockHttpServer ¶
type MockHttpServer struct {
// contains filtered or unexported fields
}
MockHttpServer provides an http server for testing
func NewMockServer ¶
func NewMockServer(f http.HandlerFunc) *MockHttpServer
NewBasicGetServer creates a testing http server for basic get commands
type MockJob ¶
type MockJob struct {
// contains filtered or unexported fields
}
MockJob is a job which exicutes `echo hello` as a cli command
func NewBasicGetHttpJob ¶
NewMockHttpJob create a new job to be used in testing the worker/http package
func NewBasicWithHeadersJob ¶
NewBasicWithHeadersJob
func (*MockJob) JobConfirmer ¶
func (m *MockJob) JobConfirmer() job.JobConfirmer
JobConfirmer return something that is able to confirm a job has been completed
type MockProvider ¶
type MockProvider struct {
}
MockProvider is a testing job provider
func (*MockProvider) ConfigStruct ¶
func (m *MockProvider) ConfigStruct() interface{}
ConfigStruct return the mock provider config struct
func (*MockProvider) ConfirmJob ¶
func (m *MockProvider) ConfirmJob(j job.Job) error
ConfirmJob confirm that the job has been completed
func (*MockProvider) Init ¶
func (m *MockProvider) Init(i interface{}) error
Init initialize the MockProvider
func (*MockProvider) RequestWork ¶
func (m *MockProvider) RequestWork(numJobs int, j chan job.Job) error
RequestWork make fake request for work, launch provideWork
Source Files