Documentation ¶
Index ¶
- type BalanceRepository
- func (b BalanceRepository) CreateAccount(ctx context.Context, balance entity.Balance) error
- func (b BalanceRepository) GetAllOrderByOwnerAsc(ctx context.Context) ([]entity.Balance, error)
- func (b BalanceRepository) GetByID(ctx context.Context, aggregateID uuid.UUID) (entity.Balance, error)
- func (b BalanceRepository) GetMaxSequence(ctx context.Context) (projection.Token, error)
- func (b BalanceRepository) Update(ctx context.Context, balance entity.Balance) error
- type GetESResponse
- type GetResponse
- type Hits
- type ProjectionResume
- type ProjectionResumeRow
- type SearchResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BalanceRepository ¶
type BalanceRepository struct {
// contains filtered or unexported fields
}
func NewBalanceRepository ¶
func NewBalanceRepository(logger log.Logger, client *elasticsearch.Client) BalanceRepository
func (BalanceRepository) CreateAccount ¶
func (BalanceRepository) GetAllOrderByOwnerAsc ¶
func (BalanceRepository) GetMaxSequence ¶
func (b BalanceRepository) GetMaxSequence(ctx context.Context) (projection.Token, error)
type GetESResponse ¶
type GetResponse ¶
type ProjectionResume ¶
type ProjectionResume struct {
// contains filtered or unexported fields
}
func NewProjectionResume ¶
func NewProjectionResume(client *elasticsearch.Client, index string) ProjectionResume
func (ProjectionResume) GetStreamResumeToken ¶
func (es ProjectionResume) GetStreamResumeToken(ctx context.Context, key projection.ResumeKey) (projection.Token, error)
func (ProjectionResume) SetStreamResumeToken ¶
func (es ProjectionResume) SetStreamResumeToken(ctx context.Context, key projection.ResumeKey, token projection.Token) error
type ProjectionResumeRow ¶
type SearchResponse ¶
type SearchResponse struct {
Hits Hits `json:"hits"`
}
Click to show internal directories.
Click to hide internal directories.