impl

Documentation

Index

• Constants
• func NewEdgeConnFactory(routerName, key string, ch channel2.Channel, owner RouterConnOwner) edge.RouterConn
• type MultiListener
  • func NewMultiListener(service *edge.Service, getSessionF func() *edge.Session) MultiListener
• type MultipleErrors
  • func (e MultipleErrors) Error() string
• type RouterConnOwner

Constants

const (
	// TODO: Add configuration mechanism for the SDK
	DefaultMaxOutOfOrderMsgs = 5000
)

Functions

func NewEdgeConnFactory

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

Types

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 RouterConnOwner

type RouterConnOwner interface {
	OnClose(factory edge.RouterConn)
}