Documentation
¶
Index ¶
- type AppRepository
- func (a *AppRepository) FindAllByDA(ctx context.Context, da model.DataAvailabilitySelector) ([]model.Application, error)
- func (a *AppRepository) FindOneByContract(ctx context.Context, address common.Address) (*model.Application, error)
- func (a *AppRepository) List(ctx context.Context) ([]model.Application, error)
- func (a *AppRepository) UpdateDA(ctx context.Context, applicationId int64, da model.DataAvailabilitySelector) error
- type AppRepositoryInterface
- type EpochRepository
- type EpochRepositoryInterface
- type InputRepository
- func (i *InputRepository) Count(ctx context.Context, filter []*cModel.ConvenienceFilter) (uint64, error)
- func (i *InputRepository) Create(ctx context.Context, input model.Input) error
- func (i *InputRepository) FindAll(ctx context.Context, first *int, last *int, after *string, before *string, ...) (*commons.PageResult[model.Input], error)
- func (i *InputRepository) FindOne(ctx context.Context, applicationId int64, index uint64) (*model.Input, error)
- type InputRepositoryInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppRepository ¶
func NewAppRepository ¶
func NewAppRepository(db *sqlx.DB) *AppRepository
func (*AppRepository) FindAllByDA ¶
func (a *AppRepository) FindAllByDA(ctx context.Context, da model.DataAvailabilitySelector) ([]model.Application, error)
func (*AppRepository) FindOneByContract ¶
func (a *AppRepository) FindOneByContract( ctx context.Context, address common.Address, ) (*model.Application, error)
FindOneByContract returns a single application by ID
func (*AppRepository) List ¶
func (a *AppRepository) List( ctx context.Context, ) ([]model.Application, error)
func (*AppRepository) UpdateDA ¶
func (a *AppRepository) UpdateDA( ctx context.Context, applicationId int64, da model.DataAvailabilitySelector, ) error
Update field DA
type AppRepositoryInterface ¶
type AppRepositoryInterface interface {
FindOneByContract(ctx context.Context, address common.Address) (*model.Application, error)
FindAllByDA(ctx context.Context, da model.DataAvailabilitySelector) ([]model.Application, error)
UpdateDA(ctx context.Context, applicationId int64, da model.DataAvailabilitySelector) error
List(ctx context.Context) ([]model.Application, error)
}
type EpochRepository ¶
func NewEpochRepository ¶
func NewEpochRepository(db *sqlx.DB) *EpochRepository
func (*EpochRepository) GetLatestOpenEpochByAppID ¶
type InputRepository ¶
func NewInputRepository ¶
func NewInputRepository(db *sqlx.DB) *InputRepository
func (*InputRepository) Count ¶
func (i *InputRepository) Count( ctx context.Context, filter []*cModel.ConvenienceFilter, ) (uint64, error)
type InputRepositoryInterface ¶
type InputRepositoryInterface interface {
Create(ctx context.Context, input model.Input) error
FindOne(ctx context.Context, applicationId int64, index uint64) (*model.Input, error)
FindAll(
ctx context.Context,
first *int,
last *int,
after *string,
before *string,
filter []*cModel.ConvenienceFilter,
) (*commons.PageResult[model.Input], error)
Count(ctx context.Context, filter []*cModel.ConvenienceFilter) (uint64, error)
}
Click to show internal directories.
Click to hide internal directories.