Documentation ¶
Index ¶
Constants ¶
View Source
const ( ProtocolExpiration = time.Second * 60 PeerDestinationPrefix = "peer.route" PeerDestinationRouteControl = PeerDestinationPrefix + ".control" PeerDestinationRouteUpdate = PeerDestinationPrefix + ".update" )
View Source
const ( ModeIdle = iota ModeSync )
Variables ¶
View Source
var ( ModeToString = map[uint8]string{ ModeSync: "MODE_SYNC", ModeIdle: "MODE_IDLE", } )
View Source
var (
PeerRoutingExecutionCondition, _ = base64.StdEncoding.DecodeString("Zmh6rfhivXdsj8GLjp+OIAiXFIVu4jOzkCpZHQ1fKSU=")
)
Functions ¶
func DecodeMessage ¶
Types ¶
type Route ¶
type RouteControlRequest ¶
type RouteControlRequest struct { Mode uint8 LastKnownRoutingTableId string LastKnownEpoch uint32 Features [][]byte }
func (*RouteControlRequest) MarshalOER ¶
func (m *RouteControlRequest) MarshalOER(enc *oer.Encoder) error
func (*RouteControlRequest) UnmarshalOER ¶
func (m *RouteControlRequest) UnmarshalOER(dec *oer.Decoder) error
type RouteProp ¶
type RouteProp struct { Meta uint8 // Buffer or string Id uint16 Value []byte // stays byte for buffer, converted to string if utf8 }
func (*RouteProp) IsOptional ¶
func (*RouteProp) IsTransitive ¶
type RouteUpdateRequest ¶
type RouteUpdateRequest struct { RoutingTableID string CurrentEpochIndex uint32 FromEpochIndex uint32 ToEpochIndex uint32 HoldDownTime time.Duration Speaker ilp.Address NewRoutes []Route WithdrawnRoutes []ilp.Address }
func (*RouteUpdateRequest) MarshalOER ¶
func (m *RouteUpdateRequest) MarshalOER(enc *oer.Encoder) error
func (*RouteUpdateRequest) UnmarshalOER ¶
func (m *RouteUpdateRequest) UnmarshalOER(dec *oer.Decoder) error
Click to show internal directories.
Click to hide internal directories.