Documentation ¶
Overview ¶
Package mock_domain is a generated GoMock package.
Package mock_domain is a generated GoMock package.
Package mock_domain is a generated GoMock package.
Package mock_domain is a generated GoMock package.
Index ¶
- type ApplicationExecutionStatesRepositorySpy
- func (a *ApplicationExecutionStatesRepositorySpy) Aggregate(pipeline mongo.Pipeline) (*[]bson.M, error)
- func (a *ApplicationExecutionStatesRepositorySpy) BulkCreate(documents *[]bson.M) error
- func (a *ApplicationExecutionStatesRepositorySpy) BulkDeleteByExecutionID(id string) error
- func (a *ApplicationExecutionStatesRepositorySpy) Create(date time.Time, executionID primitive.ObjectID, state interface{}) error
- func (a *ApplicationExecutionStatesRepositorySpy) FindLast(filter interface{}) (*domain.ApplicationExecutionState, error)
- type BenchmarkRepositorySpy
- func (r *BenchmarkRepositorySpy) DeleteByID(id string) error
- func (r *BenchmarkRepositorySpy) FindAll() (*[]domain.Benchmark, error)
- func (r *BenchmarkRepositorySpy) InsertOne(benchmark *domain.Benchmark) error
- func (r *BenchmarkRepositorySpy) UpdateBenchmarkCompleted(id string, output *domain.BenchmarkOutput) error
- type BenchmarkServiceSpy
- func (s *BenchmarkServiceSpy) AggregateApplicationState(pipeline mongo.Pipeline) (*[]bson.M, error)
- func (s *BenchmarkServiceSpy) BulkRun(inputs []domain.BenchmarkInput, c chan domain.BenchmarkResult)
- func (s *BenchmarkServiceSpy) Create(input domain.BenchmarkInput) (*domain.Benchmark, error)
- func (s *BenchmarkServiceSpy) DeleteByID(id string) error
- func (s *BenchmarkServiceSpy) FindAll() (*[]domain.Benchmark, error)
- func (s *BenchmarkServiceSpy) GetDataSources() map[string]map[string]string
- func (s *BenchmarkServiceSpy) HandleBenchmark(benchmark *domain.Benchmark) error
- func (s *BenchmarkServiceSpy) Run(input domain.BenchmarkInput, benchmarkID *primitive.ObjectID) (*domain.BenchmarkOutput, error)
- type EmailServiceSpy
- type MockAccountService
- func (m *MockAccountService) CheckAssetWithCloserPriceExists(price, limit float32) (bool, error)
- func (m *MockAccountService) CreateAsset(amount, price float32, time time.Time) (*domain.Asset, error)
- func (m *MockAccountService) Deposit(amount float32) error
- func (m *MockAccountService) EXPECT() *MockAccountServiceMockRecorder
- func (m *MockAccountService) FindAllAssets() (*[]domain.Asset, error)
- func (m *MockAccountService) FindPendingAssets() (*[]domain.Asset, error)
- func (m *MockAccountService) GetAmount() (float32, error)
- func (m *MockAccountService) GetBalance(startDate, endDate time.Time) (float32, error)
- func (m *MockAccountService) SellAsset(assetID string, price float32, time time.Time) error
- func (m *MockAccountService) Withdraw(amount float32) error
- type MockAccountServiceMockRecorder
- func (mr *MockAccountServiceMockRecorder) CheckAssetWithCloserPriceExists(price, limit interface{}) *gomock.Call
- func (mr *MockAccountServiceMockRecorder) CreateAsset(amount, price, time interface{}) *gomock.Call
- func (mr *MockAccountServiceMockRecorder) Deposit(amount interface{}) *gomock.Call
- func (mr *MockAccountServiceMockRecorder) FindAllAssets() *gomock.Call
- func (mr *MockAccountServiceMockRecorder) FindPendingAssets() *gomock.Call
- func (mr *MockAccountServiceMockRecorder) GetAmount() *gomock.Call
- func (mr *MockAccountServiceMockRecorder) GetBalance(startDate, endDate interface{}) *gomock.Call
- func (mr *MockAccountServiceMockRecorder) SellAsset(assetID, price, time interface{}) *gomock.Call
- func (mr *MockAccountServiceMockRecorder) Withdraw(amount interface{}) *gomock.Call
- type MockAccountServiceReader
- func (m *MockAccountServiceReader) CheckAssetWithCloserPriceExists(price, limit float32) (bool, error)
- func (m *MockAccountServiceReader) EXPECT() *MockAccountServiceReaderMockRecorder
- func (m *MockAccountServiceReader) FindAllAssets() (*[]domain.Asset, error)
- func (m *MockAccountServiceReader) FindPendingAssets() (*[]domain.Asset, error)
- func (m *MockAccountServiceReader) GetAmount() (float32, error)
- func (m *MockAccountServiceReader) GetBalance(startDate, endDate time.Time) (float32, error)
- type MockAccountServiceReaderMockRecorder
- func (mr *MockAccountServiceReaderMockRecorder) CheckAssetWithCloserPriceExists(price, limit interface{}) *gomock.Call
- func (mr *MockAccountServiceReaderMockRecorder) FindAllAssets() *gomock.Call
- func (mr *MockAccountServiceReaderMockRecorder) FindPendingAssets() *gomock.Call
- func (mr *MockAccountServiceReaderMockRecorder) GetAmount() *gomock.Call
- func (mr *MockAccountServiceReaderMockRecorder) GetBalance(startDate, endDate interface{}) *gomock.Call
- type MockAccountsRepository
- func (m *MockAccountsRepository) Create(broker string, amount float32) (*domain.Account, error)
- func (m *MockAccountsRepository) Deposit(id string, amount float32) error
- func (m *MockAccountsRepository) EXPECT() *MockAccountsRepositoryMockRecorder
- func (m *MockAccountsRepository) FindByBroker(broker string) (*domain.Account, error)
- func (m *MockAccountsRepository) FindById(id string) (*domain.Account, error)
- func (m *MockAccountsRepository) Withdraw(id string, amount float32) error
- type MockAccountsRepositoryMockRecorder
- func (mr *MockAccountsRepositoryMockRecorder) Create(broker, amount interface{}) *gomock.Call
- func (mr *MockAccountsRepositoryMockRecorder) Deposit(id, amount interface{}) *gomock.Call
- func (mr *MockAccountsRepositoryMockRecorder) FindByBroker(broker interface{}) *gomock.Call
- func (mr *MockAccountsRepositoryMockRecorder) FindById(id interface{}) *gomock.Call
- func (mr *MockAccountsRepositoryMockRecorder) Withdraw(id, amount interface{}) *gomock.Call
- type MockApplicationRepository
- func (m *MockApplicationRepository) Create(asset string, options domain.ApplicationOptions, acountID primitive.ObjectID) (*domain.Application, error)
- func (m *MockApplicationRepository) DeleteByID(id string) error
- func (m *MockApplicationRepository) EXPECT() *MockApplicationRepositoryMockRecorder
- func (m *MockApplicationRepository) FindAll() (*[]domain.Application, error)
- func (m *MockApplicationRepository) FindByID(id string) (*domain.Application, error)
- type MockApplicationRepositoryMockRecorder
- func (mr *MockApplicationRepositoryMockRecorder) Create(asset, options, acountID interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) DeleteByID(id interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) FindAll() *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) FindByID(id interface{}) *gomock.Call
- type MockApplicationService
- func (m *MockApplicationService) DeleteByID(id string) error
- func (m *MockApplicationService) EXPECT() *MockApplicationServiceMockRecorder
- func (m *MockApplicationService) FindAll() (*[]domain.Application, error)
- func (m *MockApplicationService) GetLastState(appID primitive.ObjectID) (*domain.ApplicationExecutionState, error)
- func (m *MockApplicationService) GetLogEvents(appID primitive.ObjectID) (*[]domain.EventLog, error)
- func (m *MockApplicationService) GetStateAggregated(appID string, startDate, endDate time.Time) (*[]bson.M, error)
- type MockApplicationServiceMockRecorder
- func (mr *MockApplicationServiceMockRecorder) DeleteByID(id interface{}) *gomock.Call
- func (mr *MockApplicationServiceMockRecorder) FindAll() *gomock.Call
- func (mr *MockApplicationServiceMockRecorder) GetLastState(appID interface{}) *gomock.Call
- func (mr *MockApplicationServiceMockRecorder) GetLogEvents(appID interface{}) *gomock.Call
- func (mr *MockApplicationServiceMockRecorder) GetStateAggregated(appID, startDate, endDate interface{}) *gomock.Call
- type MockAssetPriceRepository
- func (m *MockAssetPriceRepository) Aggregate(pipeline mongo.Pipeline) (*[]bson.M, error)
- func (m *MockAssetPriceRepository) BulkCreate(documents *[]bson.M) error
- func (m *MockAssetPriceRepository) Create(ohlc *domain.OHLC, asset string) error
- func (m *MockAssetPriceRepository) EXPECT() *MockAssetPriceRepositoryMockRecorder
- func (m *MockAssetPriceRepository) FindAll(filter interface{}) (*[]domain.AssetPrice, error)
- func (m *MockAssetPriceRepository) GetLastAssetsPrices(asset string, limit int) (*[]domain.AssetPrice, error)
- type MockAssetPriceRepositoryMockRecorder
- func (mr *MockAssetPriceRepositoryMockRecorder) Aggregate(pipeline interface{}) *gomock.Call
- func (mr *MockAssetPriceRepositoryMockRecorder) BulkCreate(documents interface{}) *gomock.Call
- func (mr *MockAssetPriceRepositoryMockRecorder) Create(ohlc, asset interface{}) *gomock.Call
- func (mr *MockAssetPriceRepositoryMockRecorder) FindAll(filter interface{}) *gomock.Call
- func (mr *MockAssetPriceRepositoryMockRecorder) GetLastAssetsPrices(asset, limit interface{}) *gomock.Call
- type MockAssetsPricesService
- func (m *MockAssetsPricesService) Create(ohlc *domain.OHLC, asset string) error
- func (m *MockAssetsPricesService) EXPECT() *MockAssetsPricesServiceMockRecorder
- func (m *MockAssetsPricesService) FetchAndStoreAssetPrices(asset string, endDate time.Time) error
- func (m *MockAssetsPricesService) GetLastAssetsPrices(asset string, limit int) (*[]domain.AssetPrice, error)
- type MockAssetsPricesServiceMockRecorder
- func (mr *MockAssetsPricesServiceMockRecorder) Create(ohlc, asset interface{}) *gomock.Call
- func (mr *MockAssetsPricesServiceMockRecorder) FetchAndStoreAssetPrices(asset, endDate interface{}) *gomock.Call
- func (mr *MockAssetsPricesServiceMockRecorder) GetLastAssetsPrices(asset, limit interface{}) *gomock.Call
- type MockNotificationsRepository
- func (m *MockNotificationsRepository) BulkDelete(filter bson.M) error
- func (m *MockNotificationsRepository) BulkDeleteByApplicationID(id string) error
- func (m *MockNotificationsRepository) Create(notification *domain.Notification) error
- func (m *MockNotificationsRepository) EXPECT() *MockNotificationsRepositoryMockRecorder
- func (m *MockNotificationsRepository) FindLastEventLogsNotificationDate() (time.Time, error)
- func (m *MockNotificationsRepository) Sent(id primitive.ObjectID) error
- type MockNotificationsRepositoryMockRecorder
- func (mr *MockNotificationsRepositoryMockRecorder) BulkDelete(filter interface{}) *gomock.Call
- func (mr *MockNotificationsRepositoryMockRecorder) BulkDeleteByApplicationID(id interface{}) *gomock.Call
- func (mr *MockNotificationsRepositoryMockRecorder) Create(notification interface{}) *gomock.Call
- func (mr *MockNotificationsRepositoryMockRecorder) FindLastEventLogsNotificationDate() *gomock.Call
- func (mr *MockNotificationsRepositoryMockRecorder) Sent(id interface{}) *gomock.Call
- type MockNotificationsService
- func (m *MockNotificationsService) BulkDeleteByApplicationID(id string) error
- func (m *MockNotificationsService) CreateEmailNotification(subject, message, notificationType string) error
- func (m *MockNotificationsService) EXPECT() *MockNotificationsServiceMockRecorder
- func (m *MockNotificationsService) FindLastEventLogsNotificationDate() (time.Time, error)
- func (m *MockNotificationsService) SendEmail(subject, body string) error
- func (m *MockNotificationsService) ShouldSendNotification() bool
- type MockNotificationsServiceMockRecorder
- func (mr *MockNotificationsServiceMockRecorder) BulkDeleteByApplicationID(id interface{}) *gomock.Call
- func (mr *MockNotificationsServiceMockRecorder) CreateEmailNotification(subject, message, notificationType interface{}) *gomock.Call
- func (mr *MockNotificationsServiceMockRecorder) FindLastEventLogsNotificationDate() *gomock.Call
- func (mr *MockNotificationsServiceMockRecorder) SendEmail(subject, body interface{}) *gomock.Call
- func (mr *MockNotificationsServiceMockRecorder) ShouldSendNotification() *gomock.Call
- type RepositorySpy
- func (r *RepositorySpy) Aggregate(documents interface{}, pipelineOptions mongo.Pipeline) error
- func (r *RepositorySpy) BulkCreate(documents *[]bson.M) error
- func (r *RepositorySpy) BulkDelete(filter bson.M) error
- func (r *RepositorySpy) BulkUpdate(filter bson.M, update bson.M) error
- func (r *RepositorySpy) BulkUpsert(documents []bson.M) error
- func (r *RepositorySpy) DeleteByID(id string) error
- func (r *RepositorySpy) FindAll(documents interface{}, query interface{}, opts *options.FindOptions) error
- func (r *RepositorySpy) FindOne(document interface{}, query interface{}, opts *options.FindOneOptions) error
- func (r *RepositorySpy) InsertOne(document interface{}) error
- func (r *RepositorySpy) UpdateOne(query interface{}, update interface{}) error
- type UpdateBenchmarkArgs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplicationExecutionStatesRepositorySpy ¶
type ApplicationExecutionStatesRepositorySpy struct { CreateCalls [][]interface{} AggregateCalls []interface{} BulkCreateCalls []interface{} BulkDeleteCalls []string FindLastCalls []interface{} }
func (*ApplicationExecutionStatesRepositorySpy) BulkCreate ¶
func (a *ApplicationExecutionStatesRepositorySpy) BulkCreate(documents *[]bson.M) error
func (*ApplicationExecutionStatesRepositorySpy) BulkDeleteByExecutionID ¶
func (a *ApplicationExecutionStatesRepositorySpy) BulkDeleteByExecutionID(id string) error
func (*ApplicationExecutionStatesRepositorySpy) FindLast ¶
func (a *ApplicationExecutionStatesRepositorySpy) FindLast(filter interface{}) (*domain.ApplicationExecutionState, error)
type BenchmarkRepositorySpy ¶
type BenchmarkRepositorySpy struct { FindAllCalls int InsertOneCalls []domain.Benchmark DeleteByIdCalls []string UpdateBenchmarkCompletedCalls []UpdateBenchmarkArgs }
func (*BenchmarkRepositorySpy) DeleteByID ¶
func (r *BenchmarkRepositorySpy) DeleteByID(id string) error
func (*BenchmarkRepositorySpy) FindAll ¶
func (r *BenchmarkRepositorySpy) FindAll() (*[]domain.Benchmark, error)
func (*BenchmarkRepositorySpy) InsertOne ¶
func (r *BenchmarkRepositorySpy) InsertOne(benchmark *domain.Benchmark) error
func (*BenchmarkRepositorySpy) UpdateBenchmarkCompleted ¶
func (r *BenchmarkRepositorySpy) UpdateBenchmarkCompleted(id string, output *domain.BenchmarkOutput) error
type BenchmarkServiceSpy ¶
type BenchmarkServiceSpy struct { CreateCalls []domain.BenchmarkInput DeleteByIDCalls []string FindAllCalls int BulkRunCalls [][]interface{} RunCalls [][]interface{} HandleBenchmarkCalls []domain.Benchmark GetDataSourcesCalls int AggregateApplicationStateCalls []interface{} }
func (*BenchmarkServiceSpy) AggregateApplicationState ¶
func (*BenchmarkServiceSpy) BulkRun ¶
func (s *BenchmarkServiceSpy) BulkRun(inputs []domain.BenchmarkInput, c chan domain.BenchmarkResult)
func (*BenchmarkServiceSpy) Create ¶
func (s *BenchmarkServiceSpy) Create(input domain.BenchmarkInput) (*domain.Benchmark, error)
func (*BenchmarkServiceSpy) DeleteByID ¶
func (s *BenchmarkServiceSpy) DeleteByID(id string) error
func (*BenchmarkServiceSpy) FindAll ¶
func (s *BenchmarkServiceSpy) FindAll() (*[]domain.Benchmark, error)
func (*BenchmarkServiceSpy) GetDataSources ¶
func (s *BenchmarkServiceSpy) GetDataSources() map[string]map[string]string
func (*BenchmarkServiceSpy) HandleBenchmark ¶
func (s *BenchmarkServiceSpy) HandleBenchmark(benchmark *domain.Benchmark) error
func (*BenchmarkServiceSpy) Run ¶
func (s *BenchmarkServiceSpy) Run(input domain.BenchmarkInput, benchmarkID *primitive.ObjectID) (*domain.BenchmarkOutput, error)
type EmailServiceSpy ¶
type EmailServiceSpy struct {
SendMailCalls [][]interface{}
}
type MockAccountService ¶
type MockAccountService struct {
// contains filtered or unexported fields
}
MockAccountService is a mock of AccountService interface
func NewMockAccountService ¶
func NewMockAccountService(ctrl *gomock.Controller) *MockAccountService
NewMockAccountService creates a new mock instance
func (*MockAccountService) CheckAssetWithCloserPriceExists ¶
func (m *MockAccountService) CheckAssetWithCloserPriceExists(price, limit float32) (bool, error)
CheckAssetWithCloserPriceExists mocks base method
func (*MockAccountService) CreateAsset ¶
func (m *MockAccountService) CreateAsset(amount, price float32, time time.Time) (*domain.Asset, error)
CreateAsset mocks base method
func (*MockAccountService) Deposit ¶
func (m *MockAccountService) Deposit(amount float32) error
Deposit mocks base method
func (*MockAccountService) EXPECT ¶
func (m *MockAccountService) EXPECT() *MockAccountServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAccountService) FindAllAssets ¶
func (m *MockAccountService) FindAllAssets() (*[]domain.Asset, error)
FindAllAssets mocks base method
func (*MockAccountService) FindPendingAssets ¶
func (m *MockAccountService) FindPendingAssets() (*[]domain.Asset, error)
FindPendingAssets mocks base method
func (*MockAccountService) GetAmount ¶
func (m *MockAccountService) GetAmount() (float32, error)
GetAmount mocks base method
func (*MockAccountService) GetBalance ¶
func (m *MockAccountService) GetBalance(startDate, endDate time.Time) (float32, error)
GetBalance mocks base method
func (*MockAccountService) Withdraw ¶
func (m *MockAccountService) Withdraw(amount float32) error
Withdraw mocks base method
type MockAccountServiceMockRecorder ¶
type MockAccountServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockAccountServiceMockRecorder is the mock recorder for MockAccountService
func (*MockAccountServiceMockRecorder) CheckAssetWithCloserPriceExists ¶
func (mr *MockAccountServiceMockRecorder) CheckAssetWithCloserPriceExists(price, limit interface{}) *gomock.Call
CheckAssetWithCloserPriceExists indicates an expected call of CheckAssetWithCloserPriceExists
func (*MockAccountServiceMockRecorder) CreateAsset ¶
func (mr *MockAccountServiceMockRecorder) CreateAsset(amount, price, time interface{}) *gomock.Call
CreateAsset indicates an expected call of CreateAsset
func (*MockAccountServiceMockRecorder) Deposit ¶
func (mr *MockAccountServiceMockRecorder) Deposit(amount interface{}) *gomock.Call
Deposit indicates an expected call of Deposit
func (*MockAccountServiceMockRecorder) FindAllAssets ¶
func (mr *MockAccountServiceMockRecorder) FindAllAssets() *gomock.Call
FindAllAssets indicates an expected call of FindAllAssets
func (*MockAccountServiceMockRecorder) FindPendingAssets ¶
func (mr *MockAccountServiceMockRecorder) FindPendingAssets() *gomock.Call
FindPendingAssets indicates an expected call of FindPendingAssets
func (*MockAccountServiceMockRecorder) GetAmount ¶
func (mr *MockAccountServiceMockRecorder) GetAmount() *gomock.Call
GetAmount indicates an expected call of GetAmount
func (*MockAccountServiceMockRecorder) GetBalance ¶
func (mr *MockAccountServiceMockRecorder) GetBalance(startDate, endDate interface{}) *gomock.Call
GetBalance indicates an expected call of GetBalance
func (*MockAccountServiceMockRecorder) SellAsset ¶
func (mr *MockAccountServiceMockRecorder) SellAsset(assetID, price, time interface{}) *gomock.Call
SellAsset indicates an expected call of SellAsset
func (*MockAccountServiceMockRecorder) Withdraw ¶
func (mr *MockAccountServiceMockRecorder) Withdraw(amount interface{}) *gomock.Call
Withdraw indicates an expected call of Withdraw
type MockAccountServiceReader ¶
type MockAccountServiceReader struct {
// contains filtered or unexported fields
}
MockAccountServiceReader is a mock of AccountServiceReader interface
func NewMockAccountServiceReader ¶
func NewMockAccountServiceReader(ctrl *gomock.Controller) *MockAccountServiceReader
NewMockAccountServiceReader creates a new mock instance
func (*MockAccountServiceReader) CheckAssetWithCloserPriceExists ¶
func (m *MockAccountServiceReader) CheckAssetWithCloserPriceExists(price, limit float32) (bool, error)
CheckAssetWithCloserPriceExists mocks base method
func (*MockAccountServiceReader) EXPECT ¶
func (m *MockAccountServiceReader) EXPECT() *MockAccountServiceReaderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAccountServiceReader) FindAllAssets ¶
func (m *MockAccountServiceReader) FindAllAssets() (*[]domain.Asset, error)
FindAllAssets mocks base method
func (*MockAccountServiceReader) FindPendingAssets ¶
func (m *MockAccountServiceReader) FindPendingAssets() (*[]domain.Asset, error)
FindPendingAssets mocks base method
func (*MockAccountServiceReader) GetAmount ¶
func (m *MockAccountServiceReader) GetAmount() (float32, error)
GetAmount mocks base method
func (*MockAccountServiceReader) GetBalance ¶
func (m *MockAccountServiceReader) GetBalance(startDate, endDate time.Time) (float32, error)
GetBalance mocks base method
type MockAccountServiceReaderMockRecorder ¶
type MockAccountServiceReaderMockRecorder struct {
// contains filtered or unexported fields
}
MockAccountServiceReaderMockRecorder is the mock recorder for MockAccountServiceReader
func (*MockAccountServiceReaderMockRecorder) CheckAssetWithCloserPriceExists ¶
func (mr *MockAccountServiceReaderMockRecorder) CheckAssetWithCloserPriceExists(price, limit interface{}) *gomock.Call
CheckAssetWithCloserPriceExists indicates an expected call of CheckAssetWithCloserPriceExists
func (*MockAccountServiceReaderMockRecorder) FindAllAssets ¶
func (mr *MockAccountServiceReaderMockRecorder) FindAllAssets() *gomock.Call
FindAllAssets indicates an expected call of FindAllAssets
func (*MockAccountServiceReaderMockRecorder) FindPendingAssets ¶
func (mr *MockAccountServiceReaderMockRecorder) FindPendingAssets() *gomock.Call
FindPendingAssets indicates an expected call of FindPendingAssets
func (*MockAccountServiceReaderMockRecorder) GetAmount ¶
func (mr *MockAccountServiceReaderMockRecorder) GetAmount() *gomock.Call
GetAmount indicates an expected call of GetAmount
func (*MockAccountServiceReaderMockRecorder) GetBalance ¶
func (mr *MockAccountServiceReaderMockRecorder) GetBalance(startDate, endDate interface{}) *gomock.Call
GetBalance indicates an expected call of GetBalance
type MockAccountsRepository ¶
type MockAccountsRepository struct {
// contains filtered or unexported fields
}
MockAccountsRepository is a mock of AccountsRepository interface
func NewMockAccountsRepository ¶
func NewMockAccountsRepository(ctrl *gomock.Controller) *MockAccountsRepository
NewMockAccountsRepository creates a new mock instance
func (*MockAccountsRepository) Deposit ¶
func (m *MockAccountsRepository) Deposit(id string, amount float32) error
Deposit mocks base method
func (*MockAccountsRepository) EXPECT ¶
func (m *MockAccountsRepository) EXPECT() *MockAccountsRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAccountsRepository) FindByBroker ¶
func (m *MockAccountsRepository) FindByBroker(broker string) (*domain.Account, error)
FindByBroker mocks base method
type MockAccountsRepositoryMockRecorder ¶
type MockAccountsRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockAccountsRepositoryMockRecorder is the mock recorder for MockAccountsRepository
func (*MockAccountsRepositoryMockRecorder) Create ¶
func (mr *MockAccountsRepositoryMockRecorder) Create(broker, amount interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockAccountsRepositoryMockRecorder) Deposit ¶
func (mr *MockAccountsRepositoryMockRecorder) Deposit(id, amount interface{}) *gomock.Call
Deposit indicates an expected call of Deposit
func (*MockAccountsRepositoryMockRecorder) FindByBroker ¶
func (mr *MockAccountsRepositoryMockRecorder) FindByBroker(broker interface{}) *gomock.Call
FindByBroker indicates an expected call of FindByBroker
func (*MockAccountsRepositoryMockRecorder) FindById ¶
func (mr *MockAccountsRepositoryMockRecorder) FindById(id interface{}) *gomock.Call
FindById indicates an expected call of FindById
func (*MockAccountsRepositoryMockRecorder) Withdraw ¶
func (mr *MockAccountsRepositoryMockRecorder) Withdraw(id, amount interface{}) *gomock.Call
Withdraw indicates an expected call of Withdraw
type MockApplicationRepository ¶
type MockApplicationRepository struct {
// contains filtered or unexported fields
}
MockApplicationRepository is a mock of ApplicationRepository interface
func NewMockApplicationRepository ¶
func NewMockApplicationRepository(ctrl *gomock.Controller) *MockApplicationRepository
NewMockApplicationRepository creates a new mock instance
func (*MockApplicationRepository) Create ¶
func (m *MockApplicationRepository) Create(asset string, options domain.ApplicationOptions, acountID primitive.ObjectID) (*domain.Application, error)
Create mocks base method
func (*MockApplicationRepository) DeleteByID ¶
func (m *MockApplicationRepository) DeleteByID(id string) error
DeleteByID mocks base method
func (*MockApplicationRepository) EXPECT ¶
func (m *MockApplicationRepository) EXPECT() *MockApplicationRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockApplicationRepository) FindAll ¶
func (m *MockApplicationRepository) FindAll() (*[]domain.Application, error)
FindAll mocks base method
func (*MockApplicationRepository) FindByID ¶
func (m *MockApplicationRepository) FindByID(id string) (*domain.Application, error)
FindByID mocks base method
type MockApplicationRepositoryMockRecorder ¶
type MockApplicationRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockApplicationRepositoryMockRecorder is the mock recorder for MockApplicationRepository
func (*MockApplicationRepositoryMockRecorder) Create ¶
func (mr *MockApplicationRepositoryMockRecorder) Create(asset, options, acountID interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockApplicationRepositoryMockRecorder) DeleteByID ¶
func (mr *MockApplicationRepositoryMockRecorder) DeleteByID(id interface{}) *gomock.Call
DeleteByID indicates an expected call of DeleteByID
func (*MockApplicationRepositoryMockRecorder) FindAll ¶
func (mr *MockApplicationRepositoryMockRecorder) FindAll() *gomock.Call
FindAll indicates an expected call of FindAll
func (*MockApplicationRepositoryMockRecorder) FindByID ¶
func (mr *MockApplicationRepositoryMockRecorder) FindByID(id interface{}) *gomock.Call
FindByID indicates an expected call of FindByID
type MockApplicationService ¶
type MockApplicationService struct {
// contains filtered or unexported fields
}
MockApplicationService is a mock of ApplicationService interface
func NewMockApplicationService ¶
func NewMockApplicationService(ctrl *gomock.Controller) *MockApplicationService
NewMockApplicationService creates a new mock instance
func (*MockApplicationService) DeleteByID ¶
func (m *MockApplicationService) DeleteByID(id string) error
DeleteByID mocks base method
func (*MockApplicationService) EXPECT ¶
func (m *MockApplicationService) EXPECT() *MockApplicationServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockApplicationService) FindAll ¶
func (m *MockApplicationService) FindAll() (*[]domain.Application, error)
FindAll mocks base method
func (*MockApplicationService) GetLastState ¶
func (m *MockApplicationService) GetLastState(appID primitive.ObjectID) (*domain.ApplicationExecutionState, error)
GetLastState mocks base method
func (*MockApplicationService) GetLogEvents ¶
GetLogEvents mocks base method
func (*MockApplicationService) GetStateAggregated ¶
func (m *MockApplicationService) GetStateAggregated(appID string, startDate, endDate time.Time) (*[]bson.M, error)
GetStateAggregated mocks base method
type MockApplicationServiceMockRecorder ¶
type MockApplicationServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockApplicationServiceMockRecorder is the mock recorder for MockApplicationService
func (*MockApplicationServiceMockRecorder) DeleteByID ¶
func (mr *MockApplicationServiceMockRecorder) DeleteByID(id interface{}) *gomock.Call
DeleteByID indicates an expected call of DeleteByID
func (*MockApplicationServiceMockRecorder) FindAll ¶
func (mr *MockApplicationServiceMockRecorder) FindAll() *gomock.Call
FindAll indicates an expected call of FindAll
func (*MockApplicationServiceMockRecorder) GetLastState ¶
func (mr *MockApplicationServiceMockRecorder) GetLastState(appID interface{}) *gomock.Call
GetLastState indicates an expected call of GetLastState
func (*MockApplicationServiceMockRecorder) GetLogEvents ¶
func (mr *MockApplicationServiceMockRecorder) GetLogEvents(appID interface{}) *gomock.Call
GetLogEvents indicates an expected call of GetLogEvents
func (*MockApplicationServiceMockRecorder) GetStateAggregated ¶
func (mr *MockApplicationServiceMockRecorder) GetStateAggregated(appID, startDate, endDate interface{}) *gomock.Call
GetStateAggregated indicates an expected call of GetStateAggregated
type MockAssetPriceRepository ¶
type MockAssetPriceRepository struct {
// contains filtered or unexported fields
}
MockAssetPriceRepository is a mock of AssetPriceRepository interface
func NewMockAssetPriceRepository ¶
func NewMockAssetPriceRepository(ctrl *gomock.Controller) *MockAssetPriceRepository
NewMockAssetPriceRepository creates a new mock instance
func (*MockAssetPriceRepository) BulkCreate ¶
func (m *MockAssetPriceRepository) BulkCreate(documents *[]bson.M) error
BulkCreate mocks base method
func (*MockAssetPriceRepository) Create ¶
func (m *MockAssetPriceRepository) Create(ohlc *domain.OHLC, asset string) error
Create mocks base method
func (*MockAssetPriceRepository) EXPECT ¶
func (m *MockAssetPriceRepository) EXPECT() *MockAssetPriceRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAssetPriceRepository) FindAll ¶
func (m *MockAssetPriceRepository) FindAll(filter interface{}) (*[]domain.AssetPrice, error)
FindAll mocks base method
func (*MockAssetPriceRepository) GetLastAssetsPrices ¶
func (m *MockAssetPriceRepository) GetLastAssetsPrices(asset string, limit int) (*[]domain.AssetPrice, error)
GetLastAssetsPrices mocks base method
type MockAssetPriceRepositoryMockRecorder ¶
type MockAssetPriceRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockAssetPriceRepositoryMockRecorder is the mock recorder for MockAssetPriceRepository
func (*MockAssetPriceRepositoryMockRecorder) Aggregate ¶
func (mr *MockAssetPriceRepositoryMockRecorder) Aggregate(pipeline interface{}) *gomock.Call
Aggregate indicates an expected call of Aggregate
func (*MockAssetPriceRepositoryMockRecorder) BulkCreate ¶
func (mr *MockAssetPriceRepositoryMockRecorder) BulkCreate(documents interface{}) *gomock.Call
BulkCreate indicates an expected call of BulkCreate
func (*MockAssetPriceRepositoryMockRecorder) Create ¶
func (mr *MockAssetPriceRepositoryMockRecorder) Create(ohlc, asset interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockAssetPriceRepositoryMockRecorder) FindAll ¶
func (mr *MockAssetPriceRepositoryMockRecorder) FindAll(filter interface{}) *gomock.Call
FindAll indicates an expected call of FindAll
func (*MockAssetPriceRepositoryMockRecorder) GetLastAssetsPrices ¶
func (mr *MockAssetPriceRepositoryMockRecorder) GetLastAssetsPrices(asset, limit interface{}) *gomock.Call
GetLastAssetsPrices indicates an expected call of GetLastAssetsPrices
type MockAssetsPricesService ¶
type MockAssetsPricesService struct {
// contains filtered or unexported fields
}
MockAssetsPricesService is a mock of AssetsPricesService interface
func NewMockAssetsPricesService ¶
func NewMockAssetsPricesService(ctrl *gomock.Controller) *MockAssetsPricesService
NewMockAssetsPricesService creates a new mock instance
func (*MockAssetsPricesService) Create ¶
func (m *MockAssetsPricesService) Create(ohlc *domain.OHLC, asset string) error
Create mocks base method
func (*MockAssetsPricesService) EXPECT ¶
func (m *MockAssetsPricesService) EXPECT() *MockAssetsPricesServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockAssetsPricesService) FetchAndStoreAssetPrices ¶
func (m *MockAssetsPricesService) FetchAndStoreAssetPrices(asset string, endDate time.Time) error
FetchAndStoreAssetPrices mocks base method
func (*MockAssetsPricesService) GetLastAssetsPrices ¶
func (m *MockAssetsPricesService) GetLastAssetsPrices(asset string, limit int) (*[]domain.AssetPrice, error)
GetLastAssetsPrices mocks base method
type MockAssetsPricesServiceMockRecorder ¶
type MockAssetsPricesServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockAssetsPricesServiceMockRecorder is the mock recorder for MockAssetsPricesService
func (*MockAssetsPricesServiceMockRecorder) Create ¶
func (mr *MockAssetsPricesServiceMockRecorder) Create(ohlc, asset interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockAssetsPricesServiceMockRecorder) FetchAndStoreAssetPrices ¶
func (mr *MockAssetsPricesServiceMockRecorder) FetchAndStoreAssetPrices(asset, endDate interface{}) *gomock.Call
FetchAndStoreAssetPrices indicates an expected call of FetchAndStoreAssetPrices
func (*MockAssetsPricesServiceMockRecorder) GetLastAssetsPrices ¶
func (mr *MockAssetsPricesServiceMockRecorder) GetLastAssetsPrices(asset, limit interface{}) *gomock.Call
GetLastAssetsPrices indicates an expected call of GetLastAssetsPrices
type MockNotificationsRepository ¶
type MockNotificationsRepository struct {
// contains filtered or unexported fields
}
MockNotificationsRepository is a mock of NotificationsRepository interface
func NewMockNotificationsRepository ¶
func NewMockNotificationsRepository(ctrl *gomock.Controller) *MockNotificationsRepository
NewMockNotificationsRepository creates a new mock instance
func (*MockNotificationsRepository) BulkDelete ¶
func (m *MockNotificationsRepository) BulkDelete(filter bson.M) error
BulkDelete mocks base method
func (*MockNotificationsRepository) BulkDeleteByApplicationID ¶
func (m *MockNotificationsRepository) BulkDeleteByApplicationID(id string) error
BulkDeleteByApplicationID mocks base method
func (*MockNotificationsRepository) Create ¶
func (m *MockNotificationsRepository) Create(notification *domain.Notification) error
Create mocks base method
func (*MockNotificationsRepository) EXPECT ¶
func (m *MockNotificationsRepository) EXPECT() *MockNotificationsRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNotificationsRepository) FindLastEventLogsNotificationDate ¶
func (m *MockNotificationsRepository) FindLastEventLogsNotificationDate() (time.Time, error)
FindLastEventLogsNotificationDate mocks base method
type MockNotificationsRepositoryMockRecorder ¶
type MockNotificationsRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockNotificationsRepositoryMockRecorder is the mock recorder for MockNotificationsRepository
func (*MockNotificationsRepositoryMockRecorder) BulkDelete ¶
func (mr *MockNotificationsRepositoryMockRecorder) BulkDelete(filter interface{}) *gomock.Call
BulkDelete indicates an expected call of BulkDelete
func (*MockNotificationsRepositoryMockRecorder) BulkDeleteByApplicationID ¶
func (mr *MockNotificationsRepositoryMockRecorder) BulkDeleteByApplicationID(id interface{}) *gomock.Call
BulkDeleteByApplicationID indicates an expected call of BulkDeleteByApplicationID
func (*MockNotificationsRepositoryMockRecorder) Create ¶
func (mr *MockNotificationsRepositoryMockRecorder) Create(notification interface{}) *gomock.Call
Create indicates an expected call of Create
func (*MockNotificationsRepositoryMockRecorder) FindLastEventLogsNotificationDate ¶
func (mr *MockNotificationsRepositoryMockRecorder) FindLastEventLogsNotificationDate() *gomock.Call
FindLastEventLogsNotificationDate indicates an expected call of FindLastEventLogsNotificationDate
func (*MockNotificationsRepositoryMockRecorder) Sent ¶
func (mr *MockNotificationsRepositoryMockRecorder) Sent(id interface{}) *gomock.Call
Sent indicates an expected call of Sent
type MockNotificationsService ¶
type MockNotificationsService struct {
// contains filtered or unexported fields
}
MockNotificationsService is a mock of NotificationsService interface
func NewMockNotificationsService ¶
func NewMockNotificationsService(ctrl *gomock.Controller) *MockNotificationsService
NewMockNotificationsService creates a new mock instance
func (*MockNotificationsService) BulkDeleteByApplicationID ¶
func (m *MockNotificationsService) BulkDeleteByApplicationID(id string) error
BulkDeleteByApplicationID mocks base method
func (*MockNotificationsService) CreateEmailNotification ¶
func (m *MockNotificationsService) CreateEmailNotification(subject, message, notificationType string) error
CreateEmailNotification mocks base method
func (*MockNotificationsService) EXPECT ¶
func (m *MockNotificationsService) EXPECT() *MockNotificationsServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNotificationsService) FindLastEventLogsNotificationDate ¶
func (m *MockNotificationsService) FindLastEventLogsNotificationDate() (time.Time, error)
FindLastEventLogsNotificationDate mocks base method
func (*MockNotificationsService) SendEmail ¶
func (m *MockNotificationsService) SendEmail(subject, body string) error
SendEmail mocks base method
func (*MockNotificationsService) ShouldSendNotification ¶
func (m *MockNotificationsService) ShouldSendNotification() bool
ShouldSendNotification mocks base method
type MockNotificationsServiceMockRecorder ¶
type MockNotificationsServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockNotificationsServiceMockRecorder is the mock recorder for MockNotificationsService
func (*MockNotificationsServiceMockRecorder) BulkDeleteByApplicationID ¶
func (mr *MockNotificationsServiceMockRecorder) BulkDeleteByApplicationID(id interface{}) *gomock.Call
BulkDeleteByApplicationID indicates an expected call of BulkDeleteByApplicationID
func (*MockNotificationsServiceMockRecorder) CreateEmailNotification ¶
func (mr *MockNotificationsServiceMockRecorder) CreateEmailNotification(subject, message, notificationType interface{}) *gomock.Call
CreateEmailNotification indicates an expected call of CreateEmailNotification
func (*MockNotificationsServiceMockRecorder) FindLastEventLogsNotificationDate ¶
func (mr *MockNotificationsServiceMockRecorder) FindLastEventLogsNotificationDate() *gomock.Call
FindLastEventLogsNotificationDate indicates an expected call of FindLastEventLogsNotificationDate
func (*MockNotificationsServiceMockRecorder) SendEmail ¶
func (mr *MockNotificationsServiceMockRecorder) SendEmail(subject, body interface{}) *gomock.Call
SendEmail indicates an expected call of SendEmail
func (*MockNotificationsServiceMockRecorder) ShouldSendNotification ¶
func (mr *MockNotificationsServiceMockRecorder) ShouldSendNotification() *gomock.Call
ShouldSendNotification indicates an expected call of ShouldSendNotification
type RepositorySpy ¶
type RepositorySpy struct { FindAllCalls [][]interface{} AggregateCalls [][]interface{} FindOneCalls [][]interface{} InsertOneCalls []interface{} UpdateOneCalls [][]interface{} DeleteByIDCalls []string BulkUpsertCalls []interface{} BulkCreateCalls []interface{} BulkDeleteCalls []interface{} BulkUpdateCalls [][]interface{} }
func (*RepositorySpy) Aggregate ¶
func (r *RepositorySpy) Aggregate(documents interface{}, pipelineOptions mongo.Pipeline) error
func (*RepositorySpy) BulkCreate ¶
func (r *RepositorySpy) BulkCreate(documents *[]bson.M) error
func (*RepositorySpy) BulkDelete ¶
func (r *RepositorySpy) BulkDelete(filter bson.M) error
func (*RepositorySpy) BulkUpdate ¶
func (*RepositorySpy) BulkUpsert ¶
func (r *RepositorySpy) BulkUpsert(documents []bson.M) error
func (*RepositorySpy) DeleteByID ¶
func (r *RepositorySpy) DeleteByID(id string) error
func (*RepositorySpy) FindAll ¶
func (r *RepositorySpy) FindAll(documents interface{}, query interface{}, opts *options.FindOptions) error
func (*RepositorySpy) FindOne ¶
func (r *RepositorySpy) FindOne(document interface{}, query interface{}, opts *options.FindOneOptions) error
func (*RepositorySpy) InsertOne ¶
func (r *RepositorySpy) InsertOne(document interface{}) error
func (*RepositorySpy) UpdateOne ¶
func (r *RepositorySpy) UpdateOne(query interface{}, update interface{}) error
type UpdateBenchmarkArgs ¶
type UpdateBenchmarkArgs struct { ID string Output *domain.BenchmarkOutput }