Versions in this module Expand all Collapse all v1 v1.1.0 Aug 7, 2026 Changes in this version + const DeleteBatchSize + const DeleteQueueMaxSize + const DuplicateReport + const FlushDeletesFrequency + const OvertimeDeleteTimeout + const PruneBatchSize + const PruneFrequency + func NewPersistenceManager(lggr logger.Logger, orm ORM, serverURL string, maxTransmitQueueSize int, ...) *persistenceManager + type Config interface + Protocol func() MercuryTransmitterProtocol + ReaperMaxAge func() time.Duration + TransmitConcurrency func() uint32 + TransmitQueueMaxSize func() uint32 + TransmitTimeout func() time.Duration + type Mercury interface + Cache func() MercuryCache + Credentials func(credName string) *types.MercuryCredentials + TLS func() MercuryTLS + Transmitter func() MercuryTransmitter + VerboseLogging func() bool + type MercuryCache interface + LatestReportDeadline func() time.Duration + LatestReportTTL func() time.Duration + MaxStaleAge func() time.Duration + type MercuryTLS interface + CertFile func() string + type MercuryTransmitter interface + Protocol func() MercuryTransmitterProtocol + ReaperFrequency func() time.Duration + ReaperMaxAge func() time.Duration + TransmitConcurrency func() uint32 + TransmitQueueMaxSize func() uint32 + TransmitTimeout func() time.Duration + type MercuryTransmitterProtocol string + const MercuryTransmitterProtocolGRPC + const MercuryTransmitterProtocolWSRPC + func (m *MercuryTransmitterProtocol) UnmarshalText(text []byte) error + func (m MercuryTransmitterProtocol) String() string + type ORM interface + Delete func(ctx context.Context, hashes [][32]byte) error + DonID func() uint32 + Get func(ctx context.Context, serverURL string, limit int, maxAge time.Duration) ([]*Transmission, error) + Insert func(ctx context.Context, transmissions []*Transmission) error + Prune func(ctx context.Context, serverURL string, maxSize, batchSize int) (int64, error) + func NewORM(ds sqlutil.DataSource, donID uint32) ORM + type Opts struct + CapabilitiesRegistry coretypes.CapabilitiesRegistry + Cfg Config + Clients map[string]rpc.Client + DonID uint32 + FromAccount string + Lggr logger.Logger + ORM ORM + VerboseLogging bool + type QueueConfig interface + ReaperMaxAge func() time.Duration + TransmitQueueMaxSize func() uint32 + TransmitTimeout func() time.Duration + type ReportPacker interface + Pack func(digest types.ConfigDigest, seqNr uint64, report ocr2types.Report, ...) ([]byte, error) + type Transmission struct + ConfigDigest types.ConfigDigest + Report ocr3types.ReportWithInfo[llotypes.ReportInfo] + SeqNr uint64 + ServerURL string + Sigs []types.AttributedOnchainSignature + func (t Transmission) Hash() [32]byte + type TransmitQueue interface + BlockingPop func() (t *Transmission) + Init func(ts []*Transmission) error + IsEmpty func() bool + Push func(t *Transmission) (ok bool) + func NewTransmitQueue(lggr logger.Logger, serverURL string, maxlen int, asyncDeleter asyncDeleter) TransmitQueue + type Transmitter interface + func New(opts Opts) Transmitter
Go to main page