db

Documentation

Index

• type AggSenderSQLStorage
  • func NewAggSenderSQLStorage(logger *log.Logger, dbPath string) (*AggSenderSQLStorage, error)
  • 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) UpdateCertificateStatus(ctx context.Context, certificate types.CertificateInfo) error
• type AggSenderStorage

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, dbPath string) (*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) UpdateCertificateStatus

func (a *AggSenderSQLStorage) UpdateCertificateStatus(ctx context.Context, certificate types.CertificateInfo) error

UpdateCertificateStatus updates the status of a certificate

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)
	// UpdateCertificateStatus updates the status of a certificate
	UpdateCertificateStatus(ctx context.Context, certificate types.CertificateInfo) error
}

AggSenderStorage is the interface that defines the methods to interact with the storage