core

Documentation

Index

• Variables
• func CoreModule() *core
• func DefaultLogger() *logrus.Entry
• func NewServ(ctx context.Context, params router.NSManagerParams) *serv
• func NewSession(ctx context.Context, params router.PeerParams, logger *logrus.Entry) router.Session
• func SetDefaultLogger(logger *logrus.Entry)
• type CoreSettings
• type ServerOption
• type SessionImpl
  • func (session *SessionImpl) BindFrameDestination(dest deliver.FrameDestination) error
  • func (session *SessionImpl) BindFrameSource(src deliver.FrameSource) error
  • func (session *SessionImpl) Context() context.Context
  • func (session *SessionImpl) Finalize(e error)
  • func (session *SessionImpl) FrameDestination() deliver.FrameDestination
  • func (session *SessionImpl) FrameSource() deliver.FrameSource
  • func (session *SessionImpl) Get(key interface{}) interface{}
  • func (session *SessionImpl) GetNamespace() *router.Namespace
  • func (session *SessionImpl) GetRouter() router.Router
  • func (session *SessionImpl) ID() string
  • func (session *SessionImpl) Join() error
  • func (session *SessionImpl) Logger() *logrus.Entry
  • func (session *SessionImpl) PeerParams() router.PeerParams
  • func (session *SessionImpl) RouterID() string
  • func (session *SessionImpl) Set(key, value interface{})
  • func (session *SessionImpl) SetNamespace(ns *router.Namespace)
  • func (session *SessionImpl) SetRouter(r router.Router)

Variables

var (
	ErrFrameSourceAlreadyBound = errors.New("frame source already bound")
	ErrFrameDestinationBound   = errors.New("frame destination already bound")
	ErrFrameSourceNil          = errors.New("frame source is nil")
	ErrFrameDestinationNil     = errors.New("frame destination is nil")
	ErrFrameSourceClosed       = errors.New("frame source closed")
	ErrFrameDestinationClosed  = errors.New("frame destination closed")
)

Functions

func CoreModule

func CoreModule() *core

func DefaultLogger

func DefaultLogger() *logrus.Entry

func NewServ

func NewServ(ctx context.Context, params router.NSManagerParams) *serv

func NewSession

func NewSession(ctx context.Context, params router.PeerParams, logger *logrus.Entry) router.Session

func SetDefaultLogger

func SetDefaultLogger(logger *logrus.Entry)

Types

type CoreSettings

type CoreSettings struct {
	//httpserv.HttpParams `json:"http" mapstructure:"http"`
	Namespaces router.NSManagerParams `json:"namespaces" mapstructure:"namespaces"`
}

type ServerOption

type ServerOption func(*serv)

type SessionImpl

type SessionImpl struct {
	// contains filtered or unexported fields
}

func (*SessionImpl) BindFrameDestination

func (session *SessionImpl) BindFrameDestination(dest deliver.FrameDestination) error

func (*SessionImpl) BindFrameSource

func (session *SessionImpl) BindFrameSource(src deliver.FrameSource) error

func (*SessionImpl) Context

func (session *SessionImpl) Context() context.Context

func (*SessionImpl) Finalize

func (session *SessionImpl) Finalize(e error)

func (*SessionImpl) FrameDestination

func (session *SessionImpl) FrameDestination() deliver.FrameDestination

func (*SessionImpl) FrameSource

func (session *SessionImpl) FrameSource() deliver.FrameSource

func (*SessionImpl) Get

func (session *SessionImpl) Get(key interface{}) interface{}

func (*SessionImpl) GetNamespace

func (session *SessionImpl) GetNamespace() *router.Namespace

func (*SessionImpl) GetRouter

func (session *SessionImpl) GetRouter() router.Router

func (*SessionImpl) ID

func (session *SessionImpl) ID() string

func (*SessionImpl) Join

func (session *SessionImpl) Join() error

func (*SessionImpl) Logger

func (session *SessionImpl) Logger() *logrus.Entry

func (*SessionImpl) PeerParams

func (session *SessionImpl) PeerParams() router.PeerParams

func (*SessionImpl) RouterID

func (session *SessionImpl) RouterID() string

func (*SessionImpl) Set

func (session *SessionImpl) Set(key, value interface{})

func (*SessionImpl) SetNamespace

func (session *SessionImpl) SetNamespace(ns *router.Namespace)

func (*SessionImpl) SetRouter

func (session *SessionImpl) SetRouter(r router.Router)