Documentation
¶
Index ¶
- type Repository
- func (r *Repository) Aggregate(pipeline mongo.Pipeline) (*[]bson.M, error)
- func (r *Repository) BulkCreate(documents *[]bson.M) error
- func (r *Repository) BulkDeleteByExecutionID(id string) error
- func (r *Repository) Create(date time.Time, executionID primitive.ObjectID, state interface{}) error
- func (r *Repository) FindAll(filter interface{}) (*[]domain.ApplicationExecutionState, error)
- func (r *Repository) FindLast(filter interface{}) (*domain.ApplicationExecutionState, error)
- type RepositoryInMemory
- func (r *RepositoryInMemory) Aggregate(pipeline mongo.Pipeline) (*[]bson.M, error)
- func (r *RepositoryInMemory) BulkCreate(documents *[]bson.M) error
- func (r *RepositoryInMemory) BulkDeleteByExecutionID(id string) error
- func (r *RepositoryInMemory) Create(date time.Time, executionID primitive.ObjectID, state interface{}) error
- func (r *RepositoryInMemory) FindAll(filter interface{}) (*[]domain.ApplicationExecutionState, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
Repository stores and gets assets prices
func NewRepository ¶
func NewRepository(repo domain.Repository) *Repository
NewRepository returns an instance of ApplicationExecutionStatesRepository
func NewRepositoryInMemory ¶
func NewRepositoryInMemory() *Repository
NewRepository returns an instance of ApplicationExecutionStatesRepository
func (*Repository) BulkCreate ¶
func (r *Repository) BulkCreate(documents *[]bson.M) error
BulkCreate creates multiple documents
func (*Repository) BulkDeleteByExecutionID ¶
func (r *Repository) BulkDeleteByExecutionID(id string) error
BulkDeleteByExecutionID deletes rows related with an execution id.
func (*Repository) Create ¶
func (r *Repository) Create(date time.Time, executionID primitive.ObjectID, state interface{}) error
Create stores an application execution state
func (*Repository) FindAll ¶
func (r *Repository) FindAll(filter interface{}) (*[]domain.ApplicationExecutionState, error)
FindAll returns assets prices
func (*Repository) FindLast ¶
func (r *Repository) FindLast(filter interface{}) (*domain.ApplicationExecutionState, error)
FindOne retuns one document of application execution state
type RepositoryInMemory ¶
type RepositoryInMemory struct {
}
Repository stores and gets assets prices
func (*RepositoryInMemory) BulkCreate ¶
func (r *RepositoryInMemory) BulkCreate(documents *[]bson.M) error
BulkCreate creates multiple documents
func (*RepositoryInMemory) BulkDeleteByExecutionID ¶
func (r *RepositoryInMemory) BulkDeleteByExecutionID(id string) error
BulkDeleteByExecutionID deletes multiple documents
func (*RepositoryInMemory) Create ¶
func (r *RepositoryInMemory) Create(date time.Time, executionID primitive.ObjectID, state interface{}) error
Create stores an application execution state
func (*RepositoryInMemory) FindAll ¶
func (r *RepositoryInMemory) FindAll(filter interface{}) (*[]domain.ApplicationExecutionState, error)
FindAll returns assets prices
Source Files
Click to show internal directories.
Click to hide internal directories.