db

Documentation

Index

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

type AggSenderSQLStorageConfig struct {
	DBPath                  string
	KeepCertificatesHistory bool
}

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