transmission

Documentation

Index

• Variables
• func GetPeerIDToTransmissionDelay(donPeerIDs []ragep2ptypes.PeerID, sharedSecret [16]byte, transmissionID string, ...) (map[p2ptypes.PeerID]time.Duration, error)
• type LocalTargetCapability
  • func NewLocalTargetCapability(lggr logger.Logger, peerID p2ptypes.PeerID, don capabilities.DON, ...) *LocalTargetCapability
  • func (l *LocalTargetCapability) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
• type TransmissionConfig
  • func ExtractTransmissionConfig(config *values.Map) (TransmissionConfig, error)

Variables

var (
	// S = [N]
	Schedule_AllAtOnce = "allAtOnce"
	// S = [1 * N]
	Schedule_OneAtATime = "oneAtATime"
)

Functions

func GetPeerIDToTransmissionDelay

func GetPeerIDToTransmissionDelay(donPeerIDs []ragep2ptypes.PeerID, sharedSecret [16]byte, transmissionID string, tc TransmissionConfig) (map[p2ptypes.PeerID]time.Duration, error)

GetPeerIDToTransmissionDelay returns a map of PeerID to the time.Duration that the node with that PeerID should wait before transmitting. If a node is not in the map, it should not transmit. The sharedSecret is shared by nodes in the same DON and used to generate a deterministic schedule for the transmission delays.

Types

type LocalTargetCapability

type LocalTargetCapability struct {
	capabilities.TargetCapability
	// contains filtered or unexported fields
}

LocalTargetCapability handles the transmission protocol required for a target capability that exists in the same don as the caller.

func NewLocalTargetCapability

func NewLocalTargetCapability(lggr logger.Logger, peerID p2ptypes.PeerID, don capabilities.DON, underlying capabilities.TargetCapability) *LocalTargetCapability

func (*LocalTargetCapability) Execute

func (l *LocalTargetCapability) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)

type TransmissionConfig

type TransmissionConfig struct {
	Schedule   string
	DeltaStage time.Duration
}

func ExtractTransmissionConfig

func ExtractTransmissionConfig(config *values.Map) (TransmissionConfig, error)