db_holder

Documentation

Index

• Constants
• Variables
• func GetSQLWriterDBAddressFunc() func(context.Context, bool) (string, error)
• func InitOrRefreshDBConn(forceNewConn bool, randomCN bool) (*sql.DB, error)
• func SetDBConn(conn *sql.DB)
• func SetSQLWriterDBAddressFunc(f func(context.Context, bool) (string, error))
• func SetSQLWriterDBUser(userName string, password string)
• func WriteRowRecords(records [][]string, tbl *table.Table, timeout time.Duration) (int, error)
• type DBUser
  • func GetSQLWriterDBUser() (*DBUser, error)

Constants

const DBConnRetryThreshold = 8

const MOLoggerUser = "mo_logger"

const MaxConnectionNumber = 1

const MaxInsertLen = 200

const MiddleInsertLen = 10

Variables

var (
	DBConnErrCount atomic.Uint32
)

sqlWriterDBUser holds the db user for logger

Functions

func GetSQLWriterDBAddressFunc

func GetSQLWriterDBAddressFunc() func(context.Context, bool) (string, error)

func InitOrRefreshDBConn

func InitOrRefreshDBConn(forceNewConn bool, randomCN bool) (*sql.DB, error)

func SetDBConn

func SetDBConn(conn *sql.DB)

func SetSQLWriterDBAddressFunc

func SetSQLWriterDBAddressFunc(f func(context.Context, bool) (string, error))

func SetSQLWriterDBUser

func SetSQLWriterDBUser(userName string, password string)

func WriteRowRecords

func WriteRowRecords(records [][]string, tbl *table.Table, timeout time.Duration) (int, error)

Types

type DBUser

type DBUser struct {
	UserName string
	Password string
}

func GetSQLWriterDBUser

func GetSQLWriterDBUser() (*DBUser, error)