common

Documentation

Index

• Constants
• Variables
• type Flow
• type FlowInitializeFunc

Constants

const DefaultTimeout = 120 * time.Second

DefaultTimeout is the default duration to wait for enqueuing/dequeuing to/from routes.

Variables

var ErrPeerWithSameIDExists = errors.New("ready peer with the same ID already exists")

ErrPeerWithSameIDExists signifies that a peer with the same ID already exist.

Types

type Flow

type Flow struct {
	Name        string
	ExecuteFunc flowExecuteFunc
}

Flow is a a data structure that is used in order to associate a p2p flow to some route in a router.

type FlowInitializeFunc

type FlowInitializeFunc func(route *routerpkg.Route, peer *peerpkg.Peer) error

FlowInitializeFunc is a function that is used in order to initialize a flow