connector

Documentation

Index

• Constants
• func NewConnect(...[]AuthOption)
• type AuthOption
• type ConnectConfig
  • func NewConnectorConfig() *ConnectConfig
• type ConnectHandle
• type ConnectOption
  • func SetCacheSize(cacheSize uint64) ConnectOption
• type LogAuth
• type LogMinterConnector
  • func (c *LogMinterConnector) SetDefault(a AuthOption, tz string)

Constants

const (
	DefaultTimeZone = "UTC"
	PoolConnectMin  = 1
	PoolConnectMax  = 1
)

Functions

func NewConnect

func NewConnect(...[]AuthOption)

Types

type AuthOption

type AuthOption struct {
	Url      string
	UserName string
	Password string
}

type ConnectConfig

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

func NewConnectorConfig

func NewConnectorConfig() *ConnectConfig

type ConnectHandle

type ConnectHandle struct {
	DB      *sql.DB
	Session *sql.Conn
}

type ConnectOption

type ConnectOption func(*ConnectConfig) error

func SetCacheSize

func SetCacheSize(cacheSize uint64) ConnectOption

type LogAuth

type LogAuth struct {
	Auth  AuthOption
	Conn  map[int]*ConnectHandle
	State string
}

type LogMinterConnector

type LogMinterConnector struct {
	Auth     [7]*LogAuth // 最大支持7个线程
	Parallel int8        // 线程并发数, 默认4个
	Threads  int8        // 当前建立的线程
}

func (*LogMinterConnector) SetDefault

func (c *LogMinterConnector) SetDefault(a AuthOption, tz string)