task

Documentation

Index

• Constants
• func BillGenerateTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func BillingFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func CustomerPrintTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func CustomerShardingTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func DbShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func DpdnPlanTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func GetGoroutineID() uint64
• func LargeShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func MySerialKeyPostfixGenFunc(param *gs.RunReq) string
• func OverdueFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func OverduePlanFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func Panic(cxt context.Context, param *gs.RunReq) (msg []string, err error)
• func PlanRemainFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func RowReduceShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func RowShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func RowSumShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func TableShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)
• func TaskBillGenerate(cxt context.Context, param *gs.RunReq) (msg []string, err error)
• func TaskBizDateChange(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func TaskFeeCalculate(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func Test(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func Test2(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func Test3(ctx context.Context, param *gs.RunReq) (msg []string, err error)
• func TestP(cxt context.Context, param *gs.RunReq) (msg []string, err error)
• type A
• type MpParam

Constants

const DB_NUM = 3

const DB_TABLE_NUM = 10

Functions

func BillGenerateTask

func BillGenerateTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func BillingFileTask

func BillingFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func CustomerPrintTaskFunc

func CustomerPrintTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

CustomerPrintTaskFunc 任务执行函数

func CustomerShardingTaskFunc

func CustomerShardingTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

CustomerShardingTaskFunc 任务执行函数

func DbShardingMapReduceTaskFunc

func DbShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

DbShardingMapReduceTaskFunc 任务执行函数

func DpdnPlanTask

func DpdnPlanTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func GetGoroutineID

func GetGoroutineID() uint64

func LargeShardingMapReduceTaskFunc

func LargeShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

LargeShardingMapReduceTaskFunc 任务执行函数

func MySerialKeyPostfixGenFunc

func MySerialKeyPostfixGenFunc(param *gs.RunReq) string

func OverdueFileTask

func OverdueFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func OverduePlanFileTask

func OverduePlanFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func Panic

func Panic(cxt context.Context, param *gs.RunReq) (msg []string, err error)

func PlanRemainFileTask

func PlanRemainFileTask(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func RowReduceShardingMapReduceTaskFunc

func RowReduceShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

RowReduceShardingMapReduceTaskFunc 最终统计任务执行函数

func RowShardingMapReduceTaskFunc

func RowShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

RowShardingMapReduceTaskFunc 数据分批任务执行函数

func RowSumShardingMapReduceTaskFunc

func RowSumShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

RowSumShardingMapReduceTaskFunc 分批统计任务执行函数

func TableShardingMapReduceTaskFunc

func TableShardingMapReduceTaskFunc(cxt context.Context, param *gs.RunReq) ([]string, error)

TableShardingMapReduceTaskFunc 表任务执行函数

func TaskBillGenerate

func TaskBillGenerate(cxt context.Context, param *gs.RunReq) (msg []string, err error)

func TaskBizDateChange

func TaskBizDateChange(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func TaskFeeCalculate

func TaskFeeCalculate(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func Test

func Test(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func Test2

func Test2(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func Test3

func Test3(ctx context.Context, param *gs.RunReq) (msg []string, err error)

func TestP

func TestP(cxt context.Context, param *gs.RunReq) (msg []string, err error)

Types

type A

type A struct {
	A1 string
	V1 string
}

type MpParam

type MpParam struct {
	DbIdx    int
	TableIdx int
	RowStart int
	Limit    int
}