factory

Documentation

Index

• type DefaultFactory
  • func (f *DefaultFactory) Close() error
  • func (f *DefaultFactory) CreateExecutor(transaction transaction.Transaction) executor.Executor
  • func (f *DefaultFactory) CreateSession() session.SqlSession
  • func (f *DefaultFactory) CreateTransaction() transaction.Transaction
  • func (f *DefaultFactory) GetDataSource() datasource.DataSource
  • func (f *DefaultFactory) InitDB() error
  • func (f *DefaultFactory) LogFunc() logging.LogFunc
  • func (f *DefaultFactory) Open(ds datasource.DataSource) error
  • func (f *DefaultFactory) WithLock(lockFunc func(fac *DefaultFactory))
• type DefaultMultiSource
  • func NewMultiSource(t LoadBalanceType) *DefaultMultiSource
  • func (lb *DefaultMultiSource) Bind(action string, weight int, factory Factory)
  • func (lb *DefaultMultiSource) Select(action string) Factory
• type Factory
• type LoadBalanceType
• type Manager
• type SingleSource
  • func NewSingleSource(fac Factory) *SingleSource
  • func (lb *SingleSource) Bind(action string, weight int, factory Factory)
  • func (lb *SingleSource) Select(action string) Factory

Types

type DefaultFactory

type DefaultFactory struct {
	MaxConn         int
	MaxIdleConn     int
	ConnMaxLifetime time.Duration
	Log             logging.LogFunc

	DataSource datasource.DataSource
	// contains filtered or unexported fields
}

func (*DefaultFactory) Close

func (f *DefaultFactory) Close() error

func (*DefaultFactory) CreateExecutor

func (f *DefaultFactory) CreateExecutor(transaction transaction.Transaction) executor.Executor

func (*DefaultFactory) CreateSession

func (f *DefaultFactory) CreateSession() session.SqlSession

func (*DefaultFactory) CreateTransaction

func (f *DefaultFactory) CreateTransaction() transaction.Transaction

func (*DefaultFactory) GetDataSource

func (f *DefaultFactory) GetDataSource() datasource.DataSource

func (*DefaultFactory) InitDB

func (f *DefaultFactory) InitDB() error

Deprecated: Use Open instead

func (*DefaultFactory) LogFunc

func (f *DefaultFactory) LogFunc() logging.LogFunc

func (*DefaultFactory) Open

func (f *DefaultFactory) Open(ds datasource.DataSource) error

func (*DefaultFactory) WithLock

func (f *DefaultFactory) WithLock(lockFunc func(fac *DefaultFactory))

type DefaultMultiSource

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

func NewMultiSource

func NewMultiSource(t LoadBalanceType) *DefaultMultiSource

func (*DefaultMultiSource) Bind

func (lb *DefaultMultiSource) Bind(action string, weight int, factory Factory)

func (*DefaultMultiSource) Select

func (lb *DefaultMultiSource) Select(action string) Factory

type Factory

type Factory interface {
	Open(datasource.DataSource) error
	Close() error

	GetDataSource() datasource.DataSource

	CreateTransaction() transaction.Transaction
	CreateExecutor(transaction.Transaction) executor.Executor
	CreateSession() session.SqlSession
	LogFunc() logging.LogFunc
}

type LoadBalanceType

type LoadBalanceType int

const (
	LBRoundRobbin       LoadBalanceType = loadbalance.LBRoundRobbin
	LBRoundRobbinWeight LoadBalanceType = loadbalance.LBRoundRobbinWeight
	LBRandom            LoadBalanceType = loadbalance.LBRandom
	LBRandomWeight      LoadBalanceType = loadbalance.LBRandomWeight

	DefaultGroup = "default"
)

type Manager

type Manager interface {
	Bind(action string, weight int, factory Factory)
	Select(action string) Factory
}

type SingleSource

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

func NewSingleSource

func NewSingleSource(fac Factory) *SingleSource

func (*SingleSource) Bind

func (lb *SingleSource) Bind(action string, weight int, factory Factory)

func (*SingleSource) Select

func (lb *SingleSource) Select(action string) Factory