remote

Documentation

Index

• func AggregateModeRaw(elemList [][]byte, minIdenticalResponses uint32) ([]byte, error)
• 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 *capabilities.DON, ...) *remoteTargetCaller
• func NewRemoteTargetReceiver(capInfo commoncap.CapabilityInfo, donInfo *capabilities.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)

Functions

func AggregateModeRaw

func AggregateModeRaw(elemList [][]byte, minIdenticalResponses uint32) ([]byte, error)

func NewDefaultModeAggregator

func NewDefaultModeAggregator(minIdenticalResponses uint32) *defaultModeAggregator

func NewDispatcher

func NewDispatcher(peerWrapper p2ptypes.PeerWrapper, signer p2ptypes.Signer, registry core.CapabilitiesRegistry, lggr logger.Logger) *dispatcher

func NewMessageCache

func NewMessageCache[EventID comparable, PeerID comparable]() *messageCache[EventID, PeerID]

func NewRemoteTargetCaller

func NewRemoteTargetCaller(capInfo commoncap.CapabilityInfo, donInfo *capabilities.DON, dispatcher types.Dispatcher, lggr logger.Logger) *remoteTargetCaller

func NewRemoteTargetReceiver

func NewRemoteTargetReceiver(capInfo commoncap.CapabilityInfo, donInfo *capabilities.DON, dispatcher types.Dispatcher, lggr logger.Logger) *remoteTargetReceiver

func NewTriggerPublisher

func NewTriggerPublisher(config types.RemoteTriggerConfig, underlying commoncap.TriggerCapability, capInfo commoncap.CapabilityInfo, capDonInfo commoncap.DON, workflowDONs map[string]commoncap.DON, dispatcher types.Dispatcher, lggr logger.Logger) *triggerPublisher

func NewTriggerSubscriber

func NewTriggerSubscriber(config types.RemoteTriggerConfig, capInfo commoncap.CapabilityInfo, capDonInfo capabilities.DON, localDonInfo capabilities.DON, dispatcher types.Dispatcher, aggregator types.Aggregator, lggr logger.Logger) *triggerSubscriber

func ToPeerID

func ToPeerID(peerID []byte) p2ptypes.PeerID

func ValidateMessage

func ValidateMessage(msg p2ptypes.Message, expectedReceiver p2ptypes.PeerID) (*remotetypes.MessageBody, error)