transmission

Documentation

Index

• Variables
• func GetPeerIDToTransmissionDelay(donPeerIDs []types.PeerID, req capabilities.CapabilityRequest) (map[types.PeerID]time.Duration, error)
• type LocalTargetCapability
  • func NewLocalTargetCapability(lggr logger.Logger, capabilityID string, localDON capabilities.Node, ...) *LocalTargetCapability
  • func (l *LocalTargetCapability) Execute(ctx context.Context, req capabilities.CapabilityRequest) (<-chan capabilities.CapabilityResponse, error)
• type TransmissionConfig

Variables

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

Functions

func GetPeerIDToTransmissionDelay

func GetPeerIDToTransmissionDelay(donPeerIDs []types.PeerID, req capabilities.CapabilityRequest) (map[types.PeerID]time.Duration, error)

GetPeerIDToTransmissionDelay returns a map of PeerID to the time.Duration that the node with that PeerID should wait before transmitting the capability request. If a node is not in the map, it should not transmit.

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, capabilityID string, localDON capabilities.Node, 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
}