sourcereader

package
v0.0.0-...-2b0caa0 Latest Latest
Warning

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

Go to latest
Published: Jun 12, 2026 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSourceReader

func NewSourceReader(
	lggr logger.Logger,
	grpcEndpoint string,
	config ReaderConfig,
	rmnRemoteInstanceAddress contracts.InstanceAddress,
	opts ...grpc.DialOption,
) (chainaccess.SourceReader, error)

NewSourceReader creates a new canton source reader. Auth is handled via gRPC dial options (WithTransportCredentials, WithPerRPCCredentials).

Types

type ReaderConfig

type ReaderConfig struct {
	// NodeOperatorParty is the observer party that node operators will use to observe CCIPMessageSent events.
	// This is used to filter out events that are not observed by the node operator.
	NodeOperatorParty string `toml:"node_operator_party"`

	// CCIPOwnerParty is the party that we expect to be present in the CCIPMessageSent.ccipOwner field.
	// This proves that the ccipOwner is a signatory on the CCIPMessageSent contract(event).
	CCIPOwnerParty string `toml:"ccip_owner_party"`

	// CCIPMessageSentTemplateID is the template ID of the CCIPMessageSent contract.
	CCIPMessageSentTemplateID contracts.TemplateID `toml:"ccip_message_sent_template_id"`

	// RMNRemoteTemplateID is the template ID of the RMNRemote contract.
	RMNRemoteTemplateID contracts.TemplateID `toml:"rmn_remote_template_id"`

	// Authority is the authority to use for the gRPC connection.
	// Connecting to the gRPC API via nginx usually requires this to be set.
	Authority string `toml:"authority"`
}

ReaderConfig is the configuration required to create a canton source reader.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL