Documentation ¶
Index ¶
- type ConnectionsManager
- type FeedsManagerClient
- func (_m *FeedsManagerClient) ApprovedJob(ctx context.Context, in *proto.ApprovedJobRequest) (*proto.ApprovedJobResponse, error)
- func (_m *FeedsManagerClient) CancelledJob(ctx context.Context, in *proto.CancelledJobRequest) (*proto.CancelledJobResponse, error)
- func (_m *FeedsManagerClient) Healthcheck(ctx context.Context, in *proto.HealthcheckRequest) (*proto.HealthcheckResponse, error)
- func (_m *FeedsManagerClient) RejectedJob(ctx context.Context, in *proto.RejectedJobRequest) (*proto.RejectedJobResponse, error)
- func (_m *FeedsManagerClient) UpdateNode(ctx context.Context, in *proto.UpdateNodeRequest) (*proto.UpdateNodeResponse, error)
- type ORM
- func (_m *ORM) ApproveSpec(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt) error
- func (_m *ORM) CancelSpec(id int64, qopts ...pg.QOpt) error
- func (_m *ORM) CountJobProposals() (int64, error)
- func (_m *ORM) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
- func (_m *ORM) CountManagers() (int64, error)
- func (_m *ORM) CreateBatchChainConfig(cfgs []feeds.ChainConfig, qopts ...pg.QOpt) ([]int64, error)
- func (_m *ORM) CreateChainConfig(cfg feeds.ChainConfig, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
- func (_m *ORM) CreateManager(ms *feeds.FeedsManager, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) CreateSpec(spec feeds.JobProposalSpec, qopts ...pg.QOpt) (int64, error)
- func (_m *ORM) DeleteChainConfig(id int64) (int64, error)
- func (_m *ORM) DeleteProposal(id int64, qopts ...pg.QOpt) error
- func (_m *ORM) EXPECT() *ORM_Expecter
- func (_m *ORM) ExistsSpecByJobProposalIDAndVersion(jpID int64, version int32, qopts ...pg.QOpt) (bool, error)
- func (_m *ORM) GetApprovedSpec(jpID int64, qopts ...pg.QOpt) (*feeds.JobProposalSpec, error)
- func (_m *ORM) GetChainConfig(id int64) (*feeds.ChainConfig, error)
- func (_m *ORM) GetJobProposal(id int64, qopts ...pg.QOpt) (*feeds.JobProposal, error)
- func (_m *ORM) GetJobProposalByRemoteUUID(_a0 uuid.UUID) (*feeds.JobProposal, error)
- func (_m *ORM) GetLatestSpec(jpID int64) (*feeds.JobProposalSpec, error)
- func (_m *ORM) GetManager(id int64) (*feeds.FeedsManager, error)
- func (_m *ORM) GetSpec(id int64, qopts ...pg.QOpt) (*feeds.JobProposalSpec, error)
- func (_m *ORM) IsJobManaged(jobID int64, qopts ...pg.QOpt) (bool, error)
- func (_m *ORM) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
- func (_m *ORM) ListJobProposals() ([]feeds.JobProposal, error)
- func (_m *ORM) ListJobProposalsByManagersIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposal, error)
- func (_m *ORM) ListManagers() ([]feeds.FeedsManager, error)
- func (_m *ORM) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
- func (_m *ORM) ListSpecsByJobProposalIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposalSpec, error)
- func (_m *ORM) RejectSpec(id int64, qopts ...pg.QOpt) error
- func (_m *ORM) RevokeSpec(id int64, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateChainConfig(cfg feeds.ChainConfig) (int64, error)
- func (_m *ORM) UpdateJobProposalStatus(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateManager(mgr feeds.FeedsManager, qopts ...pg.QOpt) error
- func (_m *ORM) UpdateSpecDefinition(id int64, spec string, qopts ...pg.QOpt) error
- func (_m *ORM) UpsertJobProposal(jp *feeds.JobProposal, qopts ...pg.QOpt) (int64, error)
- type ORM_ApproveSpec_Call
- func (_c *ORM_ApproveSpec_Call) Return(_a0 error) *ORM_ApproveSpec_Call
- func (_c *ORM_ApproveSpec_Call) Run(run func(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt)) *ORM_ApproveSpec_Call
- func (_c *ORM_ApproveSpec_Call) RunAndReturn(run func(int64, uuid.UUID, ...pg.QOpt) error) *ORM_ApproveSpec_Call
- type ORM_CancelSpec_Call
- type ORM_CountJobProposalsByStatus_Call
- func (_c *ORM_CountJobProposalsByStatus_Call) Return(counts *feeds.JobProposalCounts, err error) *ORM_CountJobProposalsByStatus_Call
- func (_c *ORM_CountJobProposalsByStatus_Call) Run(run func()) *ORM_CountJobProposalsByStatus_Call
- func (_c *ORM_CountJobProposalsByStatus_Call) RunAndReturn(run func() (*feeds.JobProposalCounts, error)) *ORM_CountJobProposalsByStatus_Call
- type ORM_CountJobProposals_Call
- type ORM_CountManagers_Call
- type ORM_CreateBatchChainConfig_Call
- func (_c *ORM_CreateBatchChainConfig_Call) Return(_a0 []int64, _a1 error) *ORM_CreateBatchChainConfig_Call
- func (_c *ORM_CreateBatchChainConfig_Call) Run(run func(cfgs []feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateBatchChainConfig_Call
- func (_c *ORM_CreateBatchChainConfig_Call) RunAndReturn(run func([]feeds.ChainConfig, ...pg.QOpt) ([]int64, error)) *ORM_CreateBatchChainConfig_Call
- type ORM_CreateChainConfig_Call
- func (_c *ORM_CreateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_CreateChainConfig_Call
- func (_c *ORM_CreateChainConfig_Call) Run(run func(cfg feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateChainConfig_Call
- func (_c *ORM_CreateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig, ...pg.QOpt) (int64, error)) *ORM_CreateChainConfig_Call
- type ORM_CreateJobProposal_Call
- func (_c *ORM_CreateJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_CreateJobProposal_Call
- func (_c *ORM_CreateJobProposal_Call) Run(run func(jp *feeds.JobProposal)) *ORM_CreateJobProposal_Call
- func (_c *ORM_CreateJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal) (int64, error)) *ORM_CreateJobProposal_Call
- type ORM_CreateManager_Call
- func (_c *ORM_CreateManager_Call) Return(_a0 int64, _a1 error) *ORM_CreateManager_Call
- func (_c *ORM_CreateManager_Call) Run(run func(ms *feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_CreateManager_Call
- func (_c *ORM_CreateManager_Call) RunAndReturn(run func(*feeds.FeedsManager, ...pg.QOpt) (int64, error)) *ORM_CreateManager_Call
- type ORM_CreateSpec_Call
- func (_c *ORM_CreateSpec_Call) Return(_a0 int64, _a1 error) *ORM_CreateSpec_Call
- func (_c *ORM_CreateSpec_Call) Run(run func(spec feeds.JobProposalSpec, qopts ...pg.QOpt)) *ORM_CreateSpec_Call
- func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(feeds.JobProposalSpec, ...pg.QOpt) (int64, error)) *ORM_CreateSpec_Call
- type ORM_DeleteChainConfig_Call
- type ORM_DeleteProposal_Call
- type ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return(exists bool, err error) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run(run func(jpID int64, version int32, qopts ...pg.QOpt)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn(run func(int64, int32, ...pg.QOpt) (bool, error)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- type ORM_Expecter
- func (_e *ORM_Expecter) ApproveSpec(id interface{}, externalJobID interface{}, qopts ...interface{}) *ORM_ApproveSpec_Call
- func (_e *ORM_Expecter) CancelSpec(id interface{}, qopts ...interface{}) *ORM_CancelSpec_Call
- func (_e *ORM_Expecter) CountJobProposals() *ORM_CountJobProposals_Call
- func (_e *ORM_Expecter) CountJobProposalsByStatus() *ORM_CountJobProposalsByStatus_Call
- func (_e *ORM_Expecter) CountManagers() *ORM_CountManagers_Call
- func (_e *ORM_Expecter) CreateBatchChainConfig(cfgs interface{}, qopts ...interface{}) *ORM_CreateBatchChainConfig_Call
- func (_e *ORM_Expecter) CreateChainConfig(cfg interface{}, qopts ...interface{}) *ORM_CreateChainConfig_Call
- func (_e *ORM_Expecter) CreateJobProposal(jp interface{}) *ORM_CreateJobProposal_Call
- func (_e *ORM_Expecter) CreateManager(ms interface{}, qopts ...interface{}) *ORM_CreateManager_Call
- func (_e *ORM_Expecter) CreateSpec(spec interface{}, qopts ...interface{}) *ORM_CreateSpec_Call
- func (_e *ORM_Expecter) DeleteChainConfig(id interface{}) *ORM_DeleteChainConfig_Call
- func (_e *ORM_Expecter) DeleteProposal(id interface{}, qopts ...interface{}) *ORM_DeleteProposal_Call
- func (_e *ORM_Expecter) ExistsSpecByJobProposalIDAndVersion(jpID interface{}, version interface{}, qopts ...interface{}) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
- func (_e *ORM_Expecter) GetApprovedSpec(jpID interface{}, qopts ...interface{}) *ORM_GetApprovedSpec_Call
- func (_e *ORM_Expecter) GetChainConfig(id interface{}) *ORM_GetChainConfig_Call
- func (_e *ORM_Expecter) GetJobProposal(id interface{}, qopts ...interface{}) *ORM_GetJobProposal_Call
- func (_e *ORM_Expecter) GetJobProposalByRemoteUUID(_a0 interface{}) *ORM_GetJobProposalByRemoteUUID_Call
- func (_e *ORM_Expecter) GetLatestSpec(jpID interface{}) *ORM_GetLatestSpec_Call
- func (_e *ORM_Expecter) GetManager(id interface{}) *ORM_GetManager_Call
- func (_e *ORM_Expecter) GetSpec(id interface{}, qopts ...interface{}) *ORM_GetSpec_Call
- func (_e *ORM_Expecter) IsJobManaged(jobID interface{}, qopts ...interface{}) *ORM_IsJobManaged_Call
- func (_e *ORM_Expecter) ListChainConfigsByManagerIDs(mgrIDs interface{}) *ORM_ListChainConfigsByManagerIDs_Call
- func (_e *ORM_Expecter) ListJobProposals() *ORM_ListJobProposals_Call
- func (_e *ORM_Expecter) ListJobProposalsByManagersIDs(ids interface{}, qopts ...interface{}) *ORM_ListJobProposalsByManagersIDs_Call
- func (_e *ORM_Expecter) ListManagers() *ORM_ListManagers_Call
- func (_e *ORM_Expecter) ListManagersByIDs(ids interface{}) *ORM_ListManagersByIDs_Call
- func (_e *ORM_Expecter) ListSpecsByJobProposalIDs(ids interface{}, qopts ...interface{}) *ORM_ListSpecsByJobProposalIDs_Call
- func (_e *ORM_Expecter) RejectSpec(id interface{}, qopts ...interface{}) *ORM_RejectSpec_Call
- func (_e *ORM_Expecter) RevokeSpec(id interface{}, qopts ...interface{}) *ORM_RevokeSpec_Call
- func (_e *ORM_Expecter) UpdateChainConfig(cfg interface{}) *ORM_UpdateChainConfig_Call
- func (_e *ORM_Expecter) UpdateJobProposalStatus(id interface{}, status interface{}, qopts ...interface{}) *ORM_UpdateJobProposalStatus_Call
- func (_e *ORM_Expecter) UpdateManager(mgr interface{}, qopts ...interface{}) *ORM_UpdateManager_Call
- func (_e *ORM_Expecter) UpdateSpecDefinition(id interface{}, spec interface{}, qopts ...interface{}) *ORM_UpdateSpecDefinition_Call
- func (_e *ORM_Expecter) UpsertJobProposal(jp interface{}, qopts ...interface{}) *ORM_UpsertJobProposal_Call
- type ORM_GetApprovedSpec_Call
- func (_c *ORM_GetApprovedSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetApprovedSpec_Call
- func (_c *ORM_GetApprovedSpec_Call) Run(run func(jpID int64, qopts ...pg.QOpt)) *ORM_GetApprovedSpec_Call
- func (_c *ORM_GetApprovedSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetApprovedSpec_Call
- type ORM_GetChainConfig_Call
- func (_c *ORM_GetChainConfig_Call) Return(_a0 *feeds.ChainConfig, _a1 error) *ORM_GetChainConfig_Call
- func (_c *ORM_GetChainConfig_Call) Run(run func(id int64)) *ORM_GetChainConfig_Call
- func (_c *ORM_GetChainConfig_Call) RunAndReturn(run func(int64) (*feeds.ChainConfig, error)) *ORM_GetChainConfig_Call
- type ORM_GetJobProposalByRemoteUUID_Call
- func (_c *ORM_GetJobProposalByRemoteUUID_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposalByRemoteUUID_Call
- func (_c *ORM_GetJobProposalByRemoteUUID_Call) Run(run func(_a0 uuid.UUID)) *ORM_GetJobProposalByRemoteUUID_Call
- func (_c *ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn(run func(uuid.UUID) (*feeds.JobProposal, error)) *ORM_GetJobProposalByRemoteUUID_Call
- type ORM_GetJobProposal_Call
- func (_c *ORM_GetJobProposal_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposal_Call
- func (_c *ORM_GetJobProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetJobProposal_Call
- func (_c *ORM_GetJobProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposal, error)) *ORM_GetJobProposal_Call
- type ORM_GetLatestSpec_Call
- func (_c *ORM_GetLatestSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetLatestSpec_Call
- func (_c *ORM_GetLatestSpec_Call) Run(run func(jpID int64)) *ORM_GetLatestSpec_Call
- func (_c *ORM_GetLatestSpec_Call) RunAndReturn(run func(int64) (*feeds.JobProposalSpec, error)) *ORM_GetLatestSpec_Call
- type ORM_GetManager_Call
- type ORM_GetSpec_Call
- type ORM_IsJobManaged_Call
- type ORM_ListChainConfigsByManagerIDs_Call
- func (_c *ORM_ListChainConfigsByManagerIDs_Call) Return(_a0 []feeds.ChainConfig, _a1 error) *ORM_ListChainConfigsByManagerIDs_Call
- func (_c *ORM_ListChainConfigsByManagerIDs_Call) Run(run func(mgrIDs []int64)) *ORM_ListChainConfigsByManagerIDs_Call
- func (_c *ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn(run func([]int64) ([]feeds.ChainConfig, error)) *ORM_ListChainConfigsByManagerIDs_Call
- type ORM_ListJobProposalsByManagersIDs_Call
- func (_c *ORM_ListJobProposalsByManagersIDs_Call) Return(_a0 []feeds.JobProposal, _a1 error) *ORM_ListJobProposalsByManagersIDs_Call
- func (_c *ORM_ListJobProposalsByManagersIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListJobProposalsByManagersIDs_Call
- func (_c *ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposal, error)) *ORM_ListJobProposalsByManagersIDs_Call
- type ORM_ListJobProposals_Call
- func (_c *ORM_ListJobProposals_Call) Return(jps []feeds.JobProposal, err error) *ORM_ListJobProposals_Call
- func (_c *ORM_ListJobProposals_Call) Run(run func()) *ORM_ListJobProposals_Call
- func (_c *ORM_ListJobProposals_Call) RunAndReturn(run func() ([]feeds.JobProposal, error)) *ORM_ListJobProposals_Call
- type ORM_ListManagersByIDs_Call
- func (_c *ORM_ListManagersByIDs_Call) Return(_a0 []feeds.FeedsManager, _a1 error) *ORM_ListManagersByIDs_Call
- func (_c *ORM_ListManagersByIDs_Call) Run(run func(ids []int64)) *ORM_ListManagersByIDs_Call
- func (_c *ORM_ListManagersByIDs_Call) RunAndReturn(run func([]int64) ([]feeds.FeedsManager, error)) *ORM_ListManagersByIDs_Call
- type ORM_ListManagers_Call
- type ORM_ListSpecsByJobProposalIDs_Call
- func (_c *ORM_ListSpecsByJobProposalIDs_Call) Return(_a0 []feeds.JobProposalSpec, _a1 error) *ORM_ListSpecsByJobProposalIDs_Call
- func (_c *ORM_ListSpecsByJobProposalIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListSpecsByJobProposalIDs_Call
- func (_c *ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposalSpec, error)) *ORM_ListSpecsByJobProposalIDs_Call
- type ORM_RejectSpec_Call
- type ORM_RevokeSpec_Call
- type ORM_UpdateChainConfig_Call
- func (_c *ORM_UpdateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_UpdateChainConfig_Call
- func (_c *ORM_UpdateChainConfig_Call) Run(run func(cfg feeds.ChainConfig)) *ORM_UpdateChainConfig_Call
- func (_c *ORM_UpdateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig) (int64, error)) *ORM_UpdateChainConfig_Call
- type ORM_UpdateJobProposalStatus_Call
- func (_c *ORM_UpdateJobProposalStatus_Call) Return(_a0 error) *ORM_UpdateJobProposalStatus_Call
- func (_c *ORM_UpdateJobProposalStatus_Call) Run(run func(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt)) *ORM_UpdateJobProposalStatus_Call
- func (_c *ORM_UpdateJobProposalStatus_Call) RunAndReturn(run func(int64, feeds.JobProposalStatus, ...pg.QOpt) error) *ORM_UpdateJobProposalStatus_Call
- type ORM_UpdateManager_Call
- func (_c *ORM_UpdateManager_Call) Return(_a0 error) *ORM_UpdateManager_Call
- func (_c *ORM_UpdateManager_Call) Run(run func(mgr feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_UpdateManager_Call
- func (_c *ORM_UpdateManager_Call) RunAndReturn(run func(feeds.FeedsManager, ...pg.QOpt) error) *ORM_UpdateManager_Call
- type ORM_UpdateSpecDefinition_Call
- func (_c *ORM_UpdateSpecDefinition_Call) Return(_a0 error) *ORM_UpdateSpecDefinition_Call
- func (_c *ORM_UpdateSpecDefinition_Call) Run(run func(id int64, spec string, qopts ...pg.QOpt)) *ORM_UpdateSpecDefinition_Call
- func (_c *ORM_UpdateSpecDefinition_Call) RunAndReturn(run func(int64, string, ...pg.QOpt) error) *ORM_UpdateSpecDefinition_Call
- type ORM_UpsertJobProposal_Call
- func (_c *ORM_UpsertJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_UpsertJobProposal_Call
- func (_c *ORM_UpsertJobProposal_Call) Run(run func(jp *feeds.JobProposal, qopts ...pg.QOpt)) *ORM_UpsertJobProposal_Call
- func (_c *ORM_UpsertJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal, ...pg.QOpt) (int64, error)) *ORM_UpsertJobProposal_Call
- type Service
- func (_m *Service) ApproveSpec(ctx context.Context, id int64, force bool) error
- func (_m *Service) CancelSpec(ctx context.Context, id int64) error
- func (_m *Service) Close() error
- func (_m *Service) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
- func (_m *Service) CountManagers() (int64, error)
- func (_m *Service) CreateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)
- func (_m *Service) DeleteChainConfig(ctx context.Context, id int64) (int64, error)
- func (_m *Service) DeleteJob(ctx context.Context, args *feeds.DeleteJobArgs) (int64, error)
- func (_m *Service) GetChainConfig(id int64) (*feeds.ChainConfig, error)
- func (_m *Service) GetJobProposal(id int64) (*feeds.JobProposal, error)
- func (_m *Service) GetManager(id int64) (*feeds.FeedsManager, error)
- func (_m *Service) GetSpec(id int64) (*feeds.JobProposalSpec, error)
- func (_m *Service) IsJobManaged(ctx context.Context, jobID int64) (bool, error)
- func (_m *Service) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
- func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)
- func (_m *Service) ListJobProposalsByManagersIDs(ids []int64) ([]feeds.JobProposal, error)
- func (_m *Service) ListManagers() ([]feeds.FeedsManager, error)
- func (_m *Service) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
- func (_m *Service) ListSpecsByJobProposalIDs(ids []int64) ([]feeds.JobProposalSpec, error)
- func (_m *Service) ProposeJob(ctx context.Context, args *feeds.ProposeJobArgs) (int64, error)
- func (_m *Service) RegisterManager(ctx context.Context, params feeds.RegisterManagerParams) (int64, error)
- func (_m *Service) RejectSpec(ctx context.Context, id int64) error
- func (_m *Service) RevokeJob(ctx context.Context, args *feeds.RevokeJobArgs) (int64, error)
- func (_m *Service) Start(ctx context.Context) error
- func (_m *Service) SyncNodeInfo(ctx context.Context, id int64) error
- func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)
- func (_m *Service) UpdateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)
- func (_m *Service) UpdateManager(ctx context.Context, mgr feeds.FeedsManager) error
- func (_m *Service) UpdateSpecDefinition(ctx context.Context, id int64, spec string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionsManager ¶
ConnectionsManager is an autogenerated mock type for the ConnectionsManager type
func NewConnectionsManager ¶
func NewConnectionsManager(t interface { mock.TestingT Cleanup(func()) }) *ConnectionsManager
NewConnectionsManager creates a new instance of ConnectionsManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ConnectionsManager) Close ¶
func (_m *ConnectionsManager) Close()
Close provides a mock function with given fields:
func (*ConnectionsManager) Connect ¶
func (_m *ConnectionsManager) Connect(opts feeds.ConnectOpts)
Connect provides a mock function with given fields: opts
func (*ConnectionsManager) Disconnect ¶
func (_m *ConnectionsManager) Disconnect(id int64) error
Disconnect provides a mock function with given fields: id
func (*ConnectionsManager) GetClient ¶
func (_m *ConnectionsManager) GetClient(id int64) (proto.FeedsManagerClient, error)
GetClient provides a mock function with given fields: id
func (*ConnectionsManager) IsConnected ¶
func (_m *ConnectionsManager) IsConnected(id int64) bool
IsConnected provides a mock function with given fields: id
type FeedsManagerClient ¶
FeedsManagerClient is an autogenerated mock type for the FeedsManagerClient type
func NewFeedsManagerClient ¶
func NewFeedsManagerClient(t interface { mock.TestingT Cleanup(func()) }) *FeedsManagerClient
NewFeedsManagerClient creates a new instance of FeedsManagerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*FeedsManagerClient) ApprovedJob ¶
func (_m *FeedsManagerClient) ApprovedJob(ctx context.Context, in *proto.ApprovedJobRequest) (*proto.ApprovedJobResponse, error)
ApprovedJob provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) CancelledJob ¶
func (_m *FeedsManagerClient) CancelledJob(ctx context.Context, in *proto.CancelledJobRequest) (*proto.CancelledJobResponse, error)
CancelledJob provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) Healthcheck ¶
func (_m *FeedsManagerClient) Healthcheck(ctx context.Context, in *proto.HealthcheckRequest) (*proto.HealthcheckResponse, error)
Healthcheck provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) RejectedJob ¶
func (_m *FeedsManagerClient) RejectedJob(ctx context.Context, in *proto.RejectedJobRequest) (*proto.RejectedJobResponse, error)
RejectedJob provides a mock function with given fields: ctx, in
func (*FeedsManagerClient) UpdateNode ¶
func (_m *FeedsManagerClient) UpdateNode(ctx context.Context, in *proto.UpdateNodeRequest) (*proto.UpdateNodeResponse, error)
UpdateNode provides a mock function with given fields: ctx, in
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶
NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ORM) ApproveSpec ¶
ApproveSpec provides a mock function with given fields: id, externalJobID, qopts
func (*ORM) CancelSpec ¶
CancelSpec provides a mock function with given fields: id, qopts
func (*ORM) CountJobProposals ¶
CountJobProposals provides a mock function with given fields:
func (*ORM) CountJobProposalsByStatus ¶
func (_m *ORM) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
CountJobProposalsByStatus provides a mock function with given fields:
func (*ORM) CountManagers ¶
CountManagers provides a mock function with given fields:
func (*ORM) CreateBatchChainConfig ¶
CreateBatchChainConfig provides a mock function with given fields: cfgs, qopts
func (*ORM) CreateChainConfig ¶
CreateChainConfig provides a mock function with given fields: cfg, qopts
func (*ORM) CreateJobProposal ¶
func (_m *ORM) CreateJobProposal(jp *feeds.JobProposal) (int64, error)
CreateJobProposal provides a mock function with given fields: jp
func (*ORM) CreateManager ¶
CreateManager provides a mock function with given fields: ms, qopts
func (*ORM) CreateSpec ¶
CreateSpec provides a mock function with given fields: spec, qopts
func (*ORM) DeleteChainConfig ¶
DeleteChainConfig provides a mock function with given fields: id
func (*ORM) DeleteProposal ¶
DeleteProposal provides a mock function with given fields: id, qopts
func (*ORM) EXPECT ¶
func (_m *ORM) EXPECT() *ORM_Expecter
func (*ORM) ExistsSpecByJobProposalIDAndVersion ¶
func (_m *ORM) ExistsSpecByJobProposalIDAndVersion(jpID int64, version int32, qopts ...pg.QOpt) (bool, error)
ExistsSpecByJobProposalIDAndVersion provides a mock function with given fields: jpID, version, qopts
func (*ORM) GetApprovedSpec ¶
GetApprovedSpec provides a mock function with given fields: jpID, qopts
func (*ORM) GetChainConfig ¶
func (_m *ORM) GetChainConfig(id int64) (*feeds.ChainConfig, error)
GetChainConfig provides a mock function with given fields: id
func (*ORM) GetJobProposal ¶
GetJobProposal provides a mock function with given fields: id, qopts
func (*ORM) GetJobProposalByRemoteUUID ¶
GetJobProposalByRemoteUUID provides a mock function with given fields: _a0
func (*ORM) GetLatestSpec ¶
func (_m *ORM) GetLatestSpec(jpID int64) (*feeds.JobProposalSpec, error)
GetLatestSpec provides a mock function with given fields: jpID
func (*ORM) GetManager ¶
func (_m *ORM) GetManager(id int64) (*feeds.FeedsManager, error)
GetManager provides a mock function with given fields: id
func (*ORM) IsJobManaged ¶
IsJobManaged provides a mock function with given fields: jobID, qopts
func (*ORM) ListChainConfigsByManagerIDs ¶
func (_m *ORM) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
ListChainConfigsByManagerIDs provides a mock function with given fields: mgrIDs
func (*ORM) ListJobProposals ¶
func (_m *ORM) ListJobProposals() ([]feeds.JobProposal, error)
ListJobProposals provides a mock function with given fields:
func (*ORM) ListJobProposalsByManagersIDs ¶
func (_m *ORM) ListJobProposalsByManagersIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposal, error)
ListJobProposalsByManagersIDs provides a mock function with given fields: ids, qopts
func (*ORM) ListManagers ¶
func (_m *ORM) ListManagers() ([]feeds.FeedsManager, error)
ListManagers provides a mock function with given fields:
func (*ORM) ListManagersByIDs ¶
func (_m *ORM) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
ListManagersByIDs provides a mock function with given fields: ids
func (*ORM) ListSpecsByJobProposalIDs ¶
func (_m *ORM) ListSpecsByJobProposalIDs(ids []int64, qopts ...pg.QOpt) ([]feeds.JobProposalSpec, error)
ListSpecsByJobProposalIDs provides a mock function with given fields: ids, qopts
func (*ORM) RejectSpec ¶
RejectSpec provides a mock function with given fields: id, qopts
func (*ORM) RevokeSpec ¶
RevokeSpec provides a mock function with given fields: id, qopts
func (*ORM) UpdateChainConfig ¶
func (_m *ORM) UpdateChainConfig(cfg feeds.ChainConfig) (int64, error)
UpdateChainConfig provides a mock function with given fields: cfg
func (*ORM) UpdateJobProposalStatus ¶
func (_m *ORM) UpdateJobProposalStatus(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt) error
UpdateJobProposalStatus provides a mock function with given fields: id, status, qopts
func (*ORM) UpdateManager ¶
UpdateManager provides a mock function with given fields: mgr, qopts
func (*ORM) UpdateSpecDefinition ¶
UpdateSpecDefinition provides a mock function with given fields: id, spec, qopts
func (*ORM) UpsertJobProposal ¶
UpsertJobProposal provides a mock function with given fields: jp, qopts
type ORM_ApproveSpec_Call ¶
ORM_ApproveSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ApproveSpec'
func (*ORM_ApproveSpec_Call) Return ¶
func (_c *ORM_ApproveSpec_Call) Return(_a0 error) *ORM_ApproveSpec_Call
func (*ORM_ApproveSpec_Call) Run ¶
func (_c *ORM_ApproveSpec_Call) Run(run func(id int64, externalJobID uuid.UUID, qopts ...pg.QOpt)) *ORM_ApproveSpec_Call
func (*ORM_ApproveSpec_Call) RunAndReturn ¶
func (_c *ORM_ApproveSpec_Call) RunAndReturn(run func(int64, uuid.UUID, ...pg.QOpt) error) *ORM_ApproveSpec_Call
type ORM_CancelSpec_Call ¶
ORM_CancelSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelSpec'
func (*ORM_CancelSpec_Call) Return ¶
func (_c *ORM_CancelSpec_Call) Return(_a0 error) *ORM_CancelSpec_Call
func (*ORM_CancelSpec_Call) Run ¶
func (_c *ORM_CancelSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_CancelSpec_Call
func (*ORM_CancelSpec_Call) RunAndReturn ¶
func (_c *ORM_CancelSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_CancelSpec_Call
type ORM_CountJobProposalsByStatus_Call ¶
ORM_CountJobProposalsByStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountJobProposalsByStatus'
func (*ORM_CountJobProposalsByStatus_Call) Return ¶
func (_c *ORM_CountJobProposalsByStatus_Call) Return(counts *feeds.JobProposalCounts, err error) *ORM_CountJobProposalsByStatus_Call
func (*ORM_CountJobProposalsByStatus_Call) Run ¶
func (_c *ORM_CountJobProposalsByStatus_Call) Run(run func()) *ORM_CountJobProposalsByStatus_Call
func (*ORM_CountJobProposalsByStatus_Call) RunAndReturn ¶
func (_c *ORM_CountJobProposalsByStatus_Call) RunAndReturn(run func() (*feeds.JobProposalCounts, error)) *ORM_CountJobProposalsByStatus_Call
type ORM_CountJobProposals_Call ¶
ORM_CountJobProposals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountJobProposals'
func (*ORM_CountJobProposals_Call) Return ¶
func (_c *ORM_CountJobProposals_Call) Return(_a0 int64, _a1 error) *ORM_CountJobProposals_Call
func (*ORM_CountJobProposals_Call) Run ¶
func (_c *ORM_CountJobProposals_Call) Run(run func()) *ORM_CountJobProposals_Call
func (*ORM_CountJobProposals_Call) RunAndReturn ¶
func (_c *ORM_CountJobProposals_Call) RunAndReturn(run func() (int64, error)) *ORM_CountJobProposals_Call
type ORM_CountManagers_Call ¶
ORM_CountManagers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CountManagers'
func (*ORM_CountManagers_Call) Return ¶
func (_c *ORM_CountManagers_Call) Return(_a0 int64, _a1 error) *ORM_CountManagers_Call
func (*ORM_CountManagers_Call) Run ¶
func (_c *ORM_CountManagers_Call) Run(run func()) *ORM_CountManagers_Call
func (*ORM_CountManagers_Call) RunAndReturn ¶
func (_c *ORM_CountManagers_Call) RunAndReturn(run func() (int64, error)) *ORM_CountManagers_Call
type ORM_CreateBatchChainConfig_Call ¶
ORM_CreateBatchChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateBatchChainConfig'
func (*ORM_CreateBatchChainConfig_Call) Return ¶
func (_c *ORM_CreateBatchChainConfig_Call) Return(_a0 []int64, _a1 error) *ORM_CreateBatchChainConfig_Call
func (*ORM_CreateBatchChainConfig_Call) Run ¶
func (_c *ORM_CreateBatchChainConfig_Call) Run(run func(cfgs []feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateBatchChainConfig_Call
func (*ORM_CreateBatchChainConfig_Call) RunAndReturn ¶
func (_c *ORM_CreateBatchChainConfig_Call) RunAndReturn(run func([]feeds.ChainConfig, ...pg.QOpt) ([]int64, error)) *ORM_CreateBatchChainConfig_Call
type ORM_CreateChainConfig_Call ¶
ORM_CreateChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateChainConfig'
func (*ORM_CreateChainConfig_Call) Return ¶
func (_c *ORM_CreateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_CreateChainConfig_Call
func (*ORM_CreateChainConfig_Call) Run ¶
func (_c *ORM_CreateChainConfig_Call) Run(run func(cfg feeds.ChainConfig, qopts ...pg.QOpt)) *ORM_CreateChainConfig_Call
func (*ORM_CreateChainConfig_Call) RunAndReturn ¶
func (_c *ORM_CreateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig, ...pg.QOpt) (int64, error)) *ORM_CreateChainConfig_Call
type ORM_CreateJobProposal_Call ¶
ORM_CreateJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobProposal'
func (*ORM_CreateJobProposal_Call) Return ¶
func (_c *ORM_CreateJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_CreateJobProposal_Call
func (*ORM_CreateJobProposal_Call) Run ¶
func (_c *ORM_CreateJobProposal_Call) Run(run func(jp *feeds.JobProposal)) *ORM_CreateJobProposal_Call
func (*ORM_CreateJobProposal_Call) RunAndReturn ¶
func (_c *ORM_CreateJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal) (int64, error)) *ORM_CreateJobProposal_Call
type ORM_CreateManager_Call ¶
ORM_CreateManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateManager'
func (*ORM_CreateManager_Call) Return ¶
func (_c *ORM_CreateManager_Call) Return(_a0 int64, _a1 error) *ORM_CreateManager_Call
func (*ORM_CreateManager_Call) Run ¶
func (_c *ORM_CreateManager_Call) Run(run func(ms *feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_CreateManager_Call
func (*ORM_CreateManager_Call) RunAndReturn ¶
func (_c *ORM_CreateManager_Call) RunAndReturn(run func(*feeds.FeedsManager, ...pg.QOpt) (int64, error)) *ORM_CreateManager_Call
type ORM_CreateSpec_Call ¶
ORM_CreateSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSpec'
func (*ORM_CreateSpec_Call) Return ¶
func (_c *ORM_CreateSpec_Call) Return(_a0 int64, _a1 error) *ORM_CreateSpec_Call
func (*ORM_CreateSpec_Call) Run ¶
func (_c *ORM_CreateSpec_Call) Run(run func(spec feeds.JobProposalSpec, qopts ...pg.QOpt)) *ORM_CreateSpec_Call
func (*ORM_CreateSpec_Call) RunAndReturn ¶
func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(feeds.JobProposalSpec, ...pg.QOpt) (int64, error)) *ORM_CreateSpec_Call
type ORM_DeleteChainConfig_Call ¶
ORM_DeleteChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteChainConfig'
func (*ORM_DeleteChainConfig_Call) Return ¶
func (_c *ORM_DeleteChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_DeleteChainConfig_Call
func (*ORM_DeleteChainConfig_Call) Run ¶
func (_c *ORM_DeleteChainConfig_Call) Run(run func(id int64)) *ORM_DeleteChainConfig_Call
func (*ORM_DeleteChainConfig_Call) RunAndReturn ¶
func (_c *ORM_DeleteChainConfig_Call) RunAndReturn(run func(int64) (int64, error)) *ORM_DeleteChainConfig_Call
type ORM_DeleteProposal_Call ¶
ORM_DeleteProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteProposal'
func (*ORM_DeleteProposal_Call) Return ¶
func (_c *ORM_DeleteProposal_Call) Return(_a0 error) *ORM_DeleteProposal_Call
func (*ORM_DeleteProposal_Call) Run ¶
func (_c *ORM_DeleteProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_DeleteProposal_Call
func (*ORM_DeleteProposal_Call) RunAndReturn ¶
func (_c *ORM_DeleteProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_DeleteProposal_Call
type ORM_ExistsSpecByJobProposalIDAndVersion_Call ¶
ORM_ExistsSpecByJobProposalIDAndVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExistsSpecByJobProposalIDAndVersion'
func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return ¶
func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return(exists bool, err error) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run ¶
func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run(run func(jpID int64, version int32, qopts ...pg.QOpt)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn ¶
func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn(run func(int64, int32, ...pg.QOpt) (bool, error)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
type ORM_Expecter ¶
type ORM_Expecter struct {
// contains filtered or unexported fields
}
func (*ORM_Expecter) ApproveSpec ¶
func (_e *ORM_Expecter) ApproveSpec(id interface{}, externalJobID interface{}, qopts ...interface{}) *ORM_ApproveSpec_Call
ApproveSpec is a helper method to define mock.On call
- id int64
- externalJobID uuid.UUID
- qopts ...pg.QOpt
func (*ORM_Expecter) CancelSpec ¶
func (_e *ORM_Expecter) CancelSpec(id interface{}, qopts ...interface{}) *ORM_CancelSpec_Call
CancelSpec is a helper method to define mock.On call
- id int64
- qopts ...pg.QOpt
func (*ORM_Expecter) CountJobProposals ¶
func (_e *ORM_Expecter) CountJobProposals() *ORM_CountJobProposals_Call
CountJobProposals is a helper method to define mock.On call
func (*ORM_Expecter) CountJobProposalsByStatus ¶
func (_e *ORM_Expecter) CountJobProposalsByStatus() *ORM_CountJobProposalsByStatus_Call
CountJobProposalsByStatus is a helper method to define mock.On call
func (*ORM_Expecter) CountManagers ¶
func (_e *ORM_Expecter) CountManagers() *ORM_CountManagers_Call
CountManagers is a helper method to define mock.On call
func (*ORM_Expecter) CreateBatchChainConfig ¶
func (_e *ORM_Expecter) CreateBatchChainConfig(cfgs interface{}, qopts ...interface{}) *ORM_CreateBatchChainConfig_Call
CreateBatchChainConfig is a helper method to define mock.On call
- cfgs []feeds.ChainConfig
- qopts ...pg.QOpt
func (*ORM_Expecter) CreateChainConfig ¶
func (_e *ORM_Expecter) CreateChainConfig(cfg interface{}, qopts ...interface{}) *ORM_CreateChainConfig_Call
CreateChainConfig is a helper method to define mock.On call
- cfg feeds.ChainConfig
- qopts ...pg.QOpt
func (*ORM_Expecter) CreateJobProposal ¶
func (_e *ORM_Expecter) CreateJobProposal(jp interface{}) *ORM_CreateJobProposal_Call
CreateJobProposal is a helper method to define mock.On call
- jp *feeds.JobProposal
func (*ORM_Expecter) CreateManager ¶
func (_e *ORM_Expecter) CreateManager(ms interface{}, qopts ...interface{}) *ORM_CreateManager_Call
CreateManager is a helper method to define mock.On call
- ms *feeds.FeedsManager
- qopts ...pg.QOpt
func (*ORM_Expecter) CreateSpec ¶
func (_e *ORM_Expecter) CreateSpec(spec interface{}, qopts ...interface{}) *ORM_CreateSpec_Call
CreateSpec is a helper method to define mock.On call
- spec feeds.JobProposalSpec
- qopts ...pg.QOpt
func (*ORM_Expecter) DeleteChainConfig ¶
func (_e *ORM_Expecter) DeleteChainConfig(id interface{}) *ORM_DeleteChainConfig_Call
DeleteChainConfig is a helper method to define mock.On call
- id int64
func (*ORM_Expecter) DeleteProposal ¶
func (_e *ORM_Expecter) DeleteProposal(id interface{}, qopts ...interface{}) *ORM_DeleteProposal_Call
DeleteProposal is a helper method to define mock.On call
- id int64
- qopts ...pg.QOpt
func (*ORM_Expecter) ExistsSpecByJobProposalIDAndVersion ¶
func (_e *ORM_Expecter) ExistsSpecByJobProposalIDAndVersion(jpID interface{}, version interface{}, qopts ...interface{}) *ORM_ExistsSpecByJobProposalIDAndVersion_Call
ExistsSpecByJobProposalIDAndVersion is a helper method to define mock.On call
- jpID int64
- version int32
- qopts ...pg.QOpt
func (*ORM_Expecter) GetApprovedSpec ¶
func (_e *ORM_Expecter) GetApprovedSpec(jpID interface{}, qopts ...interface{}) *ORM_GetApprovedSpec_Call
GetApprovedSpec is a helper method to define mock.On call
- jpID int64
- qopts ...pg.QOpt
func (*ORM_Expecter) GetChainConfig ¶
func (_e *ORM_Expecter) GetChainConfig(id interface{}) *ORM_GetChainConfig_Call
GetChainConfig is a helper method to define mock.On call
- id int64
func (*ORM_Expecter) GetJobProposal ¶
func (_e *ORM_Expecter) GetJobProposal(id interface{}, qopts ...interface{}) *ORM_GetJobProposal_Call
GetJobProposal is a helper method to define mock.On call
- id int64
- qopts ...pg.QOpt
func (*ORM_Expecter) GetJobProposalByRemoteUUID ¶
func (_e *ORM_Expecter) GetJobProposalByRemoteUUID(_a0 interface{}) *ORM_GetJobProposalByRemoteUUID_Call
GetJobProposalByRemoteUUID is a helper method to define mock.On call
- _a0 uuid.UUID
func (*ORM_Expecter) GetLatestSpec ¶
func (_e *ORM_Expecter) GetLatestSpec(jpID interface{}) *ORM_GetLatestSpec_Call
GetLatestSpec is a helper method to define mock.On call
- jpID int64
func (*ORM_Expecter) GetManager ¶
func (_e *ORM_Expecter) GetManager(id interface{}) *ORM_GetManager_Call
GetManager is a helper method to define mock.On call
- id int64
func (*ORM_Expecter) GetSpec ¶
func (_e *ORM_Expecter) GetSpec(id interface{}, qopts ...interface{}) *ORM_GetSpec_Call
GetSpec is a helper method to define mock.On call
- id int64
- qopts ...pg.QOpt
func (*ORM_Expecter) IsJobManaged ¶
func (_e *ORM_Expecter) IsJobManaged(jobID interface{}, qopts ...interface{}) *ORM_IsJobManaged_Call
IsJobManaged is a helper method to define mock.On call
- jobID int64
- qopts ...pg.QOpt
func (*ORM_Expecter) ListChainConfigsByManagerIDs ¶
func (_e *ORM_Expecter) ListChainConfigsByManagerIDs(mgrIDs interface{}) *ORM_ListChainConfigsByManagerIDs_Call
ListChainConfigsByManagerIDs is a helper method to define mock.On call
- mgrIDs []int64
func (*ORM_Expecter) ListJobProposals ¶
func (_e *ORM_Expecter) ListJobProposals() *ORM_ListJobProposals_Call
ListJobProposals is a helper method to define mock.On call
func (*ORM_Expecter) ListJobProposalsByManagersIDs ¶
func (_e *ORM_Expecter) ListJobProposalsByManagersIDs(ids interface{}, qopts ...interface{}) *ORM_ListJobProposalsByManagersIDs_Call
ListJobProposalsByManagersIDs is a helper method to define mock.On call
- ids []int64
- qopts ...pg.QOpt
func (*ORM_Expecter) ListManagers ¶
func (_e *ORM_Expecter) ListManagers() *ORM_ListManagers_Call
ListManagers is a helper method to define mock.On call
func (*ORM_Expecter) ListManagersByIDs ¶
func (_e *ORM_Expecter) ListManagersByIDs(ids interface{}) *ORM_ListManagersByIDs_Call
ListManagersByIDs is a helper method to define mock.On call
- ids []int64
func (*ORM_Expecter) ListSpecsByJobProposalIDs ¶
func (_e *ORM_Expecter) ListSpecsByJobProposalIDs(ids interface{}, qopts ...interface{}) *ORM_ListSpecsByJobProposalIDs_Call
ListSpecsByJobProposalIDs is a helper method to define mock.On call
- ids []int64
- qopts ...pg.QOpt
func (*ORM_Expecter) RejectSpec ¶
func (_e *ORM_Expecter) RejectSpec(id interface{}, qopts ...interface{}) *ORM_RejectSpec_Call
RejectSpec is a helper method to define mock.On call
- id int64
- qopts ...pg.QOpt
func (*ORM_Expecter) RevokeSpec ¶
func (_e *ORM_Expecter) RevokeSpec(id interface{}, qopts ...interface{}) *ORM_RevokeSpec_Call
RevokeSpec is a helper method to define mock.On call
- id int64
- qopts ...pg.QOpt
func (*ORM_Expecter) UpdateChainConfig ¶
func (_e *ORM_Expecter) UpdateChainConfig(cfg interface{}) *ORM_UpdateChainConfig_Call
UpdateChainConfig is a helper method to define mock.On call
- cfg feeds.ChainConfig
func (*ORM_Expecter) UpdateJobProposalStatus ¶
func (_e *ORM_Expecter) UpdateJobProposalStatus(id interface{}, status interface{}, qopts ...interface{}) *ORM_UpdateJobProposalStatus_Call
UpdateJobProposalStatus is a helper method to define mock.On call
- id int64
- status feeds.JobProposalStatus
- qopts ...pg.QOpt
func (*ORM_Expecter) UpdateManager ¶
func (_e *ORM_Expecter) UpdateManager(mgr interface{}, qopts ...interface{}) *ORM_UpdateManager_Call
UpdateManager is a helper method to define mock.On call
- mgr feeds.FeedsManager
- qopts ...pg.QOpt
func (*ORM_Expecter) UpdateSpecDefinition ¶
func (_e *ORM_Expecter) UpdateSpecDefinition(id interface{}, spec interface{}, qopts ...interface{}) *ORM_UpdateSpecDefinition_Call
UpdateSpecDefinition is a helper method to define mock.On call
- id int64
- spec string
- qopts ...pg.QOpt
func (*ORM_Expecter) UpsertJobProposal ¶
func (_e *ORM_Expecter) UpsertJobProposal(jp interface{}, qopts ...interface{}) *ORM_UpsertJobProposal_Call
UpsertJobProposal is a helper method to define mock.On call
- jp *feeds.JobProposal
- qopts ...pg.QOpt
type ORM_GetApprovedSpec_Call ¶
ORM_GetApprovedSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetApprovedSpec'
func (*ORM_GetApprovedSpec_Call) Return ¶
func (_c *ORM_GetApprovedSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetApprovedSpec_Call
func (*ORM_GetApprovedSpec_Call) Run ¶
func (_c *ORM_GetApprovedSpec_Call) Run(run func(jpID int64, qopts ...pg.QOpt)) *ORM_GetApprovedSpec_Call
func (*ORM_GetApprovedSpec_Call) RunAndReturn ¶
func (_c *ORM_GetApprovedSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetApprovedSpec_Call
type ORM_GetChainConfig_Call ¶
ORM_GetChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChainConfig'
func (*ORM_GetChainConfig_Call) Return ¶
func (_c *ORM_GetChainConfig_Call) Return(_a0 *feeds.ChainConfig, _a1 error) *ORM_GetChainConfig_Call
func (*ORM_GetChainConfig_Call) Run ¶
func (_c *ORM_GetChainConfig_Call) Run(run func(id int64)) *ORM_GetChainConfig_Call
func (*ORM_GetChainConfig_Call) RunAndReturn ¶
func (_c *ORM_GetChainConfig_Call) RunAndReturn(run func(int64) (*feeds.ChainConfig, error)) *ORM_GetChainConfig_Call
type ORM_GetJobProposalByRemoteUUID_Call ¶
ORM_GetJobProposalByRemoteUUID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobProposalByRemoteUUID'
func (*ORM_GetJobProposalByRemoteUUID_Call) Return ¶
func (_c *ORM_GetJobProposalByRemoteUUID_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposalByRemoteUUID_Call
func (*ORM_GetJobProposalByRemoteUUID_Call) Run ¶
func (_c *ORM_GetJobProposalByRemoteUUID_Call) Run(run func(_a0 uuid.UUID)) *ORM_GetJobProposalByRemoteUUID_Call
func (*ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn ¶
func (_c *ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn(run func(uuid.UUID) (*feeds.JobProposal, error)) *ORM_GetJobProposalByRemoteUUID_Call
type ORM_GetJobProposal_Call ¶
ORM_GetJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobProposal'
func (*ORM_GetJobProposal_Call) Return ¶
func (_c *ORM_GetJobProposal_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposal_Call
func (*ORM_GetJobProposal_Call) Run ¶
func (_c *ORM_GetJobProposal_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetJobProposal_Call
func (*ORM_GetJobProposal_Call) RunAndReturn ¶
func (_c *ORM_GetJobProposal_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposal, error)) *ORM_GetJobProposal_Call
type ORM_GetLatestSpec_Call ¶
ORM_GetLatestSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestSpec'
func (*ORM_GetLatestSpec_Call) Return ¶
func (_c *ORM_GetLatestSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetLatestSpec_Call
func (*ORM_GetLatestSpec_Call) Run ¶
func (_c *ORM_GetLatestSpec_Call) Run(run func(jpID int64)) *ORM_GetLatestSpec_Call
func (*ORM_GetLatestSpec_Call) RunAndReturn ¶
func (_c *ORM_GetLatestSpec_Call) RunAndReturn(run func(int64) (*feeds.JobProposalSpec, error)) *ORM_GetLatestSpec_Call
type ORM_GetManager_Call ¶
ORM_GetManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManager'
func (*ORM_GetManager_Call) Return ¶
func (_c *ORM_GetManager_Call) Return(_a0 *feeds.FeedsManager, _a1 error) *ORM_GetManager_Call
func (*ORM_GetManager_Call) Run ¶
func (_c *ORM_GetManager_Call) Run(run func(id int64)) *ORM_GetManager_Call
func (*ORM_GetManager_Call) RunAndReturn ¶
func (_c *ORM_GetManager_Call) RunAndReturn(run func(int64) (*feeds.FeedsManager, error)) *ORM_GetManager_Call
type ORM_GetSpec_Call ¶
ORM_GetSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSpec'
func (*ORM_GetSpec_Call) Return ¶
func (_c *ORM_GetSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetSpec_Call
func (*ORM_GetSpec_Call) Run ¶
func (_c *ORM_GetSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_GetSpec_Call
func (*ORM_GetSpec_Call) RunAndReturn ¶
func (_c *ORM_GetSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) (*feeds.JobProposalSpec, error)) *ORM_GetSpec_Call
type ORM_IsJobManaged_Call ¶
ORM_IsJobManaged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsJobManaged'
func (*ORM_IsJobManaged_Call) Return ¶
func (_c *ORM_IsJobManaged_Call) Return(_a0 bool, _a1 error) *ORM_IsJobManaged_Call
func (*ORM_IsJobManaged_Call) Run ¶
func (_c *ORM_IsJobManaged_Call) Run(run func(jobID int64, qopts ...pg.QOpt)) *ORM_IsJobManaged_Call
func (*ORM_IsJobManaged_Call) RunAndReturn ¶
func (_c *ORM_IsJobManaged_Call) RunAndReturn(run func(int64, ...pg.QOpt) (bool, error)) *ORM_IsJobManaged_Call
type ORM_ListChainConfigsByManagerIDs_Call ¶
ORM_ListChainConfigsByManagerIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListChainConfigsByManagerIDs'
func (*ORM_ListChainConfigsByManagerIDs_Call) Return ¶
func (_c *ORM_ListChainConfigsByManagerIDs_Call) Return(_a0 []feeds.ChainConfig, _a1 error) *ORM_ListChainConfigsByManagerIDs_Call
func (*ORM_ListChainConfigsByManagerIDs_Call) Run ¶
func (_c *ORM_ListChainConfigsByManagerIDs_Call) Run(run func(mgrIDs []int64)) *ORM_ListChainConfigsByManagerIDs_Call
func (*ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn ¶
func (_c *ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn(run func([]int64) ([]feeds.ChainConfig, error)) *ORM_ListChainConfigsByManagerIDs_Call
type ORM_ListJobProposalsByManagersIDs_Call ¶
ORM_ListJobProposalsByManagersIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobProposalsByManagersIDs'
func (*ORM_ListJobProposalsByManagersIDs_Call) Return ¶
func (_c *ORM_ListJobProposalsByManagersIDs_Call) Return(_a0 []feeds.JobProposal, _a1 error) *ORM_ListJobProposalsByManagersIDs_Call
func (*ORM_ListJobProposalsByManagersIDs_Call) Run ¶
func (_c *ORM_ListJobProposalsByManagersIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListJobProposalsByManagersIDs_Call
func (*ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn ¶
func (_c *ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposal, error)) *ORM_ListJobProposalsByManagersIDs_Call
type ORM_ListJobProposals_Call ¶
ORM_ListJobProposals_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobProposals'
func (*ORM_ListJobProposals_Call) Return ¶
func (_c *ORM_ListJobProposals_Call) Return(jps []feeds.JobProposal, err error) *ORM_ListJobProposals_Call
func (*ORM_ListJobProposals_Call) Run ¶
func (_c *ORM_ListJobProposals_Call) Run(run func()) *ORM_ListJobProposals_Call
func (*ORM_ListJobProposals_Call) RunAndReturn ¶
func (_c *ORM_ListJobProposals_Call) RunAndReturn(run func() ([]feeds.JobProposal, error)) *ORM_ListJobProposals_Call
type ORM_ListManagersByIDs_Call ¶
ORM_ListManagersByIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListManagersByIDs'
func (*ORM_ListManagersByIDs_Call) Return ¶
func (_c *ORM_ListManagersByIDs_Call) Return(_a0 []feeds.FeedsManager, _a1 error) *ORM_ListManagersByIDs_Call
func (*ORM_ListManagersByIDs_Call) Run ¶
func (_c *ORM_ListManagersByIDs_Call) Run(run func(ids []int64)) *ORM_ListManagersByIDs_Call
func (*ORM_ListManagersByIDs_Call) RunAndReturn ¶
func (_c *ORM_ListManagersByIDs_Call) RunAndReturn(run func([]int64) ([]feeds.FeedsManager, error)) *ORM_ListManagersByIDs_Call
type ORM_ListManagers_Call ¶
ORM_ListManagers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListManagers'
func (*ORM_ListManagers_Call) Return ¶
func (_c *ORM_ListManagers_Call) Return(mgrs []feeds.FeedsManager, err error) *ORM_ListManagers_Call
func (*ORM_ListManagers_Call) Run ¶
func (_c *ORM_ListManagers_Call) Run(run func()) *ORM_ListManagers_Call
func (*ORM_ListManagers_Call) RunAndReturn ¶
func (_c *ORM_ListManagers_Call) RunAndReturn(run func() ([]feeds.FeedsManager, error)) *ORM_ListManagers_Call
type ORM_ListSpecsByJobProposalIDs_Call ¶
ORM_ListSpecsByJobProposalIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSpecsByJobProposalIDs'
func (*ORM_ListSpecsByJobProposalIDs_Call) Return ¶
func (_c *ORM_ListSpecsByJobProposalIDs_Call) Return(_a0 []feeds.JobProposalSpec, _a1 error) *ORM_ListSpecsByJobProposalIDs_Call
func (*ORM_ListSpecsByJobProposalIDs_Call) Run ¶
func (_c *ORM_ListSpecsByJobProposalIDs_Call) Run(run func(ids []int64, qopts ...pg.QOpt)) *ORM_ListSpecsByJobProposalIDs_Call
func (*ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn ¶
func (_c *ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn(run func([]int64, ...pg.QOpt) ([]feeds.JobProposalSpec, error)) *ORM_ListSpecsByJobProposalIDs_Call
type ORM_RejectSpec_Call ¶
ORM_RejectSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RejectSpec'
func (*ORM_RejectSpec_Call) Return ¶
func (_c *ORM_RejectSpec_Call) Return(_a0 error) *ORM_RejectSpec_Call
func (*ORM_RejectSpec_Call) Run ¶
func (_c *ORM_RejectSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_RejectSpec_Call
func (*ORM_RejectSpec_Call) RunAndReturn ¶
func (_c *ORM_RejectSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_RejectSpec_Call
type ORM_RevokeSpec_Call ¶
ORM_RevokeSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RevokeSpec'
func (*ORM_RevokeSpec_Call) Return ¶
func (_c *ORM_RevokeSpec_Call) Return(_a0 error) *ORM_RevokeSpec_Call
func (*ORM_RevokeSpec_Call) Run ¶
func (_c *ORM_RevokeSpec_Call) Run(run func(id int64, qopts ...pg.QOpt)) *ORM_RevokeSpec_Call
func (*ORM_RevokeSpec_Call) RunAndReturn ¶
func (_c *ORM_RevokeSpec_Call) RunAndReturn(run func(int64, ...pg.QOpt) error) *ORM_RevokeSpec_Call
type ORM_UpdateChainConfig_Call ¶
ORM_UpdateChainConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateChainConfig'
func (*ORM_UpdateChainConfig_Call) Return ¶
func (_c *ORM_UpdateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_UpdateChainConfig_Call
func (*ORM_UpdateChainConfig_Call) Run ¶
func (_c *ORM_UpdateChainConfig_Call) Run(run func(cfg feeds.ChainConfig)) *ORM_UpdateChainConfig_Call
func (*ORM_UpdateChainConfig_Call) RunAndReturn ¶
func (_c *ORM_UpdateChainConfig_Call) RunAndReturn(run func(feeds.ChainConfig) (int64, error)) *ORM_UpdateChainConfig_Call
type ORM_UpdateJobProposalStatus_Call ¶
ORM_UpdateJobProposalStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobProposalStatus'
func (*ORM_UpdateJobProposalStatus_Call) Return ¶
func (_c *ORM_UpdateJobProposalStatus_Call) Return(_a0 error) *ORM_UpdateJobProposalStatus_Call
func (*ORM_UpdateJobProposalStatus_Call) Run ¶
func (_c *ORM_UpdateJobProposalStatus_Call) Run(run func(id int64, status feeds.JobProposalStatus, qopts ...pg.QOpt)) *ORM_UpdateJobProposalStatus_Call
func (*ORM_UpdateJobProposalStatus_Call) RunAndReturn ¶
func (_c *ORM_UpdateJobProposalStatus_Call) RunAndReturn(run func(int64, feeds.JobProposalStatus, ...pg.QOpt) error) *ORM_UpdateJobProposalStatus_Call
type ORM_UpdateManager_Call ¶
ORM_UpdateManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateManager'
func (*ORM_UpdateManager_Call) Return ¶
func (_c *ORM_UpdateManager_Call) Return(_a0 error) *ORM_UpdateManager_Call
func (*ORM_UpdateManager_Call) Run ¶
func (_c *ORM_UpdateManager_Call) Run(run func(mgr feeds.FeedsManager, qopts ...pg.QOpt)) *ORM_UpdateManager_Call
func (*ORM_UpdateManager_Call) RunAndReturn ¶
func (_c *ORM_UpdateManager_Call) RunAndReturn(run func(feeds.FeedsManager, ...pg.QOpt) error) *ORM_UpdateManager_Call
type ORM_UpdateSpecDefinition_Call ¶
ORM_UpdateSpecDefinition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateSpecDefinition'
func (*ORM_UpdateSpecDefinition_Call) Return ¶
func (_c *ORM_UpdateSpecDefinition_Call) Return(_a0 error) *ORM_UpdateSpecDefinition_Call
func (*ORM_UpdateSpecDefinition_Call) Run ¶
func (_c *ORM_UpdateSpecDefinition_Call) Run(run func(id int64, spec string, qopts ...pg.QOpt)) *ORM_UpdateSpecDefinition_Call
func (*ORM_UpdateSpecDefinition_Call) RunAndReturn ¶
func (_c *ORM_UpdateSpecDefinition_Call) RunAndReturn(run func(int64, string, ...pg.QOpt) error) *ORM_UpdateSpecDefinition_Call
type ORM_UpsertJobProposal_Call ¶
ORM_UpsertJobProposal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertJobProposal'
func (*ORM_UpsertJobProposal_Call) Return ¶
func (_c *ORM_UpsertJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_UpsertJobProposal_Call
func (*ORM_UpsertJobProposal_Call) Run ¶
func (_c *ORM_UpsertJobProposal_Call) Run(run func(jp *feeds.JobProposal, qopts ...pg.QOpt)) *ORM_UpsertJobProposal_Call
func (*ORM_UpsertJobProposal_Call) RunAndReturn ¶
func (_c *ORM_UpsertJobProposal_Call) RunAndReturn(run func(*feeds.JobProposal, ...pg.QOpt) (int64, error)) *ORM_UpsertJobProposal_Call
type Service ¶
Service is an autogenerated mock type for the Service type
func NewService ¶
NewService creates a new instance of Service. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Service) ApproveSpec ¶
ApproveSpec provides a mock function with given fields: ctx, id, force
func (*Service) CancelSpec ¶
CancelSpec provides a mock function with given fields: ctx, id
func (*Service) CountJobProposalsByStatus ¶
func (_m *Service) CountJobProposalsByStatus() (*feeds.JobProposalCounts, error)
CountJobProposalsByStatus provides a mock function with given fields:
func (*Service) CountManagers ¶
CountManagers provides a mock function with given fields:
func (*Service) CreateChainConfig ¶
CreateChainConfig provides a mock function with given fields: ctx, cfg
func (*Service) DeleteChainConfig ¶
DeleteChainConfig provides a mock function with given fields: ctx, id
func (*Service) GetChainConfig ¶
func (_m *Service) GetChainConfig(id int64) (*feeds.ChainConfig, error)
GetChainConfig provides a mock function with given fields: id
func (*Service) GetJobProposal ¶
func (_m *Service) GetJobProposal(id int64) (*feeds.JobProposal, error)
GetJobProposal provides a mock function with given fields: id
func (*Service) GetManager ¶
func (_m *Service) GetManager(id int64) (*feeds.FeedsManager, error)
GetManager provides a mock function with given fields: id
func (*Service) GetSpec ¶
func (_m *Service) GetSpec(id int64) (*feeds.JobProposalSpec, error)
GetSpec provides a mock function with given fields: id
func (*Service) IsJobManaged ¶
IsJobManaged provides a mock function with given fields: ctx, jobID
func (*Service) ListChainConfigsByManagerIDs ¶
func (_m *Service) ListChainConfigsByManagerIDs(mgrIDs []int64) ([]feeds.ChainConfig, error)
ListChainConfigsByManagerIDs provides a mock function with given fields: mgrIDs
func (*Service) ListJobProposals ¶
func (_m *Service) ListJobProposals() ([]feeds.JobProposal, error)
ListJobProposals provides a mock function with given fields:
func (*Service) ListJobProposalsByManagersIDs ¶
func (_m *Service) ListJobProposalsByManagersIDs(ids []int64) ([]feeds.JobProposal, error)
ListJobProposalsByManagersIDs provides a mock function with given fields: ids
func (*Service) ListManagers ¶
func (_m *Service) ListManagers() ([]feeds.FeedsManager, error)
ListManagers provides a mock function with given fields:
func (*Service) ListManagersByIDs ¶
func (_m *Service) ListManagersByIDs(ids []int64) ([]feeds.FeedsManager, error)
ListManagersByIDs provides a mock function with given fields: ids
func (*Service) ListSpecsByJobProposalIDs ¶
func (_m *Service) ListSpecsByJobProposalIDs(ids []int64) ([]feeds.JobProposalSpec, error)
ListSpecsByJobProposalIDs provides a mock function with given fields: ids
func (*Service) ProposeJob ¶
ProposeJob provides a mock function with given fields: ctx, args
func (*Service) RegisterManager ¶
func (_m *Service) RegisterManager(ctx context.Context, params feeds.RegisterManagerParams) (int64, error)
RegisterManager provides a mock function with given fields: ctx, params
func (*Service) RejectSpec ¶
RejectSpec provides a mock function with given fields: ctx, id
func (*Service) SyncNodeInfo ¶
SyncNodeInfo provides a mock function with given fields: ctx, id
func (*Service) Unsafe_SetConnectionsManager ¶
func (_m *Service) Unsafe_SetConnectionsManager(_a0 feeds.ConnectionsManager)
Unsafe_SetConnectionsManager provides a mock function with given fields: _a0
func (*Service) UpdateChainConfig ¶
UpdateChainConfig provides a mock function with given fields: ctx, cfg
func (*Service) UpdateManager ¶
UpdateManager provides a mock function with given fields: ctx, mgr