shim

package
v0.0.0-...-5510b13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 16, 2025 License: MIT Imports: 29 Imported by: 0

Documentation

Overview

Package shim contains implementations of internal types in terms of the external types

Package shim contains implementations of internal types in terms of the external types

Package shim contains implementations of internal types in terms of the external types

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LimitCheckOCR3ReportingPlugin 

type LimitCheckOCR3ReportingPlugin[RI any] struct {
	Plugin ocr3types.ReportingPlugin[RI]
	Limits ocr3types.ReportingPluginLimits
}

LimitCheckOCR3ReportingPlugin wraps another plugin and checks that its outputs respect limits. We use it to surface violations to authors of plugins as early as possible.

It does not check inputs since those are checked by the SerializingEndpoint.

func (LimitCheckOCR3ReportingPlugin[RI]) Close 

func (rp LimitCheckOCR3ReportingPlugin[RI]) Close() error

func (LimitCheckOCR3ReportingPlugin[RI]) Observation 

func (rp LimitCheckOCR3ReportingPlugin[RI]) Observation(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query) (types.Observation, error)

func (LimitCheckOCR3ReportingPlugin[RI]) ObservationQuorum 

func (rp LimitCheckOCR3ReportingPlugin[RI]) ObservationQuorum(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query, aos []types.AttributedObservation) (bool, error)

func (LimitCheckOCR3ReportingPlugin[RI]) Outcome 

func (rp LimitCheckOCR3ReportingPlugin[RI]) Outcome(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query, aos []types.AttributedObservation) (ocr3types.Outcome, error)

func (LimitCheckOCR3ReportingPlugin[RI]) Query 

func (rp LimitCheckOCR3ReportingPlugin[RI]) Query(ctx context.Context, outctx ocr3types.OutcomeContext) (types.Query, error)

func (LimitCheckOCR3ReportingPlugin[RI]) Reports 

func (rp LimitCheckOCR3ReportingPlugin[RI]) Reports(ctx context.Context, seqNr uint64, outcome ocr3types.Outcome) ([]ocr3types.ReportPlus[RI], error)

func (LimitCheckOCR3ReportingPlugin[RI]) ShouldAcceptAttestedReport 

func (rp LimitCheckOCR3ReportingPlugin[RI]) ShouldAcceptAttestedReport(ctx context.Context, seqNr uint64, report ocr3types.ReportWithInfo[RI]) (bool, error)

func (LimitCheckOCR3ReportingPlugin[RI]) ShouldTransmitAcceptedReport 

func (rp LimitCheckOCR3ReportingPlugin[RI]) ShouldTransmitAcceptedReport(ctx context.Context, seqNr uint64, report ocr3types.ReportWithInfo[RI]) (bool, error)

func (LimitCheckOCR3ReportingPlugin[RI]) ValidateObservation 

func (rp LimitCheckOCR3ReportingPlugin[RI]) ValidateObservation(ctx context.Context, outctx ocr3types.OutcomeContext, query types.Query, ao types.AttributedObservation) error

type LimitCheckOCR3_1ReportingPlugin 

type LimitCheckOCR3_1ReportingPlugin[RI any] struct {
	Plugin ocr3_1types.ReportingPlugin[RI]
	Limits ocr3_1types.ReportingPluginLimits
}

LimitCheckOCR3_1ReportingPlugin wraps another plugin and checks that its outputs respect limits. We use it to surface violations to authors of plugins as early as possible.

It does not check inputs since those are checked by the SerializingEndpoint.

func (LimitCheckOCR3_1ReportingPlugin[RI]) Close 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) Close() error

func (LimitCheckOCR3_1ReportingPlugin[RI]) Committed 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) Committed(ctx context.Context, seqNr uint64, keyValueReader ocr3_1types.KeyValueStateReader) error

func (LimitCheckOCR3_1ReportingPlugin[RI]) Observation 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) Observation(ctx context.Context, seqNr uint64, aq types.AttributedQuery, kvReader ocr3_1types.KeyValueStateReader, blobBroadcastFetcher ocr3_1types.BlobBroadcastFetcher) (types.Observation, error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) ObservationQuorum 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) ObservationQuorum(ctx context.Context, seqNr uint64, aq types.AttributedQuery, aos []types.AttributedObservation, kvReader ocr3_1types.KeyValueStateReader, blobFetcher ocr3_1types.BlobFetcher) (bool, error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) Query 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) Query(ctx context.Context, seqNr uint64, kvReader ocr3_1types.KeyValueStateReader, blobBroadcastFetcher ocr3_1types.BlobBroadcastFetcher) (types.Query, error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) Reports 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) Reports(ctx context.Context, seqNr uint64, reportsPlusPrecursor ocr3_1types.ReportsPlusPrecursor) ([]ocr3types.ReportPlus[RI], error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) ShouldAcceptAttestedReport 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) ShouldAcceptAttestedReport(ctx context.Context, seqNr uint64, report ocr3types.ReportWithInfo[RI]) (bool, error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) ShouldTransmitAcceptedReport 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) ShouldTransmitAcceptedReport(ctx context.Context, seqNr uint64, report ocr3types.ReportWithInfo[RI]) (bool, error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) StateTransition 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) StateTransition(ctx context.Context, seqNr uint64, aq types.AttributedQuery, aos []types.AttributedObservation, kvReadWriter ocr3_1types.KeyValueStateReadWriter, blobFetcher ocr3_1types.BlobFetcher) (ocr3_1types.ReportsPlusPrecursor, error)

func (LimitCheckOCR3_1ReportingPlugin[RI]) ValidateObservation 

func (rp LimitCheckOCR3_1ReportingPlugin[RI]) ValidateObservation(ctx context.Context, seqNr uint64, aq types.AttributedQuery, ao types.AttributedObservation, kvReader ocr3_1types.KeyValueStateReader, blobFetcher ocr3_1types.BlobFetcher) error

type LimitCheckReportingPlugin 

type LimitCheckReportingPlugin struct {
	Plugin types.ReportingPlugin
	Limits types.ReportingPluginLimits
}

LimitCheckReportingPlugin wraps another ReportingPlugin and checks that its outputs respect limits. We use it to surface violations to authors of ReportingPlugins as early as possible.

It does not check inputs since those are checked by the SerializingEndpoint.

func (LimitCheckReportingPlugin) Close 

func (rp LimitCheckReportingPlugin) Close() error

func (LimitCheckReportingPlugin) Observation 

func (rp LimitCheckReportingPlugin) Observation(ctx context.Context, ts types.ReportTimestamp, query types.Query) (types.Observation, error)

func (LimitCheckReportingPlugin) Query 

func (rp LimitCheckReportingPlugin) Query(ctx context.Context, ts types.ReportTimestamp) (types.Query, error)

func (LimitCheckReportingPlugin) Report 

func (rp LimitCheckReportingPlugin) Report(ctx context.Context, ts types.ReportTimestamp, query types.Query, aos []types.AttributedObservation) (bool, types.Report, error)

func (LimitCheckReportingPlugin) ShouldAcceptFinalizedReport 

func (rp LimitCheckReportingPlugin) ShouldAcceptFinalizedReport(ctx context.Context, ts types.ReportTimestamp, report types.Report) (bool, error)

func (LimitCheckReportingPlugin) ShouldTransmitAcceptedReport 

func (rp LimitCheckReportingPlugin) ShouldTransmitAcceptedReport(ctx context.Context, ts types.ReportTimestamp, report types.Report) (bool, error)

type OCR2SerializingEndpoint 

type OCR2SerializingEndpoint struct {
	// contains filtered or unexported fields
}

func NewOCR2SerializingEndpoint 

func NewOCR2SerializingEndpoint(
	chTelemetry chan<- *serialization.TelemetryWrapper,
	configDigest types.ConfigDigest,
	endpoint commontypes.BinaryNetworkEndpoint,
	logger commontypes.Logger,
	metricsRegisterer prometheus.Registerer,
	reportingPluginLimits types.ReportingPluginLimits,
) *OCR2SerializingEndpoint

func (*OCR2SerializingEndpoint) Broadcast 

func (n *OCR2SerializingEndpoint) Broadcast(msg protocol.Message)

func (*OCR2SerializingEndpoint) Close 

func (n *OCR2SerializingEndpoint) Close() error

Close closes the SerializingEndpoint. It will also close the underlying endpoint.

func (*OCR2SerializingEndpoint) Receive 

func (n *OCR2SerializingEndpoint) Receive() <-chan protocol.MessageWithSender

func (*OCR2SerializingEndpoint) SendTo 

func (n *OCR2SerializingEndpoint) SendTo(msg protocol.Message, to commontypes.OracleID)

func (*OCR2SerializingEndpoint) Start 

func (n *OCR2SerializingEndpoint) Start() error

Start starts the SerializingEndpoint. It will also start the underlying endpoint.

type OCR2TelemetrySender 

type OCR2TelemetrySender struct {
	// contains filtered or unexported fields
}

func NewOCR2TelemetrySender 

func NewOCR2TelemetrySender(chTelemetry chan<- *serialization.TelemetryWrapper, logger commontypes.Logger, enableTransmissionTelemetry bool) *OCR2TelemetrySender

func (*OCR2TelemetrySender) EpochStarted 

func (ts *OCR2TelemetrySender) EpochStarted(
	configDigest types.ConfigDigest,
	epoch uint32,
	leader commontypes.OracleID,
)

func (*OCR2TelemetrySender) RoundStarted 

func (ts *OCR2TelemetrySender) RoundStarted(
	reportTimestamp types.ReportTimestamp,
	leader commontypes.OracleID,
)

func (*OCR2TelemetrySender) TransmissionScheduleComputed 

func (ts *OCR2TelemetrySender) TransmissionScheduleComputed(
	reportTimestamp types.ReportTimestamp,
	now time.Time,
	schedule map[commontypes.OracleID]time.Duration,
)

func (*OCR2TelemetrySender) TransmissionShouldAcceptFinalizedReportComputed 

func (ts *OCR2TelemetrySender) TransmissionShouldAcceptFinalizedReportComputed(
	reportTimestamp types.ReportTimestamp,
	result bool,
	ok bool,
)

func (*OCR2TelemetrySender) TransmissionShouldTransmitAcceptedReportComputed 

func (ts *OCR2TelemetrySender) TransmissionShouldTransmitAcceptedReportComputed(
	reportTimestamp types.ReportTimestamp,
	result bool,
	ok bool,
)

type OCR3SerializingEndpoint 

type OCR3SerializingEndpoint[RI any] struct {
	// contains filtered or unexported fields
}

func NewOCR3SerializingEndpoint 

func NewOCR3SerializingEndpoint[RI any](
	chTelemetry chan<- *serialization.TelemetryWrapper,
	configDigest types.ConfigDigest,
	endpoint commontypes.BinaryNetworkEndpoint,
	maxSigLen int,
	logger commontypes.Logger,
	metricsRegisterer prometheus.Registerer,
	pluginLimits ocr3types.ReportingPluginLimits,
	n, f int,
) *OCR3SerializingEndpoint[RI]

func (*OCR3SerializingEndpoint[RI]) Broadcast 

func (n *OCR3SerializingEndpoint[RI]) Broadcast(msg protocol.Message[RI])

func (*OCR3SerializingEndpoint[RI]) Close 

func (n *OCR3SerializingEndpoint[RI]) Close() error

Close closes the SerializingEndpoint. It will also close the underlying endpoint.

func (*OCR3SerializingEndpoint[RI]) Receive 

func (n *OCR3SerializingEndpoint[RI]) Receive() <-chan protocol.MessageWithSender[RI]

func (*OCR3SerializingEndpoint[RI]) SendTo 

func (n *OCR3SerializingEndpoint[RI]) SendTo(msg protocol.Message[RI], to commontypes.OracleID)

func (*OCR3SerializingEndpoint[RI]) Start 

func (n *OCR3SerializingEndpoint[RI]) Start() error

Start starts the SerializingEndpoint. It will also start the underlying endpoint.

type OCR3TelemetrySender 

type OCR3TelemetrySender struct {
	// contains filtered or unexported fields
}

func NewOCR3TelemetrySender 

func NewOCR3TelemetrySender(chTelemetry chan<- *serialization.TelemetryWrapper, logger commontypes.Logger, enableTransmissionTelemetry bool) *OCR3TelemetrySender

func (*OCR3TelemetrySender) EpochStarted 

func (ts *OCR3TelemetrySender) EpochStarted(
	configDigest types.ConfigDigest,
	epoch uint32,
	leader commontypes.OracleID,
)

func (*OCR3TelemetrySender) RoundStarted 

func (ts *OCR3TelemetrySender) RoundStarted(
	configDigest types.ConfigDigest,
	epoch uint64,
	seqNr uint64,
	round uint64,
	leader commontypes.OracleID,
)

func (*OCR3TelemetrySender) TransmissionScheduleComputed 

func (ts *OCR3TelemetrySender) TransmissionScheduleComputed(
	configDigest types.ConfigDigest,
	seqNr uint64,
	index int,
	now time.Time,
	isOverride bool,
	schedule map[commontypes.OracleID]time.Duration,
	ok bool,
)

func (*OCR3TelemetrySender) TransmissionShouldAcceptAttestedReportComputed 

func (ts *OCR3TelemetrySender) TransmissionShouldAcceptAttestedReportComputed(
	configDigest types.ConfigDigest,
	seqNr uint64,
	index int,
	result bool,
	ok bool,
)

func (*OCR3TelemetrySender) TransmissionShouldTransmitAcceptedReportComputed 

func (ts *OCR3TelemetrySender) TransmissionShouldTransmitAcceptedReportComputed(
	configDigest types.ConfigDigest,
	seqNr uint64,
	index int,
	result bool,
	ok bool,
)

type OCR3_1SerializingEndpoint 

type OCR3_1SerializingEndpoint[RI any] struct {
	// contains filtered or unexported fields
}

func NewOCR3_1SerializingEndpoint 

func NewOCR3_1SerializingEndpoint[RI any](
	chTelemetry chan<- *serialization.TelemetryWrapper,
	configDigest types.ConfigDigest,
	endpoint types.BinaryNetworkEndpoint2,
	maxSigLen int,
	logger commontypes.Logger,
	metricsRegisterer prometheus.Registerer,
	pluginLimits ocr3_1types.ReportingPluginLimits,
	publicConfig ocr3config.PublicConfig,
	serializedLengthLimits limits.OCR3_1SerializedLengthLimits,
) *OCR3_1SerializingEndpoint[RI]

func (*OCR3_1SerializingEndpoint[RI]) Broadcast 

func (n *OCR3_1SerializingEndpoint[RI]) Broadcast(msg protocol.Message[RI])

func (*OCR3_1SerializingEndpoint[RI]) Close 

func (n *OCR3_1SerializingEndpoint[RI]) Close() error

Close closes the SerializingEndpoint. It will also close the underlying endpoint.

func (*OCR3_1SerializingEndpoint[RI]) Receive 

func (n *OCR3_1SerializingEndpoint[RI]) Receive() <-chan protocol.MessageWithSender[RI]

func (*OCR3_1SerializingEndpoint[RI]) SendTo 

func (n *OCR3_1SerializingEndpoint[RI]) SendTo(msg protocol.Message[RI], to commontypes.OracleID)

func (*OCR3_1SerializingEndpoint[RI]) Start 

func (n *OCR3_1SerializingEndpoint[RI]) Start() error

Start starts the SerializingEndpoint. It will also start the underlying endpoint.

type OCR3_1TelemetrySender 

type OCR3_1TelemetrySender struct {
	// contains filtered or unexported fields
}

func NewOCR3_1TelemetrySender 

func NewOCR3_1TelemetrySender(chTelemetry chan<- *serialization.TelemetryWrapper, logger commontypes.Logger) *OCR3_1TelemetrySender

func (*OCR3_1TelemetrySender) RoundStarted 

func (ts *OCR3_1TelemetrySender) RoundStarted(
	configDigest types.ConfigDigest,
	epoch uint64,
	seqNr uint64,
	round uint64,
	leader commontypes.OracleID,
)

type SemanticOCR3_1KeyValueDatabase 

type SemanticOCR3_1KeyValueDatabase struct {
	KeyValueDatabase ocr3_1types.KeyValueDatabase
	Limits           ocr3_1types.ReportingPluginLimits
	// contains filtered or unexported fields
}

func NewSemanticOCR3_1KeyValueDatabase 

func NewSemanticOCR3_1KeyValueDatabase(
	keyValueDatabase ocr3_1types.KeyValueDatabase,
	limits ocr3_1types.ReportingPluginLimits,
	logger commontypes.Logger,
	metricsRegisterer prometheus.Registerer,
) *SemanticOCR3_1KeyValueDatabase

func (*SemanticOCR3_1KeyValueDatabase) Close 

func (s *SemanticOCR3_1KeyValueDatabase) Close() error

func (*SemanticOCR3_1KeyValueDatabase) HighestCommittedSeqNr 

func (s *SemanticOCR3_1KeyValueDatabase) HighestCommittedSeqNr() (uint64, error)

func (*SemanticOCR3_1KeyValueDatabase) NewReadTransaction 

func (s *SemanticOCR3_1KeyValueDatabase) NewReadTransaction(postSeqNr uint64) (protocol.KeyValueDatabaseReadTransaction, error)

func (*SemanticOCR3_1KeyValueDatabase) NewReadTransactionUnchecked 

func (s *SemanticOCR3_1KeyValueDatabase) NewReadTransactionUnchecked() (protocol.KeyValueDatabaseReadTransaction, error)

func (*SemanticOCR3_1KeyValueDatabase) NewSerializedReadWriteTransaction 

func (s *SemanticOCR3_1KeyValueDatabase) NewSerializedReadWriteTransaction(postSeqNr uint64) (protocol.KeyValueDatabaseReadWriteTransaction, error)

func (*SemanticOCR3_1KeyValueDatabase) NewSerializedReadWriteTransactionUnchecked 

func (s *SemanticOCR3_1KeyValueDatabase) NewSerializedReadWriteTransactionUnchecked() (protocol.KeyValueDatabaseReadWriteTransaction, error)

func (*SemanticOCR3_1KeyValueDatabase) NewUnserializedReadWriteTransactionUnchecked 

func (s *SemanticOCR3_1KeyValueDatabase) NewUnserializedReadWriteTransactionUnchecked() (protocol.KeyValueDatabaseReadWriteTransaction, error)

type SemanticOCR3_1KeyValueDatabaseReadTransaction 

type SemanticOCR3_1KeyValueDatabaseReadTransaction struct {
	// contains filtered or unexported fields
}

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) Discard 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) Discard()

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) Read 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) Read(key []byte) ([]byte, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadAttestedStateTransitionBlock 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadAttestedStateTransitionBlock(seqNr uint64) (protocol.AttestedStateTransitionBlock, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadAttestedStateTransitionBlocks 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadAttestedStateTransitionBlocks(minSeqNr uint64, maxItems int) (blocks []protocol.AttestedStateTransitionBlock, more bool, err error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadBlobChunk 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadBlobChunk(blobDigest protocol.BlobDigest, chunkIndex uint64) ([]byte, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadBlobMeta 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadBlobMeta(blobDigest protocol.BlobDigest) (*protocol.BlobMeta, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadBlobPayload 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadBlobPayload(blobDigest protocol.BlobDigest) ([]byte, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadHighestCommittedSeqNr 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadHighestCommittedSeqNr() (uint64, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadLowestPersistedSeqNr 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadLowestPersistedSeqNr() (uint64, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadNode 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadNode(nodeKey jmt.NodeKey) (jmt.Node, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadRoot 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadRoot(version jmt.Version) (jmt.NodeKey, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadStaleBlobIndex 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadStaleBlobIndex(maxStaleSinceSeqNr uint64, limit int) ([]protocol.StaleBlob, error)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadTreeSyncChunk 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadTreeSyncChunk(
	toSeqNr uint64,
	startIndex jmt.Digest,
	requestEndInclIndex jmt.Digest,
) (
	endInclIndex jmt.Digest,
	boundingLeaves []jmt.BoundingLeaf,
	keyValues []protocol.KeyValuePair,
	err error,
)

func (*SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadTreeSyncStatus 

func (s *SemanticOCR3_1KeyValueDatabaseReadTransaction) ReadTreeSyncStatus() (protocol.TreeSyncStatus, error)

type SemanticOCR3_1KeyValueDatabaseReadWriteTransaction 

type SemanticOCR3_1KeyValueDatabaseReadWriteTransaction struct {
	protocol.KeyValueDatabaseReadTransaction // inherit all read implementations
	// contains filtered or unexported fields
}

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) ApplyWriteSet 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) ApplyWriteSet(writeSet []protocol.KeyValuePairWithDeletions) (protocol.StateRootDigest, error)

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) CloseWriteSet 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) CloseWriteSet() (protocol.StateRootDigest, error)

CloseWriteSet updates the state tree according to the write set and returns the root. After this function is invoked the transaction for writing: any future attempts for Writes or Deletes on this transaction will fail.

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Commit 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Commit() error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Delete 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Delete(key []byte) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteAttestedStateTransitionBlocks 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteAttestedStateTransitionBlocks(maxSeqNrToDelete uint64, maxItems int) (done bool, err error)

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteBlobChunk 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteBlobChunk(blobDigest protocol.BlobDigest, chunkIndex uint64) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteBlobMeta 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteBlobMeta(blobDigest protocol.BlobDigest) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteRoots 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteRoots(minVersionToKeep jmt.Version, maxItems int) (done bool, err error)

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteStaleBlobIndex 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteStaleBlobIndex(staleBlob protocol.StaleBlob) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteStaleNodes 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DeleteStaleNodes(maxStaleSinceVersion jmt.Version, maxItems int) (done bool, err error)

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DestructiveDestroyForTreeSync 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) DestructiveDestroyForTreeSync(n int) (done bool, err error)

Caller must ensure to make committed state inaccessible to other transactions until completed. Must be reinvoked until done=true.

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Discard 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Discard()

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) GetWriteSet 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) GetWriteSet() ([]protocol.KeyValuePairWithDeletions, error)

GetWriteSet returns sorted list of key-value pairs that have been modified as part of this transaction.

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) VerifyAndWriteTreeSyncChunk 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) VerifyAndWriteTreeSyncChunk(
	targetRootDigest protocol.StateRootDigest,
	targetSeqNr uint64,
	startIndex jmt.Digest,
	endInclIndex jmt.Digest,
	boundingLeaves []jmt.BoundingLeaf,
	keyValues []protocol.KeyValuePair,
) (protocol.VerifyAndWriteTreeSyncChunkResult, error)

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Write 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) Write(key []byte, value []byte) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteAttestedStateTransitionBlock 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteAttestedStateTransitionBlock(seqNr uint64, block protocol.AttestedStateTransitionBlock) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteBlobChunk 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteBlobChunk(blobDigest protocol.BlobDigest, chunkIndex uint64, chunk []byte) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteBlobMeta 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteBlobMeta(blobDigest protocol.BlobDigest, blobMeta protocol.BlobMeta) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteHighestCommittedSeqNr 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteHighestCommittedSeqNr(seqNr uint64) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteLowestPersistedSeqNr 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteLowestPersistedSeqNr(seqNr uint64) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteNode 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteNode(nodeKey jmt.NodeKey, nodeOrNil jmt.Node) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteRoot 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteRoot(version jmt.Version, nodeKey jmt.NodeKey) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteStaleBlobIndex 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteStaleBlobIndex(staleBlob protocol.StaleBlob) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteStaleNode 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteStaleNode(staleNode jmt.StaleNode) error

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteTreeSyncStatus 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransaction) WriteTreeSyncStatus(status protocol.TreeSyncStatus) error

type SemanticOCR3_1KeyValueDatabaseReadWriteTransactionWithPreCommitHook 

type SemanticOCR3_1KeyValueDatabaseReadWriteTransactionWithPreCommitHook struct {
	protocol.KeyValueDatabaseReadWriteTransaction
	// contains filtered or unexported fields
}

func (*SemanticOCR3_1KeyValueDatabaseReadWriteTransactionWithPreCommitHook) Commit 

func (s *SemanticOCR3_1KeyValueDatabaseReadWriteTransactionWithPreCommitHook) Commit() error

type SerializingOCR3Database 

type SerializingOCR3Database struct {
	BinaryDb ocr3types.Database
}

func (*SerializingOCR3Database) ReadCert 

func (db *SerializingOCR3Database) ReadCert(ctx context.Context, configDigest types.ConfigDigest) (protocol.CertifiedPrepareOrCommit, error)

func (*SerializingOCR3Database) ReadConfig 

func (db *SerializingOCR3Database) ReadConfig(ctx context.Context) (*types.ContractConfig, error)

func (*SerializingOCR3Database) ReadPacemakerState 

func (db *SerializingOCR3Database) ReadPacemakerState(ctx context.Context, configDigest types.ConfigDigest) (protocol.PacemakerState, error)

func (*SerializingOCR3Database) WriteCert 

func (db *SerializingOCR3Database) WriteCert(ctx context.Context, configDigest types.ConfigDigest, cert protocol.CertifiedPrepareOrCommit) error

Writing with an empty value is the same as deleting.

func (*SerializingOCR3Database) WriteConfig 

func (db *SerializingOCR3Database) WriteConfig(ctx context.Context, config types.ContractConfig) error

func (*SerializingOCR3Database) WritePacemakerState 

func (db *SerializingOCR3Database) WritePacemakerState(ctx context.Context, configDigest types.ConfigDigest, state protocol.PacemakerState) error

type SerializingOCR3_1Database 

type SerializingOCR3_1Database struct {
	BinaryDb ocr3_1types.Database
}

func (*SerializingOCR3_1Database) ReadCert 

func (db *SerializingOCR3_1Database) ReadCert(ctx context.Context, configDigest types.ConfigDigest) (protocol.CertifiedPrepareOrCommit, error)

func (*SerializingOCR3_1Database) ReadConfig 

func (db *SerializingOCR3_1Database) ReadConfig(ctx context.Context) (*types.ContractConfig, error)

func (*SerializingOCR3_1Database) ReadPacemakerState 

func (db *SerializingOCR3_1Database) ReadPacemakerState(ctx context.Context, configDigest types.ConfigDigest) (protocol.PacemakerState, error)

func (*SerializingOCR3_1Database) WriteCert 

func (db *SerializingOCR3_1Database) WriteCert(ctx context.Context, configDigest types.ConfigDigest, cert protocol.CertifiedPrepareOrCommit) error

Writing with an empty value is the same as deleting.

func (*SerializingOCR3_1Database) WriteConfig 

func (db *SerializingOCR3_1Database) WriteConfig(ctx context.Context, config types.ContractConfig) error

func (*SerializingOCR3_1Database) WritePacemakerState 

func (db *SerializingOCR3_1Database) WritePacemakerState(ctx context.Context, configDigest types.ConfigDigest, state protocol.PacemakerState) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.