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.
Click to show internal directories.
Click to hide internal directories.