nosqlfs

package

v0.0.0-...-eecab09 Latest Latest Go to latest Published: Aug 1, 2023 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/program-world-labs/DDDGo

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type CRUDDatasourceImpl
- func NewCRUDDatasourceImpl(db *firestoredb.Firestore) *CRUDDatasourceImpl
type TransactionDataSourceImpl
- func NewTransactionRunDataSourceImpl(db *firestoredb.Firestore) *TransactionDataSourceImpl
- func (r *TransactionDataSourceImpl) RunTransaction(ctx context.Context, txFunc domain.TransactionEventFunc) error
type TransactionEventDataSourceImpl
- func NewTransactionEventDataSourceImpl(db *firestore.Transaction) *TransactionEventDataSourceImpl
- func (r *TransactionEventDataSourceImpl) GetTx() interface{}

Constants ¶

View Source

const (
	ErrorCodeSQLCreate = domainerrors.ErrorCodeInfraDatasource + domainerrors.ErrorCodeInfraDatasource + domainerrors.ErrorCodeInfraDatasourceSQL + iota
	ErrorCodeSQLDelete
	ErrorCodeSQLUpdate
	ErrorCodeSQLUpdateWithFields
	ErrorCodeSQLGet
	ErrorCodeSQLGetAll
	ErrorCodeSQLCreateTx
	ErrorCodeSQLDeleteTx
	ErrorCodeSQLUpdateTx
	ErrorCodeSQLUpdateWithFieldsTx
	ErrorCodeSQLCast
	ErrorCodeSQLAppendAssociation
	ErrorCodeSQLReplaceAssociation
	ErrorCodeSQLRemoveAssociation
	ErrorCodeSQLGetAssociationCount
	ErrorCodeSQLAppendAssociationTx
	ErrorCodeSQLReplaceAssociationTx
	ErrorCodeSQLRemoveAssociationTx
)

Variables ¶

View Source

var (
	ErrCastToEntityFailed = errors.New("cast to entity failed")
)

Functions ¶

This section is empty.

Types ¶

type CRUDDatasourceImpl ¶

type CRUDDatasourceImpl struct {
	Client *firestore.Client
}

CRUDDatasourceImpl -.

func NewCRUDDatasourceImpl ¶

func NewCRUDDatasourceImpl(db *firestoredb.Firestore) *CRUDDatasourceImpl

NewCRUDDatasourceImpl -.

func (*CRUDDatasourceImpl) Create ¶

func (r *CRUDDatasourceImpl) Create(ctx context.Context, model dto.IRepoEntity) (dto.IRepoEntity, error)

Create -.

func (*CRUDDatasourceImpl) CreateTx ¶

func (r *CRUDDatasourceImpl) CreateTx(ctx context.Context, model dto.IRepoEntity, tx domain.ITransactionEvent) (dto.IRepoEntity, error)

Create -.

func (*CRUDDatasourceImpl) Delete ¶

func (r *CRUDDatasourceImpl) Delete(ctx context.Context, model dto.IRepoEntity) (dto.IRepoEntity, error)

Delete -.

func (*CRUDDatasourceImpl) DeleteTx ¶

func (r *CRUDDatasourceImpl) DeleteTx(ctx context.Context, model dto.IRepoEntity, tx domain.ITransactionEvent) (dto.IRepoEntity, error)

Delete -.

func (*CRUDDatasourceImpl) GetAll ¶

func (r *CRUDDatasourceImpl) GetAll(ctx context.Context, sq *domain.SearchQuery, model dto.IRepoEntity) (*dto.List, error)

func (*CRUDDatasourceImpl) GetByID ¶

func (r *CRUDDatasourceImpl) GetByID(ctx context.Context, model dto.IRepoEntity) (dto.IRepoEntity, error)

GetByID -.

func (*CRUDDatasourceImpl) Update ¶

func (r *CRUDDatasourceImpl) Update(ctx context.Context, model dto.IRepoEntity) (dto.IRepoEntity, error)

Update -.

func (*CRUDDatasourceImpl) UpdateTx ¶

func (r *CRUDDatasourceImpl) UpdateTx(ctx context.Context, model dto.IRepoEntity, tx domain.ITransactionEvent) (dto.IRepoEntity, error)

Update -.

func (*CRUDDatasourceImpl) UpdateWithFields ¶

func (r *CRUDDatasourceImpl) UpdateWithFields(ctx context.Context, model dto.IRepoEntity, fields []string) (dto.IRepoEntity, error)

UpdateWithFields -.

func (*CRUDDatasourceImpl) UpdateWithFieldsTx ¶

func (r *CRUDDatasourceImpl) UpdateWithFieldsTx(ctx context.Context, model dto.IRepoEntity, fields []string, tx domain.ITransactionEvent) (dto.IRepoEntity, error)

UpdateWithFields -.

type TransactionDataSourceImpl ¶

type TransactionDataSourceImpl struct {
	// contains filtered or unexported fields
}

TransactionDataSourceImpl -.

func NewTransactionRunDataSourceImpl ¶

func NewTransactionRunDataSourceImpl(db *firestoredb.Firestore) *TransactionDataSourceImpl

NewTransactionDataSourceImpl -.

func (*TransactionDataSourceImpl) RunTransaction ¶

func (r *TransactionDataSourceImpl) RunTransaction(ctx context.Context, txFunc domain.TransactionEventFunc) error

RunTransaction -.

type TransactionEventDataSourceImpl ¶

type TransactionEventDataSourceImpl struct {
	// contains filtered or unexported fields
}

func NewTransactionEventDataSourceImpl ¶

func NewTransactionEventDataSourceImpl(db *firestore.Transaction) *TransactionEventDataSourceImpl

func (*TransactionEventDataSourceImpl) GetTx ¶

func (r *TransactionEventDataSourceImpl) GetTx() interface{}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL