db_holder

Documentation

Index

• Constants
• Variables
• func CloseDBConn()
• func GetLabelSelector() map[string]string
• func GetOrInitDBConn(forceNewConn bool, randomCN bool) (*sql.DB, error)
• func GetSQLWriterDBAddressFunc() func(context.Context, bool) (string, error)
• func IsRecordExisted(ctx context.Context, record []string, tbl *table.Table, ...) (bool, error)
• func SetDBConn(conn *sql.DB)
• func SetLabelSelector(labels map[string]string)
• 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 CSVWriter
  • func NewCSVWriter(ctx context.Context) *CSVWriter
  • func (w *CSVWriter) GetContent() string
  • func (w *CSVWriter) Release()
  • func (w *CSVWriter) WriteStrings(record []string) error
• type DBConnProvider
• type DBUser
  • func GetSQLWriterDBUser() (*DBUser, error)

Constants

const DBConnRetryThreshold = 8

const DBRefreshTime = time.Hour

const MOLoggerUser = "mo_logger"

const MaxConnectionNumber = 1

Variables

var (
	DBConnErrCount atomic.Uint32
)

sqlWriterDBUser holds the db user for logger

Functions

func CloseDBConn

func CloseDBConn()

func GetLabelSelector

func GetLabelSelector() map[string]string

GetLabelSelector Tips: more details in route.RouteForSuperTenant function. It mainly depends on S1. Tips: gLabels better contain {"account":"sys"}. - Because clusterservice.Selector using clusterservice.globbing do regex-match in route.RouteForSuperTenant - If you use labels{"account":"sys", "role":"ob"}, the Selector can match those pods, which have labels{"account":"*", "role":"ob"}

func GetOrInitDBConn

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

func GetSQLWriterDBAddressFunc

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

func IsRecordExisted

func IsRecordExisted(ctx context.Context, record []string, tbl *table.Table, getDBConn DBConnProvider) (bool, error)

func SetDBConn

func SetDBConn(conn *sql.DB)

func SetLabelSelector

func SetLabelSelector(labels map[string]string)

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 CSVWriter

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

func NewCSVWriter

func NewCSVWriter(ctx context.Context) *CSVWriter

func (*CSVWriter) GetContent

func (w *CSVWriter) GetContent() string

func (*CSVWriter) Release

func (w *CSVWriter) Release()

func (*CSVWriter) WriteStrings

func (w *CSVWriter) WriteStrings(record []string) error

type DBConnProvider

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

type DBUser

type DBUser struct {
	UserName string
	Password string
}

func GetSQLWriterDBUser

func GetSQLWriterDBUser() (*DBUser, error)