Documentation ¶
Overview ¶
Package db is a generated GoMock package.
Index ¶
- type JobsStore
- type MockJobsStore
- func (m *MockJobsStore) Create(ctx context.Context, job jobs.Job) error
- func (m *MockJobsStore) Deschedule(ctx context.Context, id string) error
- func (m *MockJobsStore) EXPECT() *MockJobsStoreMockRecorder
- func (m *MockJobsStore) Get(ctx context.Context, id string) (jobs.Job, error)
- func (m *MockJobsStore) ScheduleNow(ctx context.Context, id string) error
- func (m *MockJobsStore) Search(ctx context.Context, limit, offset int, search string) ([]jobs.Job, error)
- func (m *MockJobsStore) Update(ctx context.Context, job jobs.Job) error
- type MockJobsStoreMockRecorder
- func (mr *MockJobsStoreMockRecorder) Create(ctx, job interface{}) *gomock.Call
- func (mr *MockJobsStoreMockRecorder) Deschedule(ctx, id interface{}) *gomock.Call
- func (mr *MockJobsStoreMockRecorder) Get(ctx, id interface{}) *gomock.Call
- func (mr *MockJobsStoreMockRecorder) ScheduleNow(ctx, id interface{}) *gomock.Call
- func (mr *MockJobsStoreMockRecorder) Search(ctx, limit, offset, search interface{}) *gomock.Call
- func (mr *MockJobsStoreMockRecorder) Update(ctx, job interface{}) *gomock.Call
- type Queue
- type QueueStatistics
- type Statistics
- type Store
- func (s *Store) Create(ctx context.Context, job jobs.Job) error
- func (s *Store) Deschedule(ctx context.Context, id string) error
- func (s *Store) Get(ctx context.Context, id string) (jobs.Job, error)
- func (s *Store) GetStatistics(ctx context.Context) (Statistics, error)
- func (s *Store) ScheduleNow(ctx context.Context, id string) error
- func (s *Store) Search(ctx context.Context, limit, offset int, search string) ([]jobs.Job, error)
- func (s *Store) Update(ctx context.Context, job jobs.Job) error
- type Tx
- func (tx *Tx) Create(ctx context.Context, job jobs.Job) error
- func (tx *Tx) Deschedule(ctx context.Context, id string) error
- func (tx *Tx) Get(ctx context.Context, id string) (jobs.Job, error)
- func (tx *Tx) ScheduleNow(ctx context.Context, id string) error
- func (tx *Tx) Search(ctx context.Context, limit, offset int, search string) ([]jobs.Job, error)
- func (tx *Tx) Update(ctx context.Context, job jobs.Job) error
- type TxStore
- type TxWrapper
- type WorkerStatistics
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobsStore ¶
type JobsStore interface { Update(ctx context.Context, job jobs.Job) error Create(ctx context.Context, job jobs.Job) error Deschedule(ctx context.Context, id string) error ScheduleNow(ctx context.Context, id string) error Search(ctx context.Context, limit, offset int, search string) ([]jobs.Job, error) Get(ctx context.Context, id string) (jobs.Job, error) GetStatistics(ctx context.Context) (Statistics, error) }
type MockJobsStore ¶
type MockJobsStore struct {
// contains filtered or unexported fields
}
MockJobsStore is a mock of JobsStore interface.
func NewMockJobsStore ¶
func NewMockJobsStore(ctrl *gomock.Controller) *MockJobsStore
NewMockJobsStore creates a new mock instance.
func (*MockJobsStore) Deschedule ¶
func (m *MockJobsStore) Deschedule(ctx context.Context, id string) error
Deschedule mocks base method.
func (*MockJobsStore) EXPECT ¶
func (m *MockJobsStore) EXPECT() *MockJobsStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockJobsStore) ScheduleNow ¶
func (m *MockJobsStore) ScheduleNow(ctx context.Context, id string) error
ScheduleNow mocks base method.
type MockJobsStoreMockRecorder ¶
type MockJobsStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockJobsStoreMockRecorder is the mock recorder for MockJobsStore.
func (*MockJobsStoreMockRecorder) Create ¶
func (mr *MockJobsStoreMockRecorder) Create(ctx, job interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*MockJobsStoreMockRecorder) Deschedule ¶
func (mr *MockJobsStoreMockRecorder) Deschedule(ctx, id interface{}) *gomock.Call
Deschedule indicates an expected call of Deschedule.
func (*MockJobsStoreMockRecorder) Get ¶
func (mr *MockJobsStoreMockRecorder) Get(ctx, id interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockJobsStoreMockRecorder) ScheduleNow ¶
func (mr *MockJobsStoreMockRecorder) ScheduleNow(ctx, id interface{}) *gomock.Call
ScheduleNow indicates an expected call of ScheduleNow.
func (*MockJobsStoreMockRecorder) Search ¶
func (mr *MockJobsStoreMockRecorder) Search(ctx, limit, offset, search interface{}) *gomock.Call
Search indicates an expected call of Search.
func (*MockJobsStoreMockRecorder) Update ¶
func (mr *MockJobsStoreMockRecorder) Update(ctx, job interface{}) *gomock.Call
Update indicates an expected call of Update.
type QueueStatistics ¶
type Statistics ¶
type Statistics struct {
Queues []QueueStatistics `json:"queues"`
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) Deschedule ¶
Deschedule the job
func (*Store) GetStatistics ¶
func (s *Store) GetStatistics(ctx context.Context) (Statistics, error)
func (*Store) ScheduleNow ¶
ScheduleNow the job
type Tx ¶
func (*Tx) Deschedule ¶
Deschedule the job
func (*Tx) ScheduleNow ¶
ScheduleNow the job
type TxStore ¶
type TxStore interface { Search(ctx context.Context, limit int, offset int, search string) ([]jobs.Job, error) Get(ctx context.Context, id string) (jobs.Job, error) Update(ctx context.Context, job jobs.Job) error Create(ctx context.Context, job jobs.Job) error Deschedule(ctx context.Context, id string) error ScheduleNow(ctx context.Context, id string) error Commit() error }
type TxWrapper ¶
type TxWrapper struct {
// contains filtered or unexported fields
}