poolmgr

Documentation

Index

• type ConnectionKeeper
• type PoolMgr
  • func MatchConnectionPooler(client client.RouterClient, rcfg *config.Router) (PoolMgr, error)
• type SessConnManager
  • func NewSessConnManager(rcfg *config.Router) *SessConnManager
  • func (t *SessConnManager) ConnectionActive(rst ConnectionKeeper) bool
  • func (s *SessConnManager) RouteCB(client client.RouterClient, sh []kr.ShardKey) error
  • func (s *SessConnManager) TXBeginCB(rst ConnectionKeeper) error
  • func (s *SessConnManager) TXEndCB(rst ConnectionKeeper) error
  • func (s *SessConnManager) UnRouteCB(cl client.RouterClient, sh []kr.ShardKey) error
  • func (s *SessConnManager) UnRouteWithError(client client.RouterClient, sh []kr.ShardKey, errmsg error) error
  • func (s *SessConnManager) ValidateReRoute(rst ConnectionKeeper) bool
• type TxConnManager
  • func NewTxConnManager(rcfg *config.Router) *TxConnManager
  • func (t *TxConnManager) ConnectionActive(rst ConnectionKeeper) bool
  • func (t *TxConnManager) RouteCB(client client.RouterClient, sh []kr.ShardKey) error
  • func (t *TxConnManager) TXBeginCB(rst ConnectionKeeper) error
  • func (t *TxConnManager) TXEndCB(rst ConnectionKeeper) error
  • func (t *TxConnManager) UnRouteCB(cl client.RouterClient, sh []kr.ShardKey) error
  • func (t *TxConnManager) UnRouteWithError(client client.RouterClient, sh []kr.ShardKey, errmsg error) error
  • func (t *TxConnManager) ValidateReRoute(rst ConnectionKeeper) bool

Types

type ConnectionKeeper

type ConnectionKeeper interface {
	txstatus.TxStatusMgr
	ActiveShards() []kr.ShardKey
	ActiveShardsReset()

	SyncCount() int64

	DataPending() bool
	RequestData()

	Client() client.RouterClient
}

type PoolMgr

type PoolMgr interface {
	TXBeginCB(rst ConnectionKeeper) error
	TXEndCB(rst ConnectionKeeper) error

	RouteCB(client client.RouterClient, sh []kr.ShardKey) error
	UnRouteCB(client client.RouterClient, sh []kr.ShardKey) error
	UnRouteWithError(client client.RouterClient, sh []kr.ShardKey, errmsg error) error

	ValidateReRoute(rst ConnectionKeeper) bool
	ConnectionActive(rst ConnectionKeeper) bool
}

func MatchConnectionPooler

func MatchConnectionPooler(client client.RouterClient, rcfg *config.Router) (PoolMgr, error)

TODO : unit tests

type SessConnManager

type SessConnManager struct {
}

func NewSessConnManager

func NewSessConnManager(rcfg *config.Router) *SessConnManager

func (*SessConnManager) ConnectionActive

func (t *SessConnManager) ConnectionActive(rst ConnectionKeeper) bool

TODO : unit tests

func (*SessConnManager) RouteCB

func (s *SessConnManager) RouteCB(client client.RouterClient, sh []kr.ShardKey) error

TODO : unit tests

func (*SessConnManager) TXBeginCB

func (s *SessConnManager) TXBeginCB(rst ConnectionKeeper) error

func (*SessConnManager) TXEndCB

func (s *SessConnManager) TXEndCB(rst ConnectionKeeper) error

func (*SessConnManager) UnRouteCB

func (s *SessConnManager) UnRouteCB(cl client.RouterClient, sh []kr.ShardKey) error

TODO : unit tests

func (*SessConnManager) UnRouteWithError

func (s *SessConnManager) UnRouteWithError(client client.RouterClient, sh []kr.ShardKey, errmsg error) error

TODO : unit tests

func (*SessConnManager) ValidateReRoute

func (s *SessConnManager) ValidateReRoute(rst ConnectionKeeper) bool

TODO : unit tests

type TxConnManager

type TxConnManager struct {
}

func NewTxConnManager

func NewTxConnManager(rcfg *config.Router) *TxConnManager

func (*TxConnManager) ConnectionActive

func (t *TxConnManager) ConnectionActive(rst ConnectionKeeper) bool

TODO : unit tests

func (*TxConnManager) RouteCB

func (t *TxConnManager) RouteCB(client client.RouterClient, sh []kr.ShardKey) error

TODO : unit tests

func (*TxConnManager) TXBeginCB

func (t *TxConnManager) TXBeginCB(rst ConnectionKeeper) error

func (*TxConnManager) TXEndCB

func (t *TxConnManager) TXEndCB(rst ConnectionKeeper) error

TODO : unit tests

func (*TxConnManager) UnRouteCB

func (t *TxConnManager) UnRouteCB(cl client.RouterClient, sh []kr.ShardKey) error

TODO : unit tests

func (*TxConnManager) UnRouteWithError

func (t *TxConnManager) UnRouteWithError(client client.RouterClient, sh []kr.ShardKey, errmsg error) error

TODO : unit tests

func (*TxConnManager) ValidateReRoute

func (t *TxConnManager) ValidateReRoute(rst ConnectionKeeper) bool

TODO : unit tests