Documentation ¶
Index ¶
- type Carrior
- type Chan
- type MWHandler
- type MWNode
- type MiddleManager
- type MiddlewareManager
- func (mgr *MiddlewareManager) ChangeChanBufferSize(mn string, chl_size int) error
- func (mgr *MiddlewareManager) DropMW(mn string) error
- func (mgr *MiddlewareManager) InsertMWBack(mn string, nn *MWNode) error
- func (mgr *MiddlewareManager) MWIter(ii string)
- func (mgr *MiddlewareManager) Register(mwn *MWNode)
- func (mgr *MiddlewareManager) Run()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MWHandler ¶
type MWHandler func() MiddleManager
type MWNode ¶
type MWNode struct { Name string Create MWHandler GRT_NUM int CHL_SIZE int ClosedGRTNum int64 Instances []MiddleManager Next *MWNode }
单个中间件及配置
type MiddleManager ¶
type MiddlewareManager ¶
type MiddlewareManager struct { TXL *MWNode // contains filtered or unexported fields }
中间件管理器
func NewMWManager ¶
func NewMWManager() *MiddlewareManager
func (*MiddlewareManager) ChangeChanBufferSize ¶
func (mgr *MiddlewareManager) ChangeChanBufferSize(mn string, chl_size int) error
修改缓冲区大小
func (*MiddlewareManager) InsertMWBack ¶
func (mgr *MiddlewareManager) InsertMWBack(mn string, nn *MWNode) error
在某个中间件的前面插入添加的中间件
Click to show internal directories.
Click to hide internal directories.