executor

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddCampaignArgs 

func AddCampaignArgs(model *models.AddCampaignRequestVO) []interface{}

func AddCampaignTemplateArgs 

func AddCampaignTemplateArgs(model *models.AddCampaignTemplateRequestVO) []interface{}

func AddControlGroupArgs 

func AddControlGroupArgs(model *models.AddControlGroupRequestVO) []interface{}

func AddDynamicDataArgs 

func AddDynamicDataArgs(model *models.AddDynamicDataRequestVO) []interface{}

func AddInactionTargetUserArgs 

func AddInactionTargetUserArgs(model *models.AddInactionTargetUserRequestVO) []interface{}

func AddQueryCampaignArgs 

func AddQueryCampaignArgs(model *models.AddQueryCampaignRequestVO) []interface{}

func AddTargetUserArgs 

func AddTargetUserArgs(model *models.AddTargetUserRequestVO) []interface{}

func DeleteCampaignTemplateArgs 

func DeleteCampaignTemplateArgs(model *models.DeleteCampaignTemplateRequestVO) []interface{}

func Execute 

func Execute(ctx context.Context, request *fs.MultiRequests) []error

func FindCampaignByIdArgs 

func FindCampaignByIdArgs(request *fs.FindCampaignByIdRequest) []interface{}

func FindCampaignTemplateByIdArgs 

func FindCampaignTemplateByIdArgs(request *fs.FindCampaignTemplateByIdRequest) []interface{}

func FindControlGroupByCampaignIdArgs 

func FindControlGroupByCampaignIdArgs(request *fs.FindControlGroupByCampaignIdRequest) []interface{}

func FindInactionTargetUserByCampaignIdArgs 

func FindInactionTargetUserByCampaignIdArgs(request *fs.FindInactionTargetUserByCampaignIdRequest) []interface{}

func FindQueryCampaignArgs 

func FindQueryCampaignArgs(request *fs.FindQueryCampaignRequest) []interface{}

func FindQueryCampaignArgsReq 

func FindQueryCampaignArgsReq(model *models.FindQueryCampaignRequestVO) []interface{}

func FindTargetUserByIdArgs 

func FindTargetUserByIdArgs(request *fs.FindTargetUserByIdRequest) []interface{}

func GetDynamicDataByKeyArgs 

func GetDynamicDataByKeyArgs(request *fs.GetDynamicDataByKeyRequest) []interface{}

func HandleTransactionResult 

func HandleTransactionResult(tx dialect.Tx, txErr error) error

func UpdateCampaignArgs 

func UpdateCampaignArgs(model *models.UpdateCampaignRequestVO) []interface{}

Types

type DBDriver 

type DBDriver struct {
	Driver *entsql.Driver
}
var Driver *DBDriver

func (*DBDriver) GetDriver 

func (d *DBDriver) GetDriver() *entsql.Driver

func (*DBDriver) InitializeDriver 

func (d *DBDriver) InitializeDriver()

func (*DBDriver) TransactionRunner 

func (d *DBDriver) TransactionRunner(ctx context.Context, txName string, fun Transaction) (res TransactionResult, txErr error)

type Executor 

type Executor struct {
}

func (*Executor) ExecuteAddCampaign 

func (se *Executor) ExecuteAddCampaign(ctx context.Context, request *fs.AddCampaignRequest) (*fs.AddCampaignResponse, error)

func (*Executor) ExecuteAddCampaignBulk 

func (se *Executor) ExecuteAddCampaignBulk(ctx context.Context, bulkRequest *fs.BulkAddCampaignRequest) (*fs.BulkAddCampaignResponse, error)

func (*Executor) ExecuteAddCampaignTemplate 

func (se *Executor) ExecuteAddCampaignTemplate(ctx context.Context, request *fs.AddCampaignTemplateRequest) (*fs.AddCampaignTemplateResponse, error)

func (*Executor) ExecuteAddCampaignTemplateBulk 

func (se *Executor) ExecuteAddCampaignTemplateBulk(ctx context.Context, bulkRequest *fs.BulkAddCampaignTemplateRequest) (*fs.BulkAddCampaignTemplateResponse, error)

func (*Executor) ExecuteAddControlGroup 

func (se *Executor) ExecuteAddControlGroup(ctx context.Context, request *fs.AddControlGroupRequest) (*fs.AddControlGroupResponse, error)

func (*Executor) ExecuteAddDynamicData 

func (se *Executor) ExecuteAddDynamicData(ctx context.Context, request *fs.AddDynamicDataRequest, tx ...dialect.Tx) (*fs.AddDynamicDataResponse, error)

func (*Executor) ExecuteAddDynamicDataBulk 

func (se *Executor) ExecuteAddDynamicDataBulk(ctx context.Context, bulkRequest *fs.BulkAddDynamicDataRequest, tx ...dialect.Tx) (*fs.BulkAddDynamicDataResponse, error)

func (*Executor) ExecuteAddInactionTargetUser 

func (se *Executor) ExecuteAddInactionTargetUser(ctx context.Context, request *fs.AddInactionTargetUserRequest) (*fs.AddInactionTargetUserResponse, error)

func (*Executor) ExecuteAddInactionTargetUserBulk 

func (se *Executor) ExecuteAddInactionTargetUserBulk(ctx context.Context, bulkRequest *fs.BulkAddInactionTargetUserRequest) (*fs.BulkAddInactionTargetUserResponse, error)

func (*Executor) ExecuteAddQueryCampaign 

func (se *Executor) ExecuteAddQueryCampaign(ctx context.Context, request *fs.AddQueryCampaignRequest) (*fs.AddQueryCampaignResponse, error)

func (*Executor) ExecuteAddQueryCampaignBulk 

func (se *Executor) ExecuteAddQueryCampaignBulk(ctx context.Context, bulkRequest *fs.BulkAddQueryCampaignRequest) (*fs.BulkAddQueryCampaignResponse, error)

func (*Executor) ExecuteAddTargetUser 

func (se *Executor) ExecuteAddTargetUser(ctx context.Context, request *fs.AddTargetUserRequest) (*fs.AddTargetUserResponse, error)

func (*Executor) ExecuteAddTargetUserBulk 

func (se *Executor) ExecuteAddTargetUserBulk(ctx context.Context, bulkRequest *fs.BulkAddTargetUserRequest) (*fs.BulkAddTargetUserResponse, error)

func (*Executor) ExecuteFilterCampaigns 

func (se *Executor) ExecuteFilterCampaigns(ctx context.Context, request *fs.FilterCampaignRequest) (*fs.FilterCampaignResponse, error)

func (*Executor) ExecuteFindCampaignById 

func (se *Executor) ExecuteFindCampaignById(ctx context.Context, request *fs.FindCampaignByIdRequest) (*fs.FindCampaignByIdResponse, error)

func (*Executor) ExecuteFindCampaignTemplateById 

func (se *Executor) ExecuteFindCampaignTemplateById(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) (*fs.FindCampaignTemplateByIdResponse, error)

func (*Executor) ExecuteFindControlGroupByCampaignId 

func (se *Executor) ExecuteFindControlGroupByCampaignId(ctx context.Context, request *fs.FindControlGroupByCampaignIdRequest) (*fs.FindControlGroupByCampaignIdResponse, error)

func (*Executor) ExecuteFindInactionTargetUserByCampaignId 

func (se *Executor) ExecuteFindInactionTargetUserByCampaignId(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) (*fs.FindInactionTargetUserByCampaignIdResponse, error)

func (*Executor) ExecuteFindQueryCampaign 

func (se *Executor) ExecuteFindQueryCampaign(ctx context.Context, request *fs.FindQueryCampaignRequest) (*fs.FindQueryCampaignResponse, error)

func (*Executor) ExecuteFindTargetUserById 

func (se *Executor) ExecuteFindTargetUserById(ctx context.Context, request *fs.FindTargetUserByIdRequest) (*fs.FindTargetUserByIdResponse, error)

func (*Executor) ExecuteGetDynamicDataByKey 

func (se *Executor) ExecuteGetDynamicDataByKey(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, tx ...dialect.Tx) (*fs.GetDynamicDataByKeyResponse, error)

func (*Executor) ExecuteUpdateCampaign 

func (se *Executor) ExecuteUpdateCampaign(ctx context.Context, request *fs.UpdateCampaignRequest, tx ...dialect.Tx) (*fs.UpdateCampaignResponse, error)

type GenericExecutor 

type GenericExecutor struct {
	ServiceExecutor ServiceExecutor
}
var RequestExecutor *GenericExecutor

func (*GenericExecutor) ExecuteAddCampaign 

func (se *GenericExecutor) ExecuteAddCampaign(ctx context.Context, request *fs.AddCampaignRequest) (*fs.AddCampaignResponse, error)

func (*GenericExecutor) ExecuteAddCampaignBulk 

func (se *GenericExecutor) ExecuteAddCampaignBulk(ctx context.Context, bulkrequest *fs.BulkAddCampaignRequest) (*fs.BulkAddCampaignResponse, error)

func (*GenericExecutor) ExecuteAddCampaignTemplate 

func (se *GenericExecutor) ExecuteAddCampaignTemplate(ctx context.Context, request *fs.AddCampaignTemplateRequest) (*fs.AddCampaignTemplateResponse, error)

func (*GenericExecutor) ExecuteAddCampaignTemplateBulk 

func (se *GenericExecutor) ExecuteAddCampaignTemplateBulk(ctx context.Context, bulkrequest *fs.BulkAddCampaignTemplateRequest) (*fs.BulkAddCampaignTemplateResponse, error)

func (*GenericExecutor) ExecuteAddControlGroup 

func (se *GenericExecutor) ExecuteAddControlGroup(ctx context.Context, request *fs.AddControlGroupRequest) (*fs.AddControlGroupResponse, error)

func (*GenericExecutor) ExecuteAddDynamicData 

func (se *GenericExecutor) ExecuteAddDynamicData(ctx context.Context, request *fs.AddDynamicDataRequest, tx ...dialect.Tx) (*fs.AddDynamicDataResponse, error)

func (*GenericExecutor) ExecuteAddDynamicDataBulk 

func (se *GenericExecutor) ExecuteAddDynamicDataBulk(ctx context.Context, bulkrequest *fs.BulkAddDynamicDataRequest, tx ...dialect.Tx) (*fs.BulkAddDynamicDataResponse, error)

func (*GenericExecutor) ExecuteAddInactionTargetUser 

func (se *GenericExecutor) ExecuteAddInactionTargetUser(ctx context.Context, request *fs.AddInactionTargetUserRequest) (*fs.AddInactionTargetUserResponse, error)

func (*GenericExecutor) ExecuteAddInactionTargetUserBulk 

func (se *GenericExecutor) ExecuteAddInactionTargetUserBulk(ctx context.Context, bulkrequest *fs.BulkAddInactionTargetUserRequest) (*fs.BulkAddInactionTargetUserResponse, error)

func (*GenericExecutor) ExecuteAddQueryCampaign 

func (se *GenericExecutor) ExecuteAddQueryCampaign(ctx context.Context, request *fs.AddQueryCampaignRequest) (*fs.AddQueryCampaignResponse, error)

func (*GenericExecutor) ExecuteAddQueryCampaignBulk 

func (se *GenericExecutor) ExecuteAddQueryCampaignBulk(ctx context.Context, bulkrequest *fs.BulkAddQueryCampaignRequest) (*fs.BulkAddQueryCampaignResponse, error)

func (*GenericExecutor) ExecuteAddTargetUser 

func (se *GenericExecutor) ExecuteAddTargetUser(ctx context.Context, request *fs.AddTargetUserRequest) (*fs.AddTargetUserResponse, error)

func (*GenericExecutor) ExecuteAddTargetUserBulk 

func (se *GenericExecutor) ExecuteAddTargetUserBulk(ctx context.Context, bulkrequest *fs.BulkAddTargetUserRequest) (*fs.BulkAddTargetUserResponse, error)

func (*GenericExecutor) ExecuteFilterCampaigns 

func (se *GenericExecutor) ExecuteFilterCampaigns(ctx context.Context, request *fs.FilterCampaignRequest) (*fs.FilterCampaignResponse, error)

func (*GenericExecutor) ExecuteFindCampaignById 

func (se *GenericExecutor) ExecuteFindCampaignById(ctx context.Context, request *fs.FindCampaignByIdRequest) (*fs.FindCampaignByIdResponse, error)

func (*GenericExecutor) ExecuteFindCampaignTemplateById 

func (se *GenericExecutor) ExecuteFindCampaignTemplateById(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) (*fs.FindCampaignTemplateByIdResponse, error)

func (*GenericExecutor) ExecuteFindControlGroupByCampaignId 

func (se *GenericExecutor) ExecuteFindControlGroupByCampaignId(ctx context.Context, request *fs.FindControlGroupByCampaignIdRequest) (*fs.FindControlGroupByCampaignIdResponse, error)

func (*GenericExecutor) ExecuteFindInactionTargetUserByCampaignId 

func (se *GenericExecutor) ExecuteFindInactionTargetUserByCampaignId(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) (*fs.FindInactionTargetUserByCampaignIdResponse, error)

func (*GenericExecutor) ExecuteFindQueryCampaign 

func (se *GenericExecutor) ExecuteFindQueryCampaign(ctx context.Context, request *fs.FindQueryCampaignRequest) (*fs.FindQueryCampaignResponse, error)

func (*GenericExecutor) ExecuteFindTargetUserById 

func (se *GenericExecutor) ExecuteFindTargetUserById(ctx context.Context, request *fs.FindTargetUserByIdRequest) (*fs.FindTargetUserByIdResponse, error)

func (*GenericExecutor) ExecuteGetDynamicDataByKey 

func (se *GenericExecutor) ExecuteGetDynamicDataByKey(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, tx ...dialect.Tx) (*fs.GetDynamicDataByKeyResponse, error)

func (*GenericExecutor) ExecuteUpdateCampaign 

func (se *GenericExecutor) ExecuteUpdateCampaign(ctx context.Context, request *fs.UpdateCampaignRequest, tx ...dialect.Tx) (*fs.UpdateCampaignResponse, error)

type ServiceExecutor 

type ServiceExecutor interface {
	ExecuteAddCampaignBulk(ctx context.Context, bulkrequest *fs.BulkAddCampaignRequest) (*fs.BulkAddCampaignResponse, error)
	ExecuteAddCampaign(ctx context.Context, request *fs.AddCampaignRequest) (*fs.AddCampaignResponse, error)
	ExecuteUpdateCampaign(ctx context.Context, request *fs.UpdateCampaignRequest, tx ...dialect.Tx) (*fs.UpdateCampaignResponse, error)
	ExecuteAddControlGroup(ctx context.Context, request *fs.AddControlGroupRequest) (*fs.AddControlGroupResponse, error)
	ExecuteAddCampaignTemplateBulk(ctx context.Context, bulkrequest *fs.BulkAddCampaignTemplateRequest) (*fs.BulkAddCampaignTemplateResponse, error)
	ExecuteAddCampaignTemplate(ctx context.Context, request *fs.AddCampaignTemplateRequest) (*fs.AddCampaignTemplateResponse, error)
	ExecuteFindCampaignById(ctx context.Context, request *fs.FindCampaignByIdRequest) (*fs.FindCampaignByIdResponse, error)
	ExecuteFindCampaignTemplateById(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) (*fs.FindCampaignTemplateByIdResponse, error)
	ExecuteAddTargetUserBulk(ctx context.Context, bulkrequest *fs.BulkAddTargetUserRequest) (*fs.BulkAddTargetUserResponse, error)
	ExecuteAddTargetUser(ctx context.Context, request *fs.AddTargetUserRequest) (*fs.AddTargetUserResponse, error)
	ExecuteFindTargetUserById(ctx context.Context, request *fs.FindTargetUserByIdRequest) (*fs.FindTargetUserByIdResponse, error)
	ExecuteAddInactionTargetUserBulk(ctx context.Context, bulkrequest *fs.BulkAddInactionTargetUserRequest) (*fs.BulkAddInactionTargetUserResponse, error)
	ExecuteAddInactionTargetUser(ctx context.Context, request *fs.AddInactionTargetUserRequest) (*fs.AddInactionTargetUserResponse, error)
	ExecuteFindInactionTargetUserByCampaignId(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) (*fs.FindInactionTargetUserByCampaignIdResponse, error)
	ExecuteFilterCampaigns(ctx context.Context, request *fs.FilterCampaignRequest) (*fs.FilterCampaignResponse, error)
	ExecuteGetDynamicDataByKey(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, tx ...dialect.Tx) (*fs.GetDynamicDataByKeyResponse, error)
	ExecuteAddDynamicDataBulk(ctx context.Context, bulkrequest *fs.BulkAddDynamicDataRequest, tx ...dialect.Tx) (*fs.BulkAddDynamicDataResponse, error)
	ExecuteAddDynamicData(ctx context.Context, request *fs.AddDynamicDataRequest, tx ...dialect.Tx) (*fs.AddDynamicDataResponse, error)
	ExecuteFindQueryCampaign(ctx context.Context, request *fs.FindQueryCampaignRequest) (*fs.FindQueryCampaignResponse, error)
	ExecuteAddQueryCampaignBulk(ctx context.Context, bulkrequest *fs.BulkAddQueryCampaignRequest) (*fs.BulkAddQueryCampaignResponse, error)
	ExecuteAddQueryCampaign(ctx context.Context, request *fs.AddQueryCampaignRequest) (*fs.AddQueryCampaignResponse, error)
	ExecuteFindControlGroupByCampaignId(ctx context.Context, request *fs.FindControlGroupByCampaignIdRequest) (*fs.FindControlGroupByCampaignIdResponse, error)
}

type Transaction 

type Transaction func(ctx context.Context, txName string, tx dialect.Tx) (res TransactionResult, err error)

type TransactionResult 

type TransactionResult interface{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.