common

Documentation

Index

• Variables
• func AppendErrGroup(eg *errgroup.Group, f ErrFunc, args ...interface{})
• func AppendErrGroupWithContext(ctx context.Context, eg *errgroup.Group, f ErrFunc, args ...interface{})
• func FindPtr[T any](db *mysql.DB) ([]*T, error)
• func ShardingInt(i int) uint32
• func WhereFind[T any](db *mysql.DB, query interface{}, args ...interface{}) ([]T, error)
• func WhereFindPtr[T any](db *mysql.DB, query interface{}, args ...interface{}) ([]*T, error)
• type ErrFunc
• type ORG
  • func NewORG(id int) (*ORG, error)
  • func (o *ORG) GetDB() *mysql.DB
  • func (o *ORG) GetID() int
  • func (o *ORG) Log(format string) string
  • func (o *ORG) Logf(format string, a ...any) string

Variables

var (
	ResourcePrometheusMetricName           = "metric_name"
	ResourcePrometheusLabelName            = "label_name"
	ResourcePrometheusLabelValue           = "label_value"
	ResourcePrometheusMetricAPPLabelLayout = "metric_app_label_layout"
	ResourcePrometheusLabel                = "label"
	ResourcePrometheusMetricLabelName      = "metric_label_name"
)

var (
	TargetLabelInstance = "instance"
	TargetLabelJob      = "job"
)

Functions

func AppendErrGroup

func AppendErrGroup(eg *errgroup.Group, f ErrFunc, args ...interface{})

func AppendErrGroupWithContext

func AppendErrGroupWithContext(ctx context.Context, eg *errgroup.Group, f ErrFunc, args ...interface{})

func FindPtr

func FindPtr[T any](db *mysql.DB) ([]*T, error)

func ShardingInt

func ShardingInt(i int) uint32

现在使用此方法的地方，传参实际在 uint32 范围内，使用此方法是为了方便调用 concurrent 库

func WhereFind

func WhereFind[T any](db *mysql.DB, query interface{}, args ...interface{}) ([]T, error)

func WhereFindPtr

func WhereFindPtr[T any](db *mysql.DB, query interface{}, args ...interface{}) ([]*T, error)

Types

type ErrFunc

type ErrFunc func(...interface{}) error

type ORG

type ORG struct {
	ID        int       // org id
	DB        *mysql.DB // org database connection
	LogPrefix logger.Prefix
}

func NewORG

func NewORG(id int) (*ORG, error)

func (*ORG) GetDB

func (o *ORG) GetDB() *mysql.DB

func (*ORG) GetID

func (o *ORG) GetID() int

func (*ORG) Log

func (o *ORG) Log(format string) string

func (*ORG) Logf

func (o *ORG) Logf(format string, a ...any) string