Documentation ¶
Index ¶
- type NosqlDatabase
- func (nosqlDatabase *NosqlDatabase) Create(carrier *aggregates.Carrier) *custom_errors.Error
- func (nosqlDatabase *NosqlDatabase) FindByCarrierId(carrierId string) (*aggregates.Carrier, *custom_errors.Error)
- func (nosqlDatabase *NosqlDatabase) FindByUserId(userId string) (*aggregates.Carrier, *custom_errors.Error)
- func (nosqlDatabase *NosqlDatabase) FindCarriersByStatus(status value_objects.State) (*[]aggregates.Carrier, *custom_errors.Error)
- func (nosqlDatabase *NosqlDatabase) Update(carrierId string, updateFilter map[string]interface{}) *custom_errors.Error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NosqlDatabase ¶
type NosqlDatabase struct {
// contains filtered or unexported fields
}
func NewNosqlDatabase ¶
func NewNosqlDatabase(logger *logger.ServiceLogger, config *config.ServiceConfig) (*NosqlDatabase, *custom_errors.Error)
func (*NosqlDatabase) Create ¶
func (nosqlDatabase *NosqlDatabase) Create(carrier *aggregates.Carrier) *custom_errors.Error
func (*NosqlDatabase) FindByCarrierId ¶
func (nosqlDatabase *NosqlDatabase) FindByCarrierId(carrierId string) (*aggregates.Carrier, *custom_errors.Error)
func (*NosqlDatabase) FindByUserId ¶
func (nosqlDatabase *NosqlDatabase) FindByUserId(userId string) (*aggregates.Carrier, *custom_errors.Error)
func (*NosqlDatabase) FindCarriersByStatus ¶
func (nosqlDatabase *NosqlDatabase) FindCarriersByStatus(status value_objects.State) (*[]aggregates.Carrier, *custom_errors.Error)
func (*NosqlDatabase) Update ¶
func (nosqlDatabase *NosqlDatabase) Update(carrierId string, updateFilter map[string]interface{}) *custom_errors.Error
Click to show internal directories.
Click to hide internal directories.