Documentation
¶
Index ¶
- Variables
- func NewEdgeConnFactory(routerName, key string, owner RouterConnOwner) edge.RouterConn
- func NewMessageTimingBinding(binding channel.Binding) channel.Binding
- func NewNoopSequencer[T any](closeNotify <-chan struct{}, channelDepth int) *noopSeq[T]
- type MultiListener
- type MultipleErrors
- type ReadTimout
- type RouterConnOwner
- type XgAdapter
- func (self *XgAdapter) Close() error
- func (self *XgAdapter) FlowFromFabricToXgressClosed()
- func (self *XgAdapter) ForwardAcknowledgement(ack *xgress.Acknowledgement, address xgress.Address)
- func (self *XgAdapter) ForwardControlMessage(control *xgress.Control, x *xgress.Xgress)
- func (self *XgAdapter) ForwardPayload(payload *xgress.Payload, _ *xgress.Xgress, ctx context.Context)
- func (self *XgAdapter) GetMetrics() xgress.Metrics
- func (self *XgAdapter) GetPayloadIngester() *xgress.PayloadIngester
- func (self *XgAdapter) GetRetransmitter() *xgress.Retransmitter
- func (self *XgAdapter) HandleControlMsg(controlType xgress.ControlType, headers channel.Headers, ...) error
- func (self *XgAdapter) HandleXgressClose(x *xgress.Xgress)
- func (self *XgAdapter) LogContext() string
- func (self *XgAdapter) ReadPayload() ([]byte, map[uint8][]byte, error)
- func (self *XgAdapter) RetransmitPayload(srcAddr xgress.Address, payload *xgress.Payload) error
- func (self *XgAdapter) WritePayload(bytes []byte, headers map[uint8][]byte) (int, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrClosed = errors.New("sequencer closed")
Functions ¶
func NewEdgeConnFactory ¶
func NewEdgeConnFactory(routerName, key string, owner RouterConnOwner) edge.RouterConn
func NewMessageTimingBinding ¶ added in v1.1.0
func NewMessageTimingBinding(binding channel.Binding) channel.Binding
func NewNoopSequencer ¶
Types ¶
type MultiListener ¶
type MultiListener interface {
edge.Listener
AddListener(listener edge.Listener, closeHandler func())
NotifyOfChildError(err error)
GetServiceName() string
GetService() *rest_model.ServiceDetail
CloseWithError(err error)
GetEstablishedCount() uint
}
func NewMultiListener ¶
func NewMultiListener(service *rest_model.ServiceDetail, getSessionF func() *rest_model.SessionDetail) MultiListener
type MultipleErrors ¶
type MultipleErrors []error
func (MultipleErrors) Error ¶
func (e MultipleErrors) Error() string
type ReadTimout ¶
type ReadTimout struct{}
func (ReadTimout) Error ¶
func (r ReadTimout) Error() string
func (ReadTimout) Temporary ¶
func (r ReadTimout) Temporary() bool
func (ReadTimout) Timeout ¶
func (r ReadTimout) Timeout() bool
type RouterConnOwner ¶
type RouterConnOwner interface {
OnClose(factory edge.RouterConn)
}
type XgAdapter ¶ added in v1.1.0
type XgAdapter struct {
// contains filtered or unexported fields
}
func (*XgAdapter) FlowFromFabricToXgressClosed ¶ added in v1.2.0
func (self *XgAdapter) FlowFromFabricToXgressClosed()
func (*XgAdapter) ForwardAcknowledgement ¶ added in v1.1.0
func (self *XgAdapter) ForwardAcknowledgement(ack *xgress.Acknowledgement, address xgress.Address)
func (*XgAdapter) ForwardControlMessage ¶ added in v1.1.0
func (*XgAdapter) ForwardPayload ¶ added in v1.1.0
func (*XgAdapter) GetMetrics ¶ added in v1.1.0
func (*XgAdapter) GetPayloadIngester ¶ added in v1.1.0
func (self *XgAdapter) GetPayloadIngester() *xgress.PayloadIngester
func (*XgAdapter) GetRetransmitter ¶ added in v1.1.0
func (self *XgAdapter) GetRetransmitter() *xgress.Retransmitter
func (*XgAdapter) HandleControlMsg ¶ added in v1.1.0
func (self *XgAdapter) HandleControlMsg(controlType xgress.ControlType, headers channel.Headers, responder xgress.ControlReceiver) error
func (*XgAdapter) HandleXgressClose ¶ added in v1.1.0
func (*XgAdapter) LogContext ¶ added in v1.1.0
func (*XgAdapter) ReadPayload ¶ added in v1.1.0
func (*XgAdapter) RetransmitPayload ¶ added in v1.1.0
Source Files
Click to show internal directories.
Click to hide internal directories.