Documentation
¶
Index ¶
- type AggSenderSQLStorage
- func (a *AggSenderSQLStorage) DeleteCertificate(ctx context.Context, certificateID common.Hash) error
- func (a *AggSenderSQLStorage) GetCertificateByHeight(height uint64) (*types.CertificateInfo, error)
- func (a *AggSenderSQLStorage) GetCertificatesByStatus(statuses []agglayer.CertificateStatus) ([]*types.CertificateInfo, error)
- func (a *AggSenderSQLStorage) GetLastSentCertificate() (*types.CertificateInfo, error)
- func (a *AggSenderSQLStorage) SaveLastSentCertificate(ctx context.Context, certificate types.CertificateInfo) error
- func (a *AggSenderSQLStorage) UpdateCertificate(ctx context.Context, certificate types.CertificateInfo) error
- type AggSenderSQLStorageConfig
- type AggSenderStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggSenderSQLStorage ¶
type AggSenderSQLStorage struct {
// contains filtered or unexported fields
}
AggSenderSQLStorage is the struct that implements the AggSenderStorage interface
func NewAggSenderSQLStorage ¶
func NewAggSenderSQLStorage(logger *log.Logger, cfg AggSenderSQLStorageConfig) (*AggSenderSQLStorage, error)
NewAggSenderSQLStorage creates a new AggSenderSQLStorage
func (*AggSenderSQLStorage) DeleteCertificate ¶
func (a *AggSenderSQLStorage) DeleteCertificate(ctx context.Context, certificateID common.Hash) error
DeleteCertificate deletes a certificate from the storage
func (*AggSenderSQLStorage) GetCertificateByHeight ¶
func (a *AggSenderSQLStorage) GetCertificateByHeight(height uint64) (*types.CertificateInfo, error)
GetCertificateByHeight returns a certificate by its height
func (*AggSenderSQLStorage) GetCertificatesByStatus ¶
func (a *AggSenderSQLStorage) GetCertificatesByStatus( statuses []agglayer.CertificateStatus) ([]*types.CertificateInfo, error)
func (*AggSenderSQLStorage) GetLastSentCertificate ¶
func (a *AggSenderSQLStorage) GetLastSentCertificate() (*types.CertificateInfo, error)
GetLastSentCertificate returns the last certificate sent to the aggLayer
func (*AggSenderSQLStorage) SaveLastSentCertificate ¶
func (a *AggSenderSQLStorage) SaveLastSentCertificate(ctx context.Context, certificate types.CertificateInfo) error
SaveLastSentCertificate saves the last certificate sent to the aggLayer
func (*AggSenderSQLStorage) UpdateCertificate ¶
func (a *AggSenderSQLStorage) UpdateCertificate(ctx context.Context, certificate types.CertificateInfo) error
UpdateCertificate updates a certificate
type AggSenderSQLStorageConfig ¶
AggSenderSQLStorageConfig is the configuration for the AggSenderSQLStorage
type AggSenderStorage ¶
type AggSenderStorage interface {
// GetCertificateByHeight returns a certificate by its height
GetCertificateByHeight(height uint64) (*types.CertificateInfo, error)
// GetLastSentCertificate returns the last certificate sent to the aggLayer
GetLastSentCertificate() (*types.CertificateInfo, error)
// SaveLastSentCertificate saves the last certificate sent to the aggLayer
SaveLastSentCertificate(ctx context.Context, certificate types.CertificateInfo) error
// DeleteCertificate deletes a certificate from the storage
DeleteCertificate(ctx context.Context, certificateID common.Hash) error
// GetCertificatesByStatus returns a list of certificates by their status
GetCertificatesByStatus(status []agglayer.CertificateStatus) ([]*types.CertificateInfo, error)
// UpdateCertificate updates certificate in db
UpdateCertificate(ctx context.Context, certificate types.CertificateInfo) error
}
AggSenderStorage is the interface that defines the methods to interact with the storage
Click to show internal directories.
Click to hide internal directories.