poolmgr

package
v0.0.0-...-096c525 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 24, 2024 License: PostgreSQL Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL