network

Documentation

Index

• 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 *rest_model.ServiceDetail, ...) 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

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

const (
	ConnTypeDial ConnType = 1
	ConnTypeBind ConnType = 2
)

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)
}