impl

Documentation

Index

• Constants
• Variables
• func NewEdgeConnFactory(routerName, key string, owner RouterConnOwner) edge.RouterConn
• func NewNoopSequencer[T any](channelDepth int) *noopSeq[T]
• type ConnType
• type MultiListener
  • func NewMultiListener(service *edge.Service, getSessionF func() *edge.Session) MultiListener
• type MultipleErrors
  • func (e MultipleErrors) Error() string
• type ReadTimout
  • func (r ReadTimout) Error() string
  • func (r ReadTimout) Temporary() bool
  • func (r ReadTimout) Timeout() bool
• type RouterConnOwner

Constants

const (
	ConnTypeDial = 1
	ConnTypeBind = 2
)

Variables

var ErrClosed = errors.New("sequencer closed")

Functions

func NewEdgeConnFactory

func NewEdgeConnFactory(routerName, key string, owner RouterConnOwner) edge.RouterConn

func NewNoopSequencer

func NewNoopSequencer[T any](channelDepth int) *noopSeq[T]

Types

type ConnType

type ConnType byte

type MultiListener

type MultiListener interface {
	edge.Listener
	AddListener(listener edge.Listener, closeHandler func())
	NotifyOfChildError(err error)
	GetServiceName() string
	GetService() *edge.Service
	CloseWithError(err error)
}

func NewMultiListener

func NewMultiListener(service *edge.Service, getSessionF func() *edge.Session) 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)
}