base

func Check ¶

func Check(a interface{})

结构体指针检查验证，如果传入的interface为nil，就通过log.Panic函数抛出一个异常 被用在starter中检查公共资源是否被实例化了

func DbxDatabase ¶

func DbxDatabase() *dbx.Database

func ExecuteContext ¶

func ExecuteContext(ctx context.Context, fn func(*dbx.TxRunner) error) error

在事务上下文中执行事务逻辑 传入绑定了runner的上下文，并执行事务函数代码 函数只能用在绑定了runner的事务上下文中，也就是说用在事务函数内部，和WithValueContext配合一起来完成。 举例：

func CreateXyz() error {
	err := Tx(func(runner *dbx.TxRunner) error {
		//将runner绑定到上下文
		ctx := WithValueContext(context.Background(), runner)
		//dao.insert xxx
		TxStepY(ctx)
		TxStepZ(ctx)
		return nil
	})

	return err
}

func TxStepY(ctx context.Context) error {
	//事务上下文中执行Y数据库操作
	return ExecuteContext(ctx, func(runner *dbx.TxRunner) error {
		//dao.insert yyy
		return nil
	})

}

func TxStepZ(ctx context.Context) error {
	//事务上下文中执行Z数据库操作
	return ExecuteContext(ctx, func(runner *dbx.TxRunner) error {
		//dao.update zzz
		return nil
	})

}

func GetEnvelopeActivityLink ¶

func GetEnvelopeActivityLink() string

读取红包活动相关配置

func GetEnvelopeDomain ¶

func GetEnvelopeDomain() string

func Iris ¶

func Iris() *iris.Application

iris applicaiton 的暴漏函数

func Props ¶

func Props() kvs.ConfigSource

func Register ¶

func Register(fn func())

func RpcRegister ¶

func RpcRegister(ri interface{})

api 向 rpc server 注册函数

func RpcServer ¶

func RpcServer() *rpc.Server

rpc server 获取函数

func Translator ¶

func Translator() ut.Translator

func Tx ¶

func Tx(fn func(*dbx.TxRunner) error) error

事务执行帮助函数，简化代码

func TxContext ¶

func TxContext(ctx context.Context, fn func(runner *dbx.TxRunner) error) error

事务执行帮助函数，简化代码，需要传入上下文

func Validate ¶

func Validate() *validator.Validate

func ValidateStruct ¶

func ValidateStruct(s interface{}) (err error)

验证输入参数是否合法

func WithValueContext ¶

func WithValueContext(parent context.Context, runner *dbx.TxRunner) context.Context

将runner绑定到上下文，并创建一个新的WithValueContext