Documentation
¶
Index ¶
- func NewDefaultModeAggregator(minIdenticalResponses uint32) *defaultModeAggregator
- func NewDispatcher(peerWrapper p2ptypes.PeerWrapper, signer p2ptypes.Signer, ...) *dispatcher
- func NewMessageCache[EventID comparable, PeerID comparable]() *messageCache[EventID, PeerID]
- func NewRemoteTargetCaller(capInfo commoncap.CapabilityInfo, donInfo *types.DON, ...) *remoteTargetCaller
- func NewRemoteTargetReceiver(capInfo commoncap.CapabilityInfo, donInfo *types.DON, ...) *remoteTargetReceiver
- func NewTriggerPublisher(config types.RemoteTriggerConfig, underlying commoncap.TriggerCapability, ...) *triggerPublisher
- func NewTriggerSubscriber(config types.RemoteTriggerConfig, capInfo commoncap.CapabilityInfo, ...) *triggerSubscriber
- func ToPeerID(peerID []byte) p2ptypes.PeerID
- func ValidateMessage(msg p2ptypes.Message, expectedReceiver p2ptypes.PeerID) (*remotetypes.MessageBody, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDefaultModeAggregator ¶
func NewDefaultModeAggregator(minIdenticalResponses uint32) *defaultModeAggregator
func NewDispatcher ¶
func NewDispatcher(peerWrapper p2ptypes.PeerWrapper, signer p2ptypes.Signer, registry commontypes.CapabilitiesRegistry, lggr logger.Logger) *dispatcher
func NewMessageCache ¶
func NewMessageCache[EventID comparable, PeerID comparable]() *messageCache[EventID, PeerID]
func NewRemoteTargetCaller ¶
func NewRemoteTargetCaller(capInfo commoncap.CapabilityInfo, donInfo *types.DON, dispatcher types.Dispatcher, lggr logger.Logger) *remoteTargetCaller
func NewRemoteTargetReceiver ¶
func NewRemoteTargetReceiver(capInfo commoncap.CapabilityInfo, donInfo *types.DON, dispatcher types.Dispatcher, lggr logger.Logger) *remoteTargetReceiver
func NewTriggerPublisher ¶
func NewTriggerPublisher(config types.RemoteTriggerConfig, underlying commoncap.TriggerCapability, capInfo commoncap.CapabilityInfo, capDonInfo types.DON, workflowDONs map[string]types.DON, dispatcher types.Dispatcher, lggr logger.Logger) *triggerPublisher
func NewTriggerSubscriber ¶
func NewTriggerSubscriber(config types.RemoteTriggerConfig, capInfo commoncap.CapabilityInfo, capDonInfo types.DON, localDonInfo types.DON, dispatcher types.Dispatcher, aggregator types.Aggregator, lggr logger.Logger) *triggerSubscriber
func ValidateMessage ¶
func ValidateMessage(msg p2ptypes.Message, expectedReceiver p2ptypes.PeerID) (*remotetypes.MessageBody, error)
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.