Documentation ¶
Index ¶
- Constants
- Variables
- func AddEdgeArgs(model *AddEdgeVO) []interface{}
- func AddEngagementVertexArgs(model *AddEngagementVertexVO) []interface{}
- func AddUserJourneyTargetUsersArgs(model *AddUserJourneyTargetUsersVO) []interface{}
- func AddUserJourneyVertexArgs(model *AddUserJourneyVertexVO) []interface{}
- func BloomFilter(controlGroupIds []int64) *bloom.BloomFilter
- func DeleteEdgesVOArgs(model *DeleteEdgesVO) []interface{}
- func DeleteEngagementVerticesArgs(model *DeleteEngagementVerticesVO) []interface{}
- func DeleteUserJourneyVerticesArgs(model *DeleteUserJourneyVerticesVO) []interface{}
- func FindEngagementStartVertexByIdArgs(campaignId int64) []interface{}
- func FindEngagementVertexByIdArgs(engagementVertexId int64) []interface{}
- func FindNextEngagementVerticesArgs(campaignId int64, engagementVertexId int64) []interface{}
- func FindPreviousEngagementVertexArgs(campaignId int64, engagementVertexId int64) []interface{}
- func FindUserJourneyCampaignByIdArgs(request *fs.FindUserJourneyCampaignByIdRequest) []interface{}
- func FindUserJourneyCampaignEdgesByIdArgs(request *fs.FindUserJourneyCampaignByIdRequest, vertexType string) []interface{}
- func GenerateRandomUserIds(userIds []int64, controlGroupPercentage int32) []int64
- func GetActorTypeUsingNamespace(namespace common.NameSpace) int32
- func GetCampaignQueryType(ctx context.Context, campaignId int64) (common.CampaignQueryType, error)
- func GetImageMetaData(languageCode common.LanguageCode, imageMap map[common.LanguageCode]string) string
- func GetInQueryWithValues(arr []int64, query string) string
- func GetIndexInRow(row []string, fieldName string) int
- func GetIndexOfId(rowData []string) int
- func GetInt64Value(index int, arr []string) int64
- func GetPlaceholderData(val []string, indexFieldMap map[int64]string) []*ce.Placeholder
- func GetPlaceholderIndexFieldMap(val []string) map[int64]string
- func GetStartEngagementVertex(ctx context.Context, campaignId int64) (int64, error)
- func GetStringValue(index int, arr []string) string
- func GetUserFilterQueries(namespace string, response *fs.FindCampaignByIdResponse) []string
- func GetUserJourneyTargetUsersArgs(campaignId int64, engagementsVertexId int64, referenceId string) []interface{}
- func GetUserJourneyWorkflowId(campaignId int64, engagementVertexId int64) string
- func GetUserJourneyWorkflowParentReferenceId(campaignId int64, engagementVertexId int64) string
- func GetWaitDuration(ctx context.Context, waitDuration int64, waitTime time.Time, waitType string) time.Duration
- func GetWorkflowId(campaignId int64) string
- func IsPresent(bloomFilter *bloom.BloomFilter, userId int64) bool
- func MakeFindUserJourneyCampaignVO(models []*FindUserJourneyCampaigVO) []*fs.FilterUserJourneyCampaignResponseRecord
- func MakeUserJourneyCampaignQuery(namespace string, namespaceValue int32, ...) ([]string, error)
- func OutputLog(log string, logLevel string, error error, request *fs.AddNewCampaignRequest)
- func OutputQueryLog(log string, logLevel string, error error, query string)
- func PostStartUpHook()
- func PreStartUpHook()
- func SendMessage(ctx context.Context, events *CommunicationEngine.BulkCommunicationEvent) error
- func UpdateCampaignArgs(model *UpdateCampaignVO) []interface{}
- type AddCampaignBulkInterface
- type AddCampaignController
- func (rc *AddCampaignController) OnError(ctx context.Context, request *fs.AddCampaignRequest, ...) *fs.AddCampaignResponse
- func (rc *AddCampaignController) OnRequest(ctx context.Context, request *fs.AddCampaignRequest) *fs.AddCampaignResponse
- func (rc *AddCampaignController) OnResponse(ctx context.Context, request *fs.AddCampaignRequest, ...) *fs.AddCampaignResponse
- type AddCampaignInterface
- type AddCampaignTemplateBulkInterface
- type AddCampaignTemplateController
- func (rc *AddCampaignTemplateController) OnError(ctx context.Context, request *fs.AddCampaignTemplateRequest, ...) *fs.AddCampaignTemplateResponse
- func (rc *AddCampaignTemplateController) OnRequest(ctx context.Context, request *fs.AddCampaignTemplateRequest) *fs.AddCampaignTemplateResponse
- func (rc *AddCampaignTemplateController) OnResponse(ctx context.Context, request *fs.AddCampaignTemplateRequest, ...) *fs.AddCampaignTemplateResponse
- type AddCampaignTemplateInterface
- type AddDynamicDataBulkInterface
- type AddDynamicDataController
- func (rc *AddDynamicDataController) OnError(ctx context.Context, request *fs.AddDynamicDataRequest, ...) *fs.AddDynamicDataResponse
- func (rc *AddDynamicDataController) OnRequest(ctx context.Context, request *fs.AddDynamicDataRequest) *fs.AddDynamicDataResponse
- func (rc *AddDynamicDataController) OnResponse(ctx context.Context, request *fs.AddDynamicDataRequest, ...) *fs.AddDynamicDataResponse
- type AddDynamicDataInterface
- type AddEdgeVO
- type AddEngagementVertexVO
- type AddInactionTargetUserBulkInterface
- type AddInactionTargetUserController
- func (rc *AddInactionTargetUserController) OnError(ctx context.Context, request *fs.AddInactionTargetUserRequest, ...) *fs.AddInactionTargetUserResponse
- func (rc *AddInactionTargetUserController) OnRequest(ctx context.Context, request *fs.AddInactionTargetUserRequest) *fs.AddInactionTargetUserResponse
- func (rc *AddInactionTargetUserController) OnResponse(ctx context.Context, request *fs.AddInactionTargetUserRequest, ...) *fs.AddInactionTargetUserResponse
- type AddInactionTargetUserInterface
- type AddNewCampaignBulkInterface
- type AddNewCampaignController
- func (rc *AddNewCampaignController) OnError(ctx context.Context, request *fs.AddNewCampaignRequest, ...) *fs.AddNewCampaignResponse
- func (rc *AddNewCampaignController) OnRequest(ctx context.Context, request *fs.AddNewCampaignRequest) *fs.AddNewCampaignResponse
- func (rc *AddNewCampaignController) OnResponse(ctx context.Context, request *fs.AddNewCampaignRequest, ...) *fs.AddNewCampaignResponse
- type AddNewCampaignInterface
- type AddQueryCampaignBulkInterface
- type AddQueryCampaignController
- func (rc *AddQueryCampaignController) OnError(ctx context.Context, request *fs.AddQueryCampaignRequest, ...) *fs.AddQueryCampaignResponse
- func (rc *AddQueryCampaignController) OnRequest(ctx context.Context, request *fs.AddQueryCampaignRequest) *fs.AddQueryCampaignResponse
- func (rc *AddQueryCampaignController) OnResponse(ctx context.Context, request *fs.AddQueryCampaignRequest, ...) *fs.AddQueryCampaignResponse
- type AddQueryCampaignInterface
- type AddTargetUserBulkInterface
- type AddTargetUserController
- func (rc *AddTargetUserController) OnError(ctx context.Context, request *fs.AddTargetUserRequest, ...) *fs.AddTargetUserResponse
- func (rc *AddTargetUserController) OnRequest(ctx context.Context, request *fs.AddTargetUserRequest) *fs.AddTargetUserResponse
- func (rc *AddTargetUserController) OnResponse(ctx context.Context, request *fs.AddTargetUserRequest, ...) *fs.AddTargetUserResponse
- type AddTargetUserInterface
- type AddUserJourneyPrefixVO
- type AddUserJourneyTargetUsersVO
- type AddUserJourneyVertexVO
- type AthenaQueryController
- func (rc *AthenaQueryController) OnError(ctx context.Context, request *fs.AthenaQueryRequest, ...) *fs.AthenaQueryResponse
- func (rc *AthenaQueryController) OnRequest(ctx context.Context, request *fs.AthenaQueryRequest) *fs.AthenaQueryResponse
- func (rc *AthenaQueryController) OnResponse(ctx context.Context, request *fs.AthenaQueryRequest, ...) *fs.AthenaQueryResponse
- type AthenaQueryInterface
- type Attributes
- type BaseVO
- type BulkAddCampaignController
- func (rc *BulkAddCampaignController) OnError(ctx context.Context, request *fs.BulkAddCampaignRequest, ...) *fs.BulkAddCampaignResponse
- func (rc *BulkAddCampaignController) OnRequest(ctx context.Context, request *fs.BulkAddCampaignRequest) *fs.BulkAddCampaignResponse
- func (rc *BulkAddCampaignController) OnResponse(ctx context.Context, request *fs.BulkAddCampaignRequest, ...) *fs.BulkAddCampaignResponse
- type BulkAddCampaignTemplateController
- func (rc *BulkAddCampaignTemplateController) OnError(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, ...) *fs.BulkAddCampaignTemplateResponse
- func (rc *BulkAddCampaignTemplateController) OnRequest(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest) *fs.BulkAddCampaignTemplateResponse
- func (rc *BulkAddCampaignTemplateController) OnResponse(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, ...) *fs.BulkAddCampaignTemplateResponse
- type BulkAddDynamicDataController
- func (rc *BulkAddDynamicDataController) OnError(ctx context.Context, request *fs.BulkAddDynamicDataRequest, ...) *fs.BulkAddDynamicDataResponse
- func (rc *BulkAddDynamicDataController) OnRequest(ctx context.Context, request *fs.BulkAddDynamicDataRequest) *fs.BulkAddDynamicDataResponse
- func (rc *BulkAddDynamicDataController) OnResponse(ctx context.Context, request *fs.BulkAddDynamicDataRequest, ...) *fs.BulkAddDynamicDataResponse
- type BulkAddInactionTargetUserController
- func (rc *BulkAddInactionTargetUserController) OnError(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, ...) *fs.BulkAddInactionTargetUserResponse
- func (rc *BulkAddInactionTargetUserController) OnRequest(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest) *fs.BulkAddInactionTargetUserResponse
- func (rc *BulkAddInactionTargetUserController) OnResponse(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, ...) *fs.BulkAddInactionTargetUserResponse
- type BulkAddNewCampaignController
- func (rc *BulkAddNewCampaignController) OnError(ctx context.Context, request *fs.BulkAddNewCampaignRequest, ...) *fs.BulkAddNewCampaignResponse
- func (rc *BulkAddNewCampaignController) OnRequest(ctx context.Context, request *fs.BulkAddNewCampaignRequest) *fs.BulkAddNewCampaignResponse
- func (rc *BulkAddNewCampaignController) OnResponse(ctx context.Context, request *fs.BulkAddNewCampaignRequest, ...) *fs.BulkAddNewCampaignResponse
- type BulkAddQueryCampaignController
- func (rc *BulkAddQueryCampaignController) OnError(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, ...) *fs.BulkAddQueryCampaignResponse
- func (rc *BulkAddQueryCampaignController) OnRequest(ctx context.Context, request *fs.BulkAddQueryCampaignRequest) *fs.BulkAddQueryCampaignResponse
- func (rc *BulkAddQueryCampaignController) OnResponse(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, ...) *fs.BulkAddQueryCampaignResponse
- type BulkAddTargetUserController
- func (rc *BulkAddTargetUserController) OnError(ctx context.Context, request *fs.BulkAddTargetUserRequest, ...) *fs.BulkAddTargetUserResponse
- func (rc *BulkAddTargetUserController) OnRequest(ctx context.Context, request *fs.BulkAddTargetUserRequest) *fs.BulkAddTargetUserResponse
- func (rc *BulkAddTargetUserController) OnResponse(ctx context.Context, request *fs.BulkAddTargetUserRequest, ...) *fs.BulkAddTargetUserResponse
- type BulkUpdateCampaignController
- func (rc *BulkUpdateCampaignController) OnError(ctx context.Context, request *fs.BulkUpdateCampaignRequest, ...) *fs.BulkUpdateCampaignResponse
- func (rc *BulkUpdateCampaignController) OnRequest(ctx context.Context, request *fs.BulkUpdateCampaignRequest) *fs.BulkUpdateCampaignResponse
- func (rc *BulkUpdateCampaignController) OnResponse(ctx context.Context, request *fs.BulkUpdateCampaignRequest, ...) *fs.BulkUpdateCampaignResponse
- type CampaignController
- func (rc *CampaignController) OnData(ctx context.Context, request *fs.CampaignRequest, ...) *fs.CampaignResponse
- func (rc *CampaignController) OnError(ctx context.Context, request *fs.CampaignRequest, ...) *fs.CampaignResponse
- func (rc *CampaignController) OnRequest(ctx context.Context, request *fs.CampaignRequest) *fs.CampaignResponse
- func (rc *CampaignController) OnResponse(ctx context.Context, request *fs.CampaignRequest, ...) *fs.CampaignResponse
- type CampaignInterface
- type DeleteEdgesVO
- type DeleteEngagementVerticesVO
- type DeleteUserJourneyVerticesVO
- type ExecuteRequestController
- func (rc *ExecuteRequestController) OnError(ctx context.Context, request interface{}, response interface{}, err error) interface{}
- func (rc *ExecuteRequestController) OnRequest(ctx context.Context, request interface{}) interface{}
- func (rc *ExecuteRequestController) OnResponse(ctx context.Context, request interface{}, response interface{}) interface{}
- type FilterCampaignController
- func (rc *FilterCampaignController) OnError(ctx context.Context, request *fs.FilterCampaignRequest, ...) *fs.FilterCampaignResponse
- func (rc *FilterCampaignController) OnRequest(ctx context.Context, request *fs.FilterCampaignRequest) *fs.FilterCampaignResponse
- func (rc *FilterCampaignController) OnResponse(ctx context.Context, request *fs.FilterCampaignRequest, ...) *fs.FilterCampaignResponse
- type FilterCampaignInterface
- type FilterUserJourneyCampaignController
- func (rc *FilterUserJourneyCampaignController) OnData(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, ...) *fs.FilterUserJourneyCampaignResponse
- func (rc *FilterUserJourneyCampaignController) OnError(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, ...) *fs.FilterUserJourneyCampaignResponse
- func (rc *FilterUserJourneyCampaignController) OnRequest(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest) *fs.FilterUserJourneyCampaignResponse
- func (rc *FilterUserJourneyCampaignController) OnResponse(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, ...) *fs.FilterUserJourneyCampaignResponse
- type FilterUserJourneyCampaignInterface
- type FindCampaignByIdController
- func (rc *FindCampaignByIdController) OnData(ctx context.Context, request *fs.FindCampaignByIdRequest, ...) *fs.FindCampaignByIdResponse
- func (rc *FindCampaignByIdController) OnError(ctx context.Context, request *fs.FindCampaignByIdRequest, ...) *fs.FindCampaignByIdResponse
- func (rc *FindCampaignByIdController) OnRequest(ctx context.Context, request *fs.FindCampaignByIdRequest) *fs.FindCampaignByIdResponse
- func (rc *FindCampaignByIdController) OnResponse(ctx context.Context, request *fs.FindCampaignByIdRequest, ...) *fs.FindCampaignByIdResponse
- type FindCampaignByIdInterface
- type FindCampaignTemplateByIdController
- func (rc *FindCampaignTemplateByIdController) OnData(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, ...) *fs.FindCampaignTemplateByIdResponse
- func (rc *FindCampaignTemplateByIdController) OnError(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, ...) *fs.FindCampaignTemplateByIdResponse
- func (rc *FindCampaignTemplateByIdController) OnRequest(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) *fs.FindCampaignTemplateByIdResponse
- func (rc *FindCampaignTemplateByIdController) OnResponse(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, ...) *fs.FindCampaignTemplateByIdResponse
- type FindCampaignTemplateByIdInterface
- type FindEdgesVO
- type FindEngagementStartVertexVO
- type FindEngagementVertexVO
- type FindInactionTargetUserByCampaignIdController
- func (rc *FindInactionTargetUserByCampaignIdController) OnData(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, ...) *fs.FindInactionTargetUserByCampaignIdResponse
- func (rc *FindInactionTargetUserByCampaignIdController) OnError(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, ...) *fs.FindInactionTargetUserByCampaignIdResponse
- func (rc *FindInactionTargetUserByCampaignIdController) OnRequest(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) *fs.FindInactionTargetUserByCampaignIdResponse
- func (rc *FindInactionTargetUserByCampaignIdController) OnResponse(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, ...) *fs.FindInactionTargetUserByCampaignIdResponse
- type FindInactionTargetUserByCampaignIdInterface
- type FindNextEngagementVertexVO
- type FindPreviousEngagementVertexVO
- type FindQueryCampaignController
- func (rc *FindQueryCampaignController) OnData(ctx context.Context, request *fs.FindQueryCampaignRequest, ...) *fs.FindQueryCampaignResponse
- func (rc *FindQueryCampaignController) OnError(ctx context.Context, request *fs.FindQueryCampaignRequest, ...) *fs.FindQueryCampaignResponse
- func (rc *FindQueryCampaignController) OnRequest(ctx context.Context, request *fs.FindQueryCampaignRequest) *fs.FindQueryCampaignResponse
- func (rc *FindQueryCampaignController) OnResponse(ctx context.Context, request *fs.FindQueryCampaignRequest, ...) *fs.FindQueryCampaignResponse
- type FindQueryCampaignInterface
- type FindTargetUserByIdController
- func (rc *FindTargetUserByIdController) OnData(ctx context.Context, request *fs.FindTargetUserByIdRequest, ...) *fs.FindTargetUserByIdResponse
- func (rc *FindTargetUserByIdController) OnError(ctx context.Context, request *fs.FindTargetUserByIdRequest, ...) *fs.FindTargetUserByIdResponse
- func (rc *FindTargetUserByIdController) OnRequest(ctx context.Context, request *fs.FindTargetUserByIdRequest) *fs.FindTargetUserByIdResponse
- func (rc *FindTargetUserByIdController) OnResponse(ctx context.Context, request *fs.FindTargetUserByIdRequest, ...) *fs.FindTargetUserByIdResponse
- type FindTargetUserByIdInterface
- type FindUserJourneyCampaigVO
- type FindUserJourneyCampaignByIdController
- func (rc *FindUserJourneyCampaignByIdController) OnData(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, ...) *fs.FindUserJourneyCampaignByIdResponse
- func (rc *FindUserJourneyCampaignByIdController) OnError(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, ...) *fs.FindUserJourneyCampaignByIdResponse
- func (rc *FindUserJourneyCampaignByIdController) OnRequest(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest) *fs.FindUserJourneyCampaignByIdResponse
- func (rc *FindUserJourneyCampaignByIdController) OnResponse(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, ...) *fs.FindUserJourneyCampaignByIdResponse
- type FindUserJourneyCampaignByIdInterface
- type FindUserJourneyTargetUsersVO
- type FindUserJourneyVertexVO
- type GenericAddCampaignExecutor
- func (ge *GenericAddCampaignExecutor) OnError(ctx context.Context, request *fs.AddCampaignRequest, ...) *fs.AddCampaignResponse
- func (ge *GenericAddCampaignExecutor) OnRequest(ctx context.Context, request *fs.AddCampaignRequest) *fs.AddCampaignResponse
- func (ge *GenericAddCampaignExecutor) OnResponse(ctx context.Context, request *fs.AddCampaignRequest, ...) *fs.AddCampaignResponse
- type GenericAddCampaignExecutorBulk
- func (ge *GenericAddCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddCampaignRequest, ...) *fs.BulkAddCampaignResponse
- func (ge *GenericAddCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddCampaignRequest) *fs.BulkAddCampaignResponse
- func (ge *GenericAddCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddCampaignRequest, ...) *fs.BulkAddCampaignResponse
- type GenericAddCampaignTemplateExecutor
- func (ge *GenericAddCampaignTemplateExecutor) OnError(ctx context.Context, request *fs.AddCampaignTemplateRequest, ...) *fs.AddCampaignTemplateResponse
- func (ge *GenericAddCampaignTemplateExecutor) OnRequest(ctx context.Context, request *fs.AddCampaignTemplateRequest) *fs.AddCampaignTemplateResponse
- func (ge *GenericAddCampaignTemplateExecutor) OnResponse(ctx context.Context, request *fs.AddCampaignTemplateRequest, ...) *fs.AddCampaignTemplateResponse
- type GenericAddCampaignTemplateExecutorBulk
- func (ge *GenericAddCampaignTemplateExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, ...) *fs.BulkAddCampaignTemplateResponse
- func (ge *GenericAddCampaignTemplateExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest) *fs.BulkAddCampaignTemplateResponse
- func (ge *GenericAddCampaignTemplateExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, ...) *fs.BulkAddCampaignTemplateResponse
- type GenericAddDynamicDataExecutor
- func (ge *GenericAddDynamicDataExecutor) OnError(ctx context.Context, request *fs.AddDynamicDataRequest, ...) *fs.AddDynamicDataResponse
- func (ge *GenericAddDynamicDataExecutor) OnRequest(ctx context.Context, request *fs.AddDynamicDataRequest) *fs.AddDynamicDataResponse
- func (ge *GenericAddDynamicDataExecutor) OnResponse(ctx context.Context, request *fs.AddDynamicDataRequest, ...) *fs.AddDynamicDataResponse
- type GenericAddDynamicDataExecutorBulk
- func (ge *GenericAddDynamicDataExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddDynamicDataRequest, ...) *fs.BulkAddDynamicDataResponse
- func (ge *GenericAddDynamicDataExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddDynamicDataRequest) *fs.BulkAddDynamicDataResponse
- func (ge *GenericAddDynamicDataExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddDynamicDataRequest, ...) *fs.BulkAddDynamicDataResponse
- type GenericAddInactionTargetUserExecutor
- func (ge *GenericAddInactionTargetUserExecutor) OnError(ctx context.Context, request *fs.AddInactionTargetUserRequest, ...) *fs.AddInactionTargetUserResponse
- func (ge *GenericAddInactionTargetUserExecutor) OnRequest(ctx context.Context, request *fs.AddInactionTargetUserRequest) *fs.AddInactionTargetUserResponse
- func (ge *GenericAddInactionTargetUserExecutor) OnResponse(ctx context.Context, request *fs.AddInactionTargetUserRequest, ...) *fs.AddInactionTargetUserResponse
- type GenericAddInactionTargetUserExecutorBulk
- func (ge *GenericAddInactionTargetUserExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, ...) *fs.BulkAddInactionTargetUserResponse
- func (ge *GenericAddInactionTargetUserExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest) *fs.BulkAddInactionTargetUserResponse
- func (ge *GenericAddInactionTargetUserExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, ...) *fs.BulkAddInactionTargetUserResponse
- type GenericAddNewCampaignExecutor
- func (ge *GenericAddNewCampaignExecutor) OnError(ctx context.Context, request *fs.AddNewCampaignRequest, ...) *fs.AddNewCampaignResponse
- func (ge *GenericAddNewCampaignExecutor) OnRequest(ctx context.Context, request *fs.AddNewCampaignRequest) *fs.AddNewCampaignResponse
- func (ge *GenericAddNewCampaignExecutor) OnResponse(ctx context.Context, request *fs.AddNewCampaignRequest, ...) *fs.AddNewCampaignResponse
- type GenericAddNewCampaignExecutorBulk
- func (ge *GenericAddNewCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddNewCampaignRequest, ...) *fs.BulkAddNewCampaignResponse
- func (ge *GenericAddNewCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddNewCampaignRequest) *fs.BulkAddNewCampaignResponse
- func (ge *GenericAddNewCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddNewCampaignRequest, ...) *fs.BulkAddNewCampaignResponse
- type GenericAddQueryCampaignExecutor
- func (ge *GenericAddQueryCampaignExecutor) OnError(ctx context.Context, request *fs.AddQueryCampaignRequest, ...) *fs.AddQueryCampaignResponse
- func (ge *GenericAddQueryCampaignExecutor) OnRequest(ctx context.Context, request *fs.AddQueryCampaignRequest) *fs.AddQueryCampaignResponse
- func (ge *GenericAddQueryCampaignExecutor) OnResponse(ctx context.Context, request *fs.AddQueryCampaignRequest, ...) *fs.AddQueryCampaignResponse
- type GenericAddQueryCampaignExecutorBulk
- func (ge *GenericAddQueryCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, ...) *fs.BulkAddQueryCampaignResponse
- func (ge *GenericAddQueryCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddQueryCampaignRequest) *fs.BulkAddQueryCampaignResponse
- func (ge *GenericAddQueryCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, ...) *fs.BulkAddQueryCampaignResponse
- type GenericAddTargetUserExecutor
- func (ge *GenericAddTargetUserExecutor) OnError(ctx context.Context, request *fs.AddTargetUserRequest, ...) *fs.AddTargetUserResponse
- func (ge *GenericAddTargetUserExecutor) OnRequest(ctx context.Context, request *fs.AddTargetUserRequest) *fs.AddTargetUserResponse
- func (ge *GenericAddTargetUserExecutor) OnResponse(ctx context.Context, request *fs.AddTargetUserRequest, ...) *fs.AddTargetUserResponse
- type GenericAddTargetUserExecutorBulk
- func (ge *GenericAddTargetUserExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddTargetUserRequest, ...) *fs.BulkAddTargetUserResponse
- func (ge *GenericAddTargetUserExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddTargetUserRequest) *fs.BulkAddTargetUserResponse
- func (ge *GenericAddTargetUserExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddTargetUserRequest, ...) *fs.BulkAddTargetUserResponse
- type GenericAthenaQueryExecutor
- func (ge *GenericAthenaQueryExecutor) OnError(ctx context.Context, request *fs.AthenaQueryRequest, ...) *fs.AthenaQueryResponse
- func (ge *GenericAthenaQueryExecutor) OnRequest(ctx context.Context, request *fs.AthenaQueryRequest) *fs.AthenaQueryResponse
- func (ge *GenericAthenaQueryExecutor) OnResponse(ctx context.Context, request *fs.AthenaQueryRequest, ...) *fs.AthenaQueryResponse
- type GenericCampaignExecutor
- func (ge *GenericCampaignExecutor) OnData(ctx context.Context, request *fs.CampaignRequest, ...) *fs.CampaignResponse
- func (ge *GenericCampaignExecutor) OnError(ctx context.Context, request *fs.CampaignRequest, ...) *fs.CampaignResponse
- func (ge *GenericCampaignExecutor) OnRequest(ctx context.Context, request *fs.CampaignRequest) *fs.CampaignResponse
- func (ge *GenericCampaignExecutor) OnResponse(ctx context.Context, request *fs.CampaignRequest, ...) *fs.CampaignResponse
- type GenericFilterCampaignExecutor
- func (ge *GenericFilterCampaignExecutor) OnError(ctx context.Context, request *fs.FilterCampaignRequest, ...) *fs.FilterCampaignResponse
- func (ge *GenericFilterCampaignExecutor) OnRequest(ctx context.Context, request *fs.FilterCampaignRequest) *fs.FilterCampaignResponse
- func (ge *GenericFilterCampaignExecutor) OnResponse(ctx context.Context, request *fs.FilterCampaignRequest, ...) *fs.FilterCampaignResponse
- type GenericFilterUserJourneyCampaignExecutor
- func (ge *GenericFilterUserJourneyCampaignExecutor) OnData(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, ...) *fs.FilterUserJourneyCampaignResponse
- func (ge *GenericFilterUserJourneyCampaignExecutor) OnError(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, ...) *fs.FilterUserJourneyCampaignResponse
- func (ge *GenericFilterUserJourneyCampaignExecutor) OnRequest(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest) *fs.FilterUserJourneyCampaignResponse
- func (ge *GenericFilterUserJourneyCampaignExecutor) OnResponse(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, ...) *fs.FilterUserJourneyCampaignResponse
- type GenericFindCampaignByIdExecutor
- func (ge *GenericFindCampaignByIdExecutor) OnData(ctx context.Context, request *fs.FindCampaignByIdRequest, ...) *fs.FindCampaignByIdResponse
- func (ge *GenericFindCampaignByIdExecutor) OnError(ctx context.Context, request *fs.FindCampaignByIdRequest, ...) *fs.FindCampaignByIdResponse
- func (ge *GenericFindCampaignByIdExecutor) OnRequest(ctx context.Context, request *fs.FindCampaignByIdRequest) *fs.FindCampaignByIdResponse
- func (ge *GenericFindCampaignByIdExecutor) OnResponse(ctx context.Context, request *fs.FindCampaignByIdRequest, ...) *fs.FindCampaignByIdResponse
- type GenericFindCampaignTemplateByIdExecutor
- func (ge *GenericFindCampaignTemplateByIdExecutor) OnData(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, ...) *fs.FindCampaignTemplateByIdResponse
- func (ge *GenericFindCampaignTemplateByIdExecutor) OnError(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, ...) *fs.FindCampaignTemplateByIdResponse
- func (ge *GenericFindCampaignTemplateByIdExecutor) OnRequest(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) *fs.FindCampaignTemplateByIdResponse
- func (ge *GenericFindCampaignTemplateByIdExecutor) OnResponse(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, ...) *fs.FindCampaignTemplateByIdResponse
- type GenericFindInactionTargetUserByCampaignIdExecutor
- func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnData(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, ...) *fs.FindInactionTargetUserByCampaignIdResponse
- func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnError(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, ...) *fs.FindInactionTargetUserByCampaignIdResponse
- func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnRequest(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) *fs.FindInactionTargetUserByCampaignIdResponse
- func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnResponse(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, ...) *fs.FindInactionTargetUserByCampaignIdResponse
- type GenericFindQueryCampaignExecutor
- func (ge *GenericFindQueryCampaignExecutor) OnData(ctx context.Context, request *fs.FindQueryCampaignRequest, ...) *fs.FindQueryCampaignResponse
- func (ge *GenericFindQueryCampaignExecutor) OnError(ctx context.Context, request *fs.FindQueryCampaignRequest, ...) *fs.FindQueryCampaignResponse
- func (ge *GenericFindQueryCampaignExecutor) OnRequest(ctx context.Context, request *fs.FindQueryCampaignRequest) *fs.FindQueryCampaignResponse
- func (ge *GenericFindQueryCampaignExecutor) OnResponse(ctx context.Context, request *fs.FindQueryCampaignRequest, ...) *fs.FindQueryCampaignResponse
- type GenericFindTargetUserByIdExecutor
- func (ge *GenericFindTargetUserByIdExecutor) OnData(ctx context.Context, request *fs.FindTargetUserByIdRequest, ...) *fs.FindTargetUserByIdResponse
- func (ge *GenericFindTargetUserByIdExecutor) OnError(ctx context.Context, request *fs.FindTargetUserByIdRequest, ...) *fs.FindTargetUserByIdResponse
- func (ge *GenericFindTargetUserByIdExecutor) OnRequest(ctx context.Context, request *fs.FindTargetUserByIdRequest) *fs.FindTargetUserByIdResponse
- func (ge *GenericFindTargetUserByIdExecutor) OnResponse(ctx context.Context, request *fs.FindTargetUserByIdRequest, ...) *fs.FindTargetUserByIdResponse
- type GenericFindUserJourneyCampaignByIdExecutor
- func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnData(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, ...) *fs.FindUserJourneyCampaignByIdResponse
- func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnError(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, ...) *fs.FindUserJourneyCampaignByIdResponse
- func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnRequest(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest) *fs.FindUserJourneyCampaignByIdResponse
- func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnResponse(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, ...) *fs.FindUserJourneyCampaignByIdResponse
- type GenericGetDynamicDataByKeyExecutor
- func (ge *GenericGetDynamicDataByKeyExecutor) OnData(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, ...) *fs.GetDynamicDataByKeyResponse
- func (ge *GenericGetDynamicDataByKeyExecutor) OnError(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, ...) *fs.GetDynamicDataByKeyResponse
- func (ge *GenericGetDynamicDataByKeyExecutor) OnRequest(ctx context.Context, request *fs.GetDynamicDataByKeyRequest) *fs.GetDynamicDataByKeyResponse
- func (ge *GenericGetDynamicDataByKeyExecutor) OnResponse(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, ...) *fs.GetDynamicDataByKeyResponse
- type GenericScheduleUserJourneyCampaignExecutor
- func (ge *GenericScheduleUserJourneyCampaignExecutor) OnData(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, ...) *fs.ScheduleUserJourneyCampaignResponse
- func (ge *GenericScheduleUserJourneyCampaignExecutor) OnError(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, ...) *fs.ScheduleUserJourneyCampaignResponse
- func (ge *GenericScheduleUserJourneyCampaignExecutor) OnRequest(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest) *fs.ScheduleUserJourneyCampaignResponse
- func (ge *GenericScheduleUserJourneyCampaignExecutor) OnResponse(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, ...) *fs.ScheduleUserJourneyCampaignResponse
- type GenericTestCampaignByIdExecutor
- func (ge *GenericTestCampaignByIdExecutor) OnError(ctx context.Context, request *fs.TestCampaignByIdRequest, ...) *fs.TestCampaignByIdResponse
- func (ge *GenericTestCampaignByIdExecutor) OnRequest(ctx context.Context, request *fs.TestCampaignByIdRequest) *fs.TestCampaignByIdResponse
- func (ge *GenericTestCampaignByIdExecutor) OnResponse(ctx context.Context, request *fs.TestCampaignByIdRequest, ...) *fs.TestCampaignByIdResponse
- type GenericTestNewCampaignExecutor
- func (ge *GenericTestNewCampaignExecutor) OnError(ctx context.Context, request *fs.TestNewCampaignRequest, ...) *fs.TestNewCampaignResponse
- func (ge *GenericTestNewCampaignExecutor) OnRequest(ctx context.Context, request *fs.TestNewCampaignRequest) *fs.TestNewCampaignResponse
- func (ge *GenericTestNewCampaignExecutor) OnResponse(ctx context.Context, request *fs.TestNewCampaignRequest, ...) *fs.TestNewCampaignResponse
- type GenericUpdateCampaignExecutor
- func (ge *GenericUpdateCampaignExecutor) OnError(ctx context.Context, request *fs.UpdateCampaignRequest, ...) *fs.UpdateCampaignResponse
- func (ge *GenericUpdateCampaignExecutor) OnRequest(ctx context.Context, request *fs.UpdateCampaignRequest) (*fs.UpdateCampaignResponse, *fs.AddNewCampaignRequest)
- func (ge *GenericUpdateCampaignExecutor) OnResponse(ctx context.Context, request *fs.UpdateCampaignRequest, ...) *fs.UpdateCampaignResponse
- type GenericUpdateCampaignExecutorBulk
- func (ge *GenericUpdateCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkUpdateCampaignRequest, ...) *fs.BulkUpdateCampaignResponse
- func (ge *GenericUpdateCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkUpdateCampaignRequest) *fs.BulkUpdateCampaignResponse
- func (ge *GenericUpdateCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkUpdateCampaignRequest, ...) *fs.BulkUpdateCampaignResponse
- type GenericUserJourneyCampaignExecutor
- func (ge *GenericUserJourneyCampaignExecutor) OnData(ctx context.Context, request *fs.UserJourneyCampaignRequest, ...) *fs.UserJourneyCampaignResponse
- func (ge *GenericUserJourneyCampaignExecutor) OnError(ctx context.Context, request *fs.UserJourneyCampaignRequest, ...) *fs.UserJourneyCampaignResponse
- func (ge *GenericUserJourneyCampaignExecutor) OnRequest(ctx context.Context, request *fs.UserJourneyCampaignRequest) *fs.UserJourneyCampaignResponse
- func (ge *GenericUserJourneyCampaignExecutor) OnResponse(ctx context.Context, request *fs.UserJourneyCampaignRequest, ...) *fs.UserJourneyCampaignResponse
- type GetDynamicDataByKeyController
- func (rc *GetDynamicDataByKeyController) OnData(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, ...) *fs.GetDynamicDataByKeyResponse
- func (rc *GetDynamicDataByKeyController) OnError(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, ...) *fs.GetDynamicDataByKeyResponse
- func (rc *GetDynamicDataByKeyController) OnRequest(ctx context.Context, request *fs.GetDynamicDataByKeyRequest) *fs.GetDynamicDataByKeyResponse
- func (rc *GetDynamicDataByKeyController) OnResponse(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, ...) *fs.GetDynamicDataByKeyResponse
- type GetDynamicDataByKeyInterface
- type KvPairs
- type ScheduleUserJourneyCampaignController
- func (rc *ScheduleUserJourneyCampaignController) OnData(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, ...) *fs.ScheduleUserJourneyCampaignResponse
- func (rc *ScheduleUserJourneyCampaignController) OnError(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, ...) *fs.ScheduleUserJourneyCampaignResponse
- func (rc *ScheduleUserJourneyCampaignController) OnRequest(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest) *fs.ScheduleUserJourneyCampaignResponse
- func (rc *ScheduleUserJourneyCampaignController) OnResponse(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, ...) *fs.ScheduleUserJourneyCampaignResponse
- type ScheduleUserJourneyCampaignInterface
- type TestCampaignByIdController
- func (rc *TestCampaignByIdController) OnError(ctx context.Context, request *fs.TestCampaignByIdRequest, ...) *fs.TestCampaignByIdResponse
- func (rc *TestCampaignByIdController) OnRequest(ctx context.Context, request *fs.TestCampaignByIdRequest) *fs.TestCampaignByIdResponse
- func (rc *TestCampaignByIdController) OnResponse(ctx context.Context, request *fs.TestCampaignByIdRequest, ...) *fs.TestCampaignByIdResponse
- type TestCampaignByIdInterface
- type TestNewCampaignController
- func (rc *TestNewCampaignController) OnError(ctx context.Context, request *fs.TestNewCampaignRequest, ...) *fs.TestNewCampaignResponse
- func (rc *TestNewCampaignController) OnRequest(ctx context.Context, request *fs.TestNewCampaignRequest) *fs.TestNewCampaignResponse
- func (rc *TestNewCampaignController) OnResponse(ctx context.Context, request *fs.TestNewCampaignRequest, ...) *fs.TestNewCampaignResponse
- type TestNewCampaignInterface
- type UpdateCampaignBulkInterface
- type UpdateCampaignController
- func (rc *UpdateCampaignController) OnError(ctx context.Context, request *fs.UpdateCampaignRequest, ...) *fs.UpdateCampaignResponse
- func (rc *UpdateCampaignController) OnRequest(ctx context.Context, request *fs.UpdateCampaignRequest) *fs.UpdateCampaignResponse
- func (rc *UpdateCampaignController) OnResponse(ctx context.Context, request *fs.UpdateCampaignRequest, ...) *fs.UpdateCampaignResponse
- type UpdateCampaignInterface
- type UpdateCampaignVO
- type UserDetail
- type UserJourneyCampaignController
- func (rc *UserJourneyCampaignController) OnData(ctx context.Context, request *fs.UserJourneyCampaignRequest, ...) *fs.UserJourneyCampaignResponse
- func (rc *UserJourneyCampaignController) OnError(ctx context.Context, request *fs.UserJourneyCampaignRequest, ...) *fs.UserJourneyCampaignResponse
- func (rc *UserJourneyCampaignController) OnRequest(ctx context.Context, request *fs.UserJourneyCampaignRequest) *fs.UserJourneyCampaignResponse
- func (rc *UserJourneyCampaignController) OnResponse(ctx context.Context, request *fs.UserJourneyCampaignRequest, ...) *fs.UserJourneyCampaignResponse
- type UserJourneyCampaignInterface
Constants ¶
View Source
const ( CONST_LOG_LEVEL_INFO = "INFO" CONST_LOG_LEVEL_ERRROR = "ERROR" )
View Source
const ( CONST_ID = "id" CONST_ATHENA_NIL = "NIL" CONST_EMAIL_ID = "email_id" CONST_MOBILE_NUMBER = "mobile_number" CONST_LANG_KEY = "lang_key" CONST_FCM_TOKEN = "push_token" CONST_MODIFIED_ON = "modified_on" CONST_APP_ID = "app_id" CONST_ACTOR_TYPE = "user_type" CONST_MESSAGE_EXPIRY_DURATION = time.Hour * 5 CONST_ACTOR_ID_SYSTEM = 1000 CONST_IMAGE = "image" CONST_UNDERSCORE = "_" CONST_FARMER_APP_ID = "NF_FARMER" CONST_RETAILER_APP_ID = "NF_RETAILER" CONST_PARTNER_APP_ID = "NF_PARTNER" CONST_DEFAULT_AP_ID = "" CONST_ZERO = 0 CONST_ERROR_CODE_NIL = -1 CONST_CTA = "cta" CONST_LOCATION = "location" CONST_CAPACITY = "capacity" CONST_K = "k" TEXT_EXTENSION = ".txt" )
View Source
const ( EMPTY = "" UNDERSCORE = "_" INVALID_REQUEST = "INVALID_REQUEST" EVENTS_DATABASE_NAME = "events_database_name" EVENTS_TABLE_NAME = "events_table_name" CONST_USER_JOURNEY_CAMPAIGN_BUFFER_TIME = 300000 CONST_TIMESTAMP_LAYOUT = "2006-01-02 15:04:05" CONST_DRAFTED = "DRAFTED" CONST_WINDOWING_TIME = 300000 )
View Source
const ( CONST_NO_CAMPAIGN_ID = 0 CONST_EMPTY_ATHENA_QUERY = "" )
View Source
const ( METRICS_NAME = "NF_CMPS_SEND_MESSAGE" HELP_MESSAGE = "Push to kafka metrics metrics" )
Variables ¶
View Source
var EVENT_DB_NAME string
View Source
var EVENT_TABLE_NAME string
Functions ¶
func AddEdgeArgs ¶
func AddEdgeArgs(model *AddEdgeVO) []interface{}
func AddEngagementVertexArgs ¶
func AddEngagementVertexArgs(model *AddEngagementVertexVO) []interface{}
func AddUserJourneyTargetUsersArgs ¶
func AddUserJourneyTargetUsersArgs(model *AddUserJourneyTargetUsersVO) []interface{}
func AddUserJourneyVertexArgs ¶
func AddUserJourneyVertexArgs(model *AddUserJourneyVertexVO) []interface{}
func BloomFilter ¶
func BloomFilter(controlGroupIds []int64) *bloom.BloomFilter
func DeleteEdgesVOArgs ¶
func DeleteEdgesVOArgs(model *DeleteEdgesVO) []interface{}
func DeleteEngagementVerticesArgs ¶
func DeleteEngagementVerticesArgs(model *DeleteEngagementVerticesVO) []interface{}
func DeleteUserJourneyVerticesArgs ¶
func DeleteUserJourneyVerticesArgs(model *DeleteUserJourneyVerticesVO) []interface{}
func FindEngagementStartVertexByIdArgs ¶
func FindEngagementStartVertexByIdArgs(campaignId int64) []interface{}
func FindEngagementVertexByIdArgs ¶
func FindEngagementVertexByIdArgs(engagementVertexId int64) []interface{}
func FindUserJourneyCampaignByIdArgs ¶
func FindUserJourneyCampaignByIdArgs(request *fs.FindUserJourneyCampaignByIdRequest) []interface{}
func FindUserJourneyCampaignEdgesByIdArgs ¶
func FindUserJourneyCampaignEdgesByIdArgs(request *fs.FindUserJourneyCampaignByIdRequest, vertexType string) []interface{}
func GenerateRandomUserIds ¶
func GetCampaignQueryType ¶
func GetImageMetaData ¶
func GetImageMetaData(languageCode common.LanguageCode, imageMap map[common.LanguageCode]string) string
func GetInQueryWithValues ¶
func GetIndexInRow ¶
func GetIndexOfId ¶
func GetInt64Value ¶
func GetPlaceholderData ¶
func GetPlaceholderData(val []string, indexFieldMap map[int64]string) []*ce.Placeholder
func GetStringValue ¶
func GetUserFilterQueries ¶
func GetUserFilterQueries(namespace string, response *fs.FindCampaignByIdResponse) []string
func GetWaitDuration ¶
func GetWorkflowId ¶
func MakeFindUserJourneyCampaignVO ¶
func MakeFindUserJourneyCampaignVO(models []*FindUserJourneyCampaigVO) []*fs.FilterUserJourneyCampaignResponseRecord
func MakeUserJourneyCampaignQuery ¶
func MakeUserJourneyCampaignQuery(namespace string, namespaceValue int32, userJourneyCampaign *fs.UserJourneyCampaign, response *fs.FindCampaignByIdResponse) ([]string, error)
func OutputLog ¶
func OutputLog(log string, logLevel string, error error, request *fs.AddNewCampaignRequest)
func PostStartUpHook ¶
func PostStartUpHook()
func PreStartUpHook ¶
func PreStartUpHook()
func SendMessage ¶
func SendMessage(ctx context.Context, events *CommunicationEngine.BulkCommunicationEvent) error
func UpdateCampaignArgs ¶
func UpdateCampaignArgs(model *UpdateCampaignVO) []interface{}
Types ¶
type AddCampaignBulkInterface ¶
type AddCampaignBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddCampaignRequest) *fs.BulkAddCampaignResponse OnError(ctx context.Context, request *fs.BulkAddCampaignRequest, response *fs.BulkAddCampaignResponse, err error) *fs.BulkAddCampaignResponse OnResponse(ctx context.Context, request *fs.BulkAddCampaignRequest, response *fs.BulkAddCampaignResponse) *fs.BulkAddCampaignResponse }
type AddCampaignController ¶
type AddCampaignController struct { }
func (*AddCampaignController) OnError ¶
func (rc *AddCampaignController) OnError(ctx context.Context, request *fs.AddCampaignRequest, response *fs.AddCampaignResponse, err error) *fs.AddCampaignResponse
func (*AddCampaignController) OnRequest ¶
func (rc *AddCampaignController) OnRequest(ctx context.Context, request *fs.AddCampaignRequest) *fs.AddCampaignResponse
func (*AddCampaignController) OnResponse ¶
func (rc *AddCampaignController) OnResponse(ctx context.Context, request *fs.AddCampaignRequest, response *fs.AddCampaignResponse) *fs.AddCampaignResponse
type AddCampaignInterface ¶
type AddCampaignInterface interface { OnRequest(ctx context.Context, request *fs.AddCampaignRequest) *fs.AddCampaignResponse OnError(ctx context.Context, request *fs.AddCampaignRequest, response *fs.AddCampaignResponse, err error) *fs.AddCampaignResponse OnResponse(ctx context.Context, request *fs.AddCampaignRequest, response *fs.AddCampaignResponse) *fs.AddCampaignResponse }
type AddCampaignTemplateBulkInterface ¶
type AddCampaignTemplateBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest) *fs.BulkAddCampaignTemplateResponse OnError(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, response *fs.BulkAddCampaignTemplateResponse, err error) *fs.BulkAddCampaignTemplateResponse OnResponse(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, response *fs.BulkAddCampaignTemplateResponse) *fs.BulkAddCampaignTemplateResponse }
type AddCampaignTemplateController ¶
type AddCampaignTemplateController struct { }
func (*AddCampaignTemplateController) OnError ¶
func (rc *AddCampaignTemplateController) OnError(ctx context.Context, request *fs.AddCampaignTemplateRequest, response *fs.AddCampaignTemplateResponse, err error) *fs.AddCampaignTemplateResponse
func (*AddCampaignTemplateController) OnRequest ¶
func (rc *AddCampaignTemplateController) OnRequest(ctx context.Context, request *fs.AddCampaignTemplateRequest) *fs.AddCampaignTemplateResponse
func (*AddCampaignTemplateController) OnResponse ¶
func (rc *AddCampaignTemplateController) OnResponse(ctx context.Context, request *fs.AddCampaignTemplateRequest, response *fs.AddCampaignTemplateResponse) *fs.AddCampaignTemplateResponse
type AddCampaignTemplateInterface ¶
type AddCampaignTemplateInterface interface { OnRequest(ctx context.Context, request *fs.AddCampaignTemplateRequest) *fs.AddCampaignTemplateResponse OnError(ctx context.Context, request *fs.AddCampaignTemplateRequest, response *fs.AddCampaignTemplateResponse, err error) *fs.AddCampaignTemplateResponse OnResponse(ctx context.Context, request *fs.AddCampaignTemplateRequest, response *fs.AddCampaignTemplateResponse) *fs.AddCampaignTemplateResponse }
type AddDynamicDataBulkInterface ¶
type AddDynamicDataBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddDynamicDataRequest) *fs.BulkAddDynamicDataResponse OnError(ctx context.Context, request *fs.BulkAddDynamicDataRequest, response *fs.BulkAddDynamicDataResponse, err error) *fs.BulkAddDynamicDataResponse OnResponse(ctx context.Context, request *fs.BulkAddDynamicDataRequest, response *fs.BulkAddDynamicDataResponse) *fs.BulkAddDynamicDataResponse }
type AddDynamicDataController ¶
type AddDynamicDataController struct { }
func (*AddDynamicDataController) OnError ¶
func (rc *AddDynamicDataController) OnError(ctx context.Context, request *fs.AddDynamicDataRequest, response *fs.AddDynamicDataResponse, err error) *fs.AddDynamicDataResponse
func (*AddDynamicDataController) OnRequest ¶
func (rc *AddDynamicDataController) OnRequest(ctx context.Context, request *fs.AddDynamicDataRequest) *fs.AddDynamicDataResponse
func (*AddDynamicDataController) OnResponse ¶
func (rc *AddDynamicDataController) OnResponse(ctx context.Context, request *fs.AddDynamicDataRequest, response *fs.AddDynamicDataResponse) *fs.AddDynamicDataResponse
type AddDynamicDataInterface ¶
type AddDynamicDataInterface interface { OnRequest(ctx context.Context, request *fs.AddDynamicDataRequest) *fs.AddDynamicDataResponse OnError(ctx context.Context, request *fs.AddDynamicDataRequest, response *fs.AddDynamicDataResponse, err error) *fs.AddDynamicDataResponse OnResponse(ctx context.Context, request *fs.AddDynamicDataRequest, response *fs.AddDynamicDataResponse) *fs.AddDynamicDataResponse }
type AddEngagementVertexVO ¶
type AddEngagementVertexVO struct { CampaignId sql.NullInt64 TemplateName sql.NullString Attributes sql.NullString AthenaQuery sql.NullString Channel sql.NullString }
type AddInactionTargetUserBulkInterface ¶
type AddInactionTargetUserBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest) *fs.BulkAddInactionTargetUserResponse OnError(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, response *fs.BulkAddInactionTargetUserResponse, err error) *fs.BulkAddInactionTargetUserResponse OnResponse(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, response *fs.BulkAddInactionTargetUserResponse) *fs.BulkAddInactionTargetUserResponse }
type AddInactionTargetUserController ¶
type AddInactionTargetUserController struct { }
func (*AddInactionTargetUserController) OnError ¶
func (rc *AddInactionTargetUserController) OnError(ctx context.Context, request *fs.AddInactionTargetUserRequest, response *fs.AddInactionTargetUserResponse, err error) *fs.AddInactionTargetUserResponse
func (*AddInactionTargetUserController) OnRequest ¶
func (rc *AddInactionTargetUserController) OnRequest(ctx context.Context, request *fs.AddInactionTargetUserRequest) *fs.AddInactionTargetUserResponse
func (*AddInactionTargetUserController) OnResponse ¶
func (rc *AddInactionTargetUserController) OnResponse(ctx context.Context, request *fs.AddInactionTargetUserRequest, response *fs.AddInactionTargetUserResponse) *fs.AddInactionTargetUserResponse
type AddInactionTargetUserInterface ¶
type AddInactionTargetUserInterface interface { OnRequest(ctx context.Context, request *fs.AddInactionTargetUserRequest) *fs.AddInactionTargetUserResponse OnError(ctx context.Context, request *fs.AddInactionTargetUserRequest, response *fs.AddInactionTargetUserResponse, err error) *fs.AddInactionTargetUserResponse OnResponse(ctx context.Context, request *fs.AddInactionTargetUserRequest, response *fs.AddInactionTargetUserResponse) *fs.AddInactionTargetUserResponse }
type AddNewCampaignBulkInterface ¶
type AddNewCampaignBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddNewCampaignRequest) *fs.BulkAddNewCampaignResponse OnError(ctx context.Context, request *fs.BulkAddNewCampaignRequest, response *fs.BulkAddNewCampaignResponse, err error) *fs.BulkAddNewCampaignResponse OnResponse(ctx context.Context, request *fs.BulkAddNewCampaignRequest, response *fs.BulkAddNewCampaignResponse) *fs.BulkAddNewCampaignResponse }
type AddNewCampaignController ¶
type AddNewCampaignController struct { }
func (*AddNewCampaignController) OnError ¶
func (rc *AddNewCampaignController) OnError(ctx context.Context, request *fs.AddNewCampaignRequest, response *fs.AddNewCampaignResponse, err error) *fs.AddNewCampaignResponse
func (*AddNewCampaignController) OnRequest ¶
func (rc *AddNewCampaignController) OnRequest(ctx context.Context, request *fs.AddNewCampaignRequest) *fs.AddNewCampaignResponse
func (*AddNewCampaignController) OnResponse ¶
func (rc *AddNewCampaignController) OnResponse(ctx context.Context, request *fs.AddNewCampaignRequest, response *fs.AddNewCampaignResponse) *fs.AddNewCampaignResponse
type AddNewCampaignInterface ¶
type AddNewCampaignInterface interface { OnRequest(ctx context.Context, request *fs.AddNewCampaignRequest) *fs.AddNewCampaignResponse OnError(ctx context.Context, request *fs.AddNewCampaignRequest, response *fs.AddNewCampaignResponse, err error) *fs.AddNewCampaignResponse OnResponse(ctx context.Context, request *fs.AddNewCampaignRequest, response *fs.AddNewCampaignResponse) *fs.AddNewCampaignResponse }
type AddQueryCampaignBulkInterface ¶
type AddQueryCampaignBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddQueryCampaignRequest) *fs.BulkAddQueryCampaignResponse OnError(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, response *fs.BulkAddQueryCampaignResponse, err error) *fs.BulkAddQueryCampaignResponse OnResponse(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, response *fs.BulkAddQueryCampaignResponse) *fs.BulkAddQueryCampaignResponse }
type AddQueryCampaignController ¶
type AddQueryCampaignController struct { }
func (*AddQueryCampaignController) OnError ¶
func (rc *AddQueryCampaignController) OnError(ctx context.Context, request *fs.AddQueryCampaignRequest, response *fs.AddQueryCampaignResponse, err error) *fs.AddQueryCampaignResponse
func (*AddQueryCampaignController) OnRequest ¶
func (rc *AddQueryCampaignController) OnRequest(ctx context.Context, request *fs.AddQueryCampaignRequest) *fs.AddQueryCampaignResponse
func (*AddQueryCampaignController) OnResponse ¶
func (rc *AddQueryCampaignController) OnResponse(ctx context.Context, request *fs.AddQueryCampaignRequest, response *fs.AddQueryCampaignResponse) *fs.AddQueryCampaignResponse
type AddQueryCampaignInterface ¶
type AddQueryCampaignInterface interface { OnRequest(ctx context.Context, request *fs.AddQueryCampaignRequest) *fs.AddQueryCampaignResponse OnError(ctx context.Context, request *fs.AddQueryCampaignRequest, response *fs.AddQueryCampaignResponse, err error) *fs.AddQueryCampaignResponse OnResponse(ctx context.Context, request *fs.AddQueryCampaignRequest, response *fs.AddQueryCampaignResponse) *fs.AddQueryCampaignResponse }
type AddTargetUserBulkInterface ¶
type AddTargetUserBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkAddTargetUserRequest) *fs.BulkAddTargetUserResponse OnError(ctx context.Context, request *fs.BulkAddTargetUserRequest, response *fs.BulkAddTargetUserResponse, err error) *fs.BulkAddTargetUserResponse OnResponse(ctx context.Context, request *fs.BulkAddTargetUserRequest, response *fs.BulkAddTargetUserResponse) *fs.BulkAddTargetUserResponse }
type AddTargetUserController ¶
type AddTargetUserController struct { }
func (*AddTargetUserController) OnError ¶
func (rc *AddTargetUserController) OnError(ctx context.Context, request *fs.AddTargetUserRequest, response *fs.AddTargetUserResponse, err error) *fs.AddTargetUserResponse
func (*AddTargetUserController) OnRequest ¶
func (rc *AddTargetUserController) OnRequest(ctx context.Context, request *fs.AddTargetUserRequest) *fs.AddTargetUserResponse
func (*AddTargetUserController) OnResponse ¶
func (rc *AddTargetUserController) OnResponse(ctx context.Context, request *fs.AddTargetUserRequest, response *fs.AddTargetUserResponse) *fs.AddTargetUserResponse
type AddTargetUserInterface ¶
type AddTargetUserInterface interface { OnRequest(ctx context.Context, request *fs.AddTargetUserRequest) *fs.AddTargetUserResponse OnError(ctx context.Context, request *fs.AddTargetUserRequest, response *fs.AddTargetUserResponse, err error) *fs.AddTargetUserResponse OnResponse(ctx context.Context, request *fs.AddTargetUserRequest, response *fs.AddTargetUserResponse) *fs.AddTargetUserResponse }
type AddUserJourneyPrefixVO ¶
type AddUserJourneyPrefixVO struct { CampaignId sql.NullInt64 PrefixExpression sql.NullString }
type AddUserJourneyTargetUsersVO ¶
type AddUserJourneyTargetUsersVO struct { CampaignId sql.NullInt64 EngagementVertexId sql.NullInt64 ReferenceId sql.NullString EventReferenceId sql.NullString ActorContactId sql.NullString Status sql.NullString }
type AddUserJourneyVertexVO ¶
type AddUserJourneyVertexVO struct { CampaignId sql.NullInt64 EventType sql.NullString EventName sql.NullString InactionDuration sql.NullInt64 InactionEventName sql.NullString Attributes sql.NullString }
type AthenaQueryController ¶
type AthenaQueryController struct { }
func (*AthenaQueryController) OnError ¶
func (rc *AthenaQueryController) OnError(ctx context.Context, request *fs.AthenaQueryRequest, response *fs.AthenaQueryResponse, err error) *fs.AthenaQueryResponse
func (*AthenaQueryController) OnRequest ¶
func (rc *AthenaQueryController) OnRequest(ctx context.Context, request *fs.AthenaQueryRequest) *fs.AthenaQueryResponse
func (*AthenaQueryController) OnResponse ¶
func (rc *AthenaQueryController) OnResponse(ctx context.Context, request *fs.AthenaQueryRequest, response *fs.AthenaQueryResponse) *fs.AthenaQueryResponse
type AthenaQueryInterface ¶
type AthenaQueryInterface interface { OnRequest(ctx context.Context, request *fs.AthenaQueryRequest) *fs.AthenaQueryResponse OnError(ctx context.Context, request *fs.AthenaQueryRequest, response *fs.AthenaQueryResponse, err error) *fs.AthenaQueryResponse OnResponse(ctx context.Context, request *fs.AthenaQueryRequest, response *fs.AthenaQueryResponse) *fs.AthenaQueryResponse }
type Attributes ¶
type Attributes struct { Placeholders []string `json:"placeholders,omitempty"` ContentMetadata []KvPairs `json:"content_metadata,omitempty"` }
func MapEngagementVertexAttributes ¶
func MapEngagementVertexAttributes(AttributeList string) (*Attributes, error)
type BaseVO ¶
type BaseVO struct { Version sql.NullInt64 CreatedAt sql.NullString UpdatedAt sql.NullString DeletedAt sql.NullString }
type BulkAddCampaignController ¶
type BulkAddCampaignController struct { }
func (*BulkAddCampaignController) OnError ¶
func (rc *BulkAddCampaignController) OnError(ctx context.Context, request *fs.BulkAddCampaignRequest, response *fs.BulkAddCampaignResponse, err error) *fs.BulkAddCampaignResponse
func (*BulkAddCampaignController) OnRequest ¶
func (rc *BulkAddCampaignController) OnRequest(ctx context.Context, request *fs.BulkAddCampaignRequest) *fs.BulkAddCampaignResponse
func (*BulkAddCampaignController) OnResponse ¶
func (rc *BulkAddCampaignController) OnResponse(ctx context.Context, request *fs.BulkAddCampaignRequest, response *fs.BulkAddCampaignResponse) *fs.BulkAddCampaignResponse
type BulkAddCampaignTemplateController ¶
type BulkAddCampaignTemplateController struct { }
func (*BulkAddCampaignTemplateController) OnError ¶
func (rc *BulkAddCampaignTemplateController) OnError(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, response *fs.BulkAddCampaignTemplateResponse, err error) *fs.BulkAddCampaignTemplateResponse
func (*BulkAddCampaignTemplateController) OnRequest ¶
func (rc *BulkAddCampaignTemplateController) OnRequest(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest) *fs.BulkAddCampaignTemplateResponse
func (*BulkAddCampaignTemplateController) OnResponse ¶
func (rc *BulkAddCampaignTemplateController) OnResponse(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, response *fs.BulkAddCampaignTemplateResponse) *fs.BulkAddCampaignTemplateResponse
type BulkAddDynamicDataController ¶
type BulkAddDynamicDataController struct { }
func (*BulkAddDynamicDataController) OnError ¶
func (rc *BulkAddDynamicDataController) OnError(ctx context.Context, request *fs.BulkAddDynamicDataRequest, response *fs.BulkAddDynamicDataResponse, err error) *fs.BulkAddDynamicDataResponse
func (*BulkAddDynamicDataController) OnRequest ¶
func (rc *BulkAddDynamicDataController) OnRequest(ctx context.Context, request *fs.BulkAddDynamicDataRequest) *fs.BulkAddDynamicDataResponse
func (*BulkAddDynamicDataController) OnResponse ¶
func (rc *BulkAddDynamicDataController) OnResponse(ctx context.Context, request *fs.BulkAddDynamicDataRequest, response *fs.BulkAddDynamicDataResponse) *fs.BulkAddDynamicDataResponse
type BulkAddInactionTargetUserController ¶
type BulkAddInactionTargetUserController struct { }
func (*BulkAddInactionTargetUserController) OnError ¶
func (rc *BulkAddInactionTargetUserController) OnError(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, response *fs.BulkAddInactionTargetUserResponse, err error) *fs.BulkAddInactionTargetUserResponse
func (*BulkAddInactionTargetUserController) OnRequest ¶
func (rc *BulkAddInactionTargetUserController) OnRequest(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest) *fs.BulkAddInactionTargetUserResponse
func (*BulkAddInactionTargetUserController) OnResponse ¶
func (rc *BulkAddInactionTargetUserController) OnResponse(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, response *fs.BulkAddInactionTargetUserResponse) *fs.BulkAddInactionTargetUserResponse
type BulkAddNewCampaignController ¶
type BulkAddNewCampaignController struct { }
func (*BulkAddNewCampaignController) OnError ¶
func (rc *BulkAddNewCampaignController) OnError(ctx context.Context, request *fs.BulkAddNewCampaignRequest, response *fs.BulkAddNewCampaignResponse, err error) *fs.BulkAddNewCampaignResponse
func (*BulkAddNewCampaignController) OnRequest ¶
func (rc *BulkAddNewCampaignController) OnRequest(ctx context.Context, request *fs.BulkAddNewCampaignRequest) *fs.BulkAddNewCampaignResponse
func (*BulkAddNewCampaignController) OnResponse ¶
func (rc *BulkAddNewCampaignController) OnResponse(ctx context.Context, request *fs.BulkAddNewCampaignRequest, response *fs.BulkAddNewCampaignResponse) *fs.BulkAddNewCampaignResponse
type BulkAddQueryCampaignController ¶
type BulkAddQueryCampaignController struct { }
func (*BulkAddQueryCampaignController) OnError ¶
func (rc *BulkAddQueryCampaignController) OnError(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, response *fs.BulkAddQueryCampaignResponse, err error) *fs.BulkAddQueryCampaignResponse
func (*BulkAddQueryCampaignController) OnRequest ¶
func (rc *BulkAddQueryCampaignController) OnRequest(ctx context.Context, request *fs.BulkAddQueryCampaignRequest) *fs.BulkAddQueryCampaignResponse
func (*BulkAddQueryCampaignController) OnResponse ¶
func (rc *BulkAddQueryCampaignController) OnResponse(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, response *fs.BulkAddQueryCampaignResponse) *fs.BulkAddQueryCampaignResponse
type BulkAddTargetUserController ¶
type BulkAddTargetUserController struct { }
func (*BulkAddTargetUserController) OnError ¶
func (rc *BulkAddTargetUserController) OnError(ctx context.Context, request *fs.BulkAddTargetUserRequest, response *fs.BulkAddTargetUserResponse, err error) *fs.BulkAddTargetUserResponse
func (*BulkAddTargetUserController) OnRequest ¶
func (rc *BulkAddTargetUserController) OnRequest(ctx context.Context, request *fs.BulkAddTargetUserRequest) *fs.BulkAddTargetUserResponse
func (*BulkAddTargetUserController) OnResponse ¶
func (rc *BulkAddTargetUserController) OnResponse(ctx context.Context, request *fs.BulkAddTargetUserRequest, response *fs.BulkAddTargetUserResponse) *fs.BulkAddTargetUserResponse
type BulkUpdateCampaignController ¶
type BulkUpdateCampaignController struct { }
func (*BulkUpdateCampaignController) OnError ¶
func (rc *BulkUpdateCampaignController) OnError(ctx context.Context, request *fs.BulkUpdateCampaignRequest, response *fs.BulkUpdateCampaignResponse, err error) *fs.BulkUpdateCampaignResponse
func (*BulkUpdateCampaignController) OnRequest ¶
func (rc *BulkUpdateCampaignController) OnRequest(ctx context.Context, request *fs.BulkUpdateCampaignRequest) *fs.BulkUpdateCampaignResponse
func (*BulkUpdateCampaignController) OnResponse ¶
func (rc *BulkUpdateCampaignController) OnResponse(ctx context.Context, request *fs.BulkUpdateCampaignRequest, response *fs.BulkUpdateCampaignResponse) *fs.BulkUpdateCampaignResponse
type CampaignController ¶
type CampaignController struct { }
func (*CampaignController) OnData ¶
func (rc *CampaignController) OnData(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse) *fs.CampaignResponse
func (*CampaignController) OnError ¶
func (rc *CampaignController) OnError(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse, err error) *fs.CampaignResponse
func (*CampaignController) OnRequest ¶
func (rc *CampaignController) OnRequest(ctx context.Context, request *fs.CampaignRequest) *fs.CampaignResponse
func (*CampaignController) OnResponse ¶
func (rc *CampaignController) OnResponse(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse) *fs.CampaignResponse
type CampaignInterface ¶
type CampaignInterface interface { OnRequest(ctx context.Context, request *fs.CampaignRequest) *fs.CampaignResponse OnData(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse) *fs.CampaignResponse OnError(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse, err error) *fs.CampaignResponse OnResponse(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse) *fs.CampaignResponse }
type DeleteEdgesVO ¶
type DeleteEdgesVO struct { CampaignId sql.NullInt64 VertexType sql.NullString }
func MakeDeleteEdgesVO ¶
func MakeDeleteEdgesVO(campaignId int64, vertexType string) *DeleteEdgesVO
type DeleteEngagementVerticesVO ¶
func MakeDeleteEngagementVerticesVO ¶
func MakeDeleteEngagementVerticesVO(campaignId int64) *DeleteEngagementVerticesVO
type DeleteUserJourneyVerticesVO ¶
func MakeDeletUserJourneyVerticesVO ¶
func MakeDeletUserJourneyVerticesVO(campaignId int64) *DeleteUserJourneyVerticesVO
type ExecuteRequestController ¶
type ExecuteRequestController struct { }
var ExecuteRequestExecutor *ExecuteRequestController
func (*ExecuteRequestController) OnError ¶
func (rc *ExecuteRequestController) OnError(ctx context.Context, request interface{}, response interface{}, err error) interface{}
func (*ExecuteRequestController) OnRequest ¶
func (rc *ExecuteRequestController) OnRequest(ctx context.Context, request interface{}) interface{}
func (*ExecuteRequestController) OnResponse ¶
func (rc *ExecuteRequestController) OnResponse(ctx context.Context, request interface{}, response interface{}) interface{}
type FilterCampaignController ¶
type FilterCampaignController struct { }
func (*FilterCampaignController) OnError ¶
func (rc *FilterCampaignController) OnError(ctx context.Context, request *fs.FilterCampaignRequest, response *fs.FilterCampaignResponse, err error) *fs.FilterCampaignResponse
func (*FilterCampaignController) OnRequest ¶
func (rc *FilterCampaignController) OnRequest(ctx context.Context, request *fs.FilterCampaignRequest) *fs.FilterCampaignResponse
func (*FilterCampaignController) OnResponse ¶
func (rc *FilterCampaignController) OnResponse(ctx context.Context, request *fs.FilterCampaignRequest, response *fs.FilterCampaignResponse) *fs.FilterCampaignResponse
type FilterCampaignInterface ¶
type FilterCampaignInterface interface { OnRequest(ctx context.Context, request *fs.FilterCampaignRequest) *fs.FilterCampaignResponse OnError(ctx context.Context, request *fs.FilterCampaignRequest, response *fs.FilterCampaignResponse, err error) *fs.FilterCampaignResponse OnResponse(ctx context.Context, request *fs.FilterCampaignRequest, response *fs.FilterCampaignResponse) *fs.FilterCampaignResponse }
type FilterUserJourneyCampaignController ¶
type FilterUserJourneyCampaignController struct { }
func (*FilterUserJourneyCampaignController) OnData ¶
func (rc *FilterUserJourneyCampaignController) OnData(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse) *fs.FilterUserJourneyCampaignResponse
func (*FilterUserJourneyCampaignController) OnError ¶
func (rc *FilterUserJourneyCampaignController) OnError(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse, err error) *fs.FilterUserJourneyCampaignResponse
func (*FilterUserJourneyCampaignController) OnRequest ¶
func (rc *FilterUserJourneyCampaignController) OnRequest(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest) *fs.FilterUserJourneyCampaignResponse
func (*FilterUserJourneyCampaignController) OnResponse ¶
func (rc *FilterUserJourneyCampaignController) OnResponse(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse) *fs.FilterUserJourneyCampaignResponse
type FilterUserJourneyCampaignInterface ¶
type FilterUserJourneyCampaignInterface interface { OnRequest(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest) *fs.FilterUserJourneyCampaignResponse OnData(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse) *fs.FilterUserJourneyCampaignResponse OnError(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse, err error) *fs.FilterUserJourneyCampaignResponse OnResponse(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse) *fs.FilterUserJourneyCampaignResponse }
type FindCampaignByIdController ¶
type FindCampaignByIdController struct { }
func (*FindCampaignByIdController) OnData ¶
func (rc *FindCampaignByIdController) OnData(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse) *fs.FindCampaignByIdResponse
func (*FindCampaignByIdController) OnError ¶
func (rc *FindCampaignByIdController) OnError(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse, err error) *fs.FindCampaignByIdResponse
func (*FindCampaignByIdController) OnRequest ¶
func (rc *FindCampaignByIdController) OnRequest(ctx context.Context, request *fs.FindCampaignByIdRequest) *fs.FindCampaignByIdResponse
func (*FindCampaignByIdController) OnResponse ¶
func (rc *FindCampaignByIdController) OnResponse(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse) *fs.FindCampaignByIdResponse
type FindCampaignByIdInterface ¶
type FindCampaignByIdInterface interface { OnRequest(ctx context.Context, request *fs.FindCampaignByIdRequest) *fs.FindCampaignByIdResponse OnData(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse) *fs.FindCampaignByIdResponse OnError(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse, err error) *fs.FindCampaignByIdResponse OnResponse(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse) *fs.FindCampaignByIdResponse }
type FindCampaignTemplateByIdController ¶
type FindCampaignTemplateByIdController struct { }
func (*FindCampaignTemplateByIdController) OnData ¶
func (rc *FindCampaignTemplateByIdController) OnData(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse) *fs.FindCampaignTemplateByIdResponse
func (*FindCampaignTemplateByIdController) OnError ¶
func (rc *FindCampaignTemplateByIdController) OnError(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse, err error) *fs.FindCampaignTemplateByIdResponse
func (*FindCampaignTemplateByIdController) OnRequest ¶
func (rc *FindCampaignTemplateByIdController) OnRequest(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) *fs.FindCampaignTemplateByIdResponse
func (*FindCampaignTemplateByIdController) OnResponse ¶
func (rc *FindCampaignTemplateByIdController) OnResponse(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse) *fs.FindCampaignTemplateByIdResponse
type FindCampaignTemplateByIdInterface ¶
type FindCampaignTemplateByIdInterface interface { OnRequest(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) *fs.FindCampaignTemplateByIdResponse OnData(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse) *fs.FindCampaignTemplateByIdResponse OnError(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse, err error) *fs.FindCampaignTemplateByIdResponse OnResponse(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse) *fs.FindCampaignTemplateByIdResponse }
type FindEdgesVO ¶
type FindEngagementVertexVO ¶
type FindEngagementVertexVO struct { Id sql.NullInt64 CampaignId sql.NullInt64 TemplateName sql.NullString Attributes sql.NullString AthenaQuery sql.NullString Channel sql.NullString BaseVO BaseVO }
type FindInactionTargetUserByCampaignIdController ¶
type FindInactionTargetUserByCampaignIdController struct { }
func (*FindInactionTargetUserByCampaignIdController) OnData ¶
func (rc *FindInactionTargetUserByCampaignIdController) OnData(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse) *fs.FindInactionTargetUserByCampaignIdResponse
func (*FindInactionTargetUserByCampaignIdController) OnError ¶
func (rc *FindInactionTargetUserByCampaignIdController) OnError(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse, err error) *fs.FindInactionTargetUserByCampaignIdResponse
func (*FindInactionTargetUserByCampaignIdController) OnRequest ¶
func (rc *FindInactionTargetUserByCampaignIdController) OnRequest(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) *fs.FindInactionTargetUserByCampaignIdResponse
func (*FindInactionTargetUserByCampaignIdController) OnResponse ¶
func (rc *FindInactionTargetUserByCampaignIdController) OnResponse(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse) *fs.FindInactionTargetUserByCampaignIdResponse
type FindInactionTargetUserByCampaignIdInterface ¶
type FindInactionTargetUserByCampaignIdInterface interface { OnRequest(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) *fs.FindInactionTargetUserByCampaignIdResponse OnData(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse) *fs.FindInactionTargetUserByCampaignIdResponse OnError(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse, err error) *fs.FindInactionTargetUserByCampaignIdResponse OnResponse(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse) *fs.FindInactionTargetUserByCampaignIdResponse }
type FindNextEngagementVertexVO ¶
type FindNextEngagementVertexVO struct { Id sql.NullInt64 MessageDeliveryStates sql.NullString WaitDuration sql.NullInt64 WaitTime sql.NullTime WaitType sql.NullString }
type FindPreviousEngagementVertexVO ¶
type FindPreviousEngagementVertexVO struct { Id sql.NullInt64 MessageDeliveryStates sql.NullString }
type FindQueryCampaignController ¶
type FindQueryCampaignController struct { }
func (*FindQueryCampaignController) OnData ¶
func (rc *FindQueryCampaignController) OnData(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse) *fs.FindQueryCampaignResponse
func (*FindQueryCampaignController) OnError ¶
func (rc *FindQueryCampaignController) OnError(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse, err error) *fs.FindQueryCampaignResponse
func (*FindQueryCampaignController) OnRequest ¶
func (rc *FindQueryCampaignController) OnRequest(ctx context.Context, request *fs.FindQueryCampaignRequest) *fs.FindQueryCampaignResponse
func (*FindQueryCampaignController) OnResponse ¶
func (rc *FindQueryCampaignController) OnResponse(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse) *fs.FindQueryCampaignResponse
type FindQueryCampaignInterface ¶
type FindQueryCampaignInterface interface { OnRequest(ctx context.Context, request *fs.FindQueryCampaignRequest) *fs.FindQueryCampaignResponse OnData(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse) *fs.FindQueryCampaignResponse OnError(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse, err error) *fs.FindQueryCampaignResponse OnResponse(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse) *fs.FindQueryCampaignResponse }
type FindTargetUserByIdController ¶
type FindTargetUserByIdController struct { }
func (*FindTargetUserByIdController) OnData ¶
func (rc *FindTargetUserByIdController) OnData(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse) *fs.FindTargetUserByIdResponse
func (*FindTargetUserByIdController) OnError ¶
func (rc *FindTargetUserByIdController) OnError(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse, err error) *fs.FindTargetUserByIdResponse
func (*FindTargetUserByIdController) OnRequest ¶
func (rc *FindTargetUserByIdController) OnRequest(ctx context.Context, request *fs.FindTargetUserByIdRequest) *fs.FindTargetUserByIdResponse
func (*FindTargetUserByIdController) OnResponse ¶
func (rc *FindTargetUserByIdController) OnResponse(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse) *fs.FindTargetUserByIdResponse
type FindTargetUserByIdInterface ¶
type FindTargetUserByIdInterface interface { OnRequest(ctx context.Context, request *fs.FindTargetUserByIdRequest) *fs.FindTargetUserByIdResponse OnData(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse) *fs.FindTargetUserByIdResponse OnError(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse, err error) *fs.FindTargetUserByIdResponse OnResponse(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse) *fs.FindTargetUserByIdResponse }
type FindUserJourneyCampaigVO ¶
type FindUserJourneyCampaigVO struct { Id sql.NullInt64 Namespace sql.NullString Name sql.NullString Status sql.NullString CreatedAt sql.NullTime Count sql.NullInt64 TargetUsersStatus sql.NullString }
type FindUserJourneyCampaignByIdController ¶
type FindUserJourneyCampaignByIdController struct { }
func (*FindUserJourneyCampaignByIdController) OnData ¶
func (rc *FindUserJourneyCampaignByIdController) OnData(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse) *fs.FindUserJourneyCampaignByIdResponse
func (*FindUserJourneyCampaignByIdController) OnError ¶
func (rc *FindUserJourneyCampaignByIdController) OnError(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse, err error) *fs.FindUserJourneyCampaignByIdResponse
func (*FindUserJourneyCampaignByIdController) OnRequest ¶
func (rc *FindUserJourneyCampaignByIdController) OnRequest(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest) *fs.FindUserJourneyCampaignByIdResponse
func (*FindUserJourneyCampaignByIdController) OnResponse ¶
func (rc *FindUserJourneyCampaignByIdController) OnResponse(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse) *fs.FindUserJourneyCampaignByIdResponse
type FindUserJourneyCampaignByIdInterface ¶
type FindUserJourneyCampaignByIdInterface interface { OnRequest(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest) *fs.FindUserJourneyCampaignByIdResponse OnData(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse) *fs.FindUserJourneyCampaignByIdResponse OnError(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse, err error) *fs.FindUserJourneyCampaignByIdResponse OnResponse(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse) *fs.FindUserJourneyCampaignByIdResponse }
type FindUserJourneyTargetUsersVO ¶
type FindUserJourneyTargetUsersVO struct { Id sql.NullInt64 CampaignId sql.NullInt64 EngagementVertexId sql.NullInt64 ReferenceId sql.NullString EventReferenceId sql.NullString ActorContactId sql.NullString Status sql.NullString BaseVO BaseVO }
type FindUserJourneyVertexVO ¶
type FindUserJourneyVertexVO struct { Id sql.NullInt64 CampaignId sql.NullInt64 EventType sql.NullString EventName sql.NullString InactionDuration sql.NullInt64 InactionEventName sql.NullString BaseVO BaseVO Attributes sql.NullString }
type GenericAddCampaignExecutor ¶
type GenericAddCampaignExecutor struct {
AddCampaignInterface AddCampaignInterface
}
var AddCampaignExecutor *GenericAddCampaignExecutor
func (*GenericAddCampaignExecutor) OnError ¶
func (ge *GenericAddCampaignExecutor) OnError(ctx context.Context, request *fs.AddCampaignRequest, response *fs.AddCampaignResponse, err error) *fs.AddCampaignResponse
func (*GenericAddCampaignExecutor) OnRequest ¶
func (ge *GenericAddCampaignExecutor) OnRequest(ctx context.Context, request *fs.AddCampaignRequest) *fs.AddCampaignResponse
func (*GenericAddCampaignExecutor) OnResponse ¶
func (ge *GenericAddCampaignExecutor) OnResponse(ctx context.Context, request *fs.AddCampaignRequest, response *fs.AddCampaignResponse) *fs.AddCampaignResponse
type GenericAddCampaignExecutorBulk ¶
type GenericAddCampaignExecutorBulk struct {
AddCampaignBulkInterface AddCampaignBulkInterface
}
var BulkAddCampaignExecutor *GenericAddCampaignExecutorBulk
func (*GenericAddCampaignExecutorBulk) OnError ¶
func (ge *GenericAddCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddCampaignRequest, response *fs.BulkAddCampaignResponse, err error) *fs.BulkAddCampaignResponse
func (*GenericAddCampaignExecutorBulk) OnRequest ¶
func (ge *GenericAddCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddCampaignRequest) *fs.BulkAddCampaignResponse
func (*GenericAddCampaignExecutorBulk) OnResponse ¶
func (ge *GenericAddCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddCampaignRequest, response *fs.BulkAddCampaignResponse) *fs.BulkAddCampaignResponse
type GenericAddCampaignTemplateExecutor ¶
type GenericAddCampaignTemplateExecutor struct {
AddCampaignTemplateInterface AddCampaignTemplateInterface
}
var AddCampaignTemplateExecutor *GenericAddCampaignTemplateExecutor
func (*GenericAddCampaignTemplateExecutor) OnError ¶
func (ge *GenericAddCampaignTemplateExecutor) OnError(ctx context.Context, request *fs.AddCampaignTemplateRequest, response *fs.AddCampaignTemplateResponse, err error) *fs.AddCampaignTemplateResponse
func (*GenericAddCampaignTemplateExecutor) OnRequest ¶
func (ge *GenericAddCampaignTemplateExecutor) OnRequest(ctx context.Context, request *fs.AddCampaignTemplateRequest) *fs.AddCampaignTemplateResponse
func (*GenericAddCampaignTemplateExecutor) OnResponse ¶
func (ge *GenericAddCampaignTemplateExecutor) OnResponse(ctx context.Context, request *fs.AddCampaignTemplateRequest, response *fs.AddCampaignTemplateResponse) *fs.AddCampaignTemplateResponse
type GenericAddCampaignTemplateExecutorBulk ¶
type GenericAddCampaignTemplateExecutorBulk struct {
AddCampaignTemplateBulkInterface AddCampaignTemplateBulkInterface
}
var BulkAddCampaignTemplateExecutor *GenericAddCampaignTemplateExecutorBulk
func (*GenericAddCampaignTemplateExecutorBulk) OnError ¶
func (ge *GenericAddCampaignTemplateExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, response *fs.BulkAddCampaignTemplateResponse, err error) *fs.BulkAddCampaignTemplateResponse
func (*GenericAddCampaignTemplateExecutorBulk) OnRequest ¶
func (ge *GenericAddCampaignTemplateExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest) *fs.BulkAddCampaignTemplateResponse
func (*GenericAddCampaignTemplateExecutorBulk) OnResponse ¶
func (ge *GenericAddCampaignTemplateExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddCampaignTemplateRequest, response *fs.BulkAddCampaignTemplateResponse) *fs.BulkAddCampaignTemplateResponse
type GenericAddDynamicDataExecutor ¶
type GenericAddDynamicDataExecutor struct {
AddDynamicDataInterface AddDynamicDataInterface
}
var AddDynamicDataExecutor *GenericAddDynamicDataExecutor
func (*GenericAddDynamicDataExecutor) OnError ¶
func (ge *GenericAddDynamicDataExecutor) OnError(ctx context.Context, request *fs.AddDynamicDataRequest, response *fs.AddDynamicDataResponse, err error) *fs.AddDynamicDataResponse
func (*GenericAddDynamicDataExecutor) OnRequest ¶
func (ge *GenericAddDynamicDataExecutor) OnRequest(ctx context.Context, request *fs.AddDynamicDataRequest) *fs.AddDynamicDataResponse
func (*GenericAddDynamicDataExecutor) OnResponse ¶
func (ge *GenericAddDynamicDataExecutor) OnResponse(ctx context.Context, request *fs.AddDynamicDataRequest, response *fs.AddDynamicDataResponse) *fs.AddDynamicDataResponse
type GenericAddDynamicDataExecutorBulk ¶
type GenericAddDynamicDataExecutorBulk struct {
AddDynamicDataBulkInterface AddDynamicDataBulkInterface
}
var BulkAddDynamicDataExecutor *GenericAddDynamicDataExecutorBulk
func (*GenericAddDynamicDataExecutorBulk) OnError ¶
func (ge *GenericAddDynamicDataExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddDynamicDataRequest, response *fs.BulkAddDynamicDataResponse, err error) *fs.BulkAddDynamicDataResponse
func (*GenericAddDynamicDataExecutorBulk) OnRequest ¶
func (ge *GenericAddDynamicDataExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddDynamicDataRequest) *fs.BulkAddDynamicDataResponse
func (*GenericAddDynamicDataExecutorBulk) OnResponse ¶
func (ge *GenericAddDynamicDataExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddDynamicDataRequest, response *fs.BulkAddDynamicDataResponse) *fs.BulkAddDynamicDataResponse
type GenericAddInactionTargetUserExecutor ¶
type GenericAddInactionTargetUserExecutor struct {
AddInactionTargetUserInterface AddInactionTargetUserInterface
}
var AddInactionTargetUserExecutor *GenericAddInactionTargetUserExecutor
func (*GenericAddInactionTargetUserExecutor) OnError ¶
func (ge *GenericAddInactionTargetUserExecutor) OnError(ctx context.Context, request *fs.AddInactionTargetUserRequest, response *fs.AddInactionTargetUserResponse, err error) *fs.AddInactionTargetUserResponse
func (*GenericAddInactionTargetUserExecutor) OnRequest ¶
func (ge *GenericAddInactionTargetUserExecutor) OnRequest(ctx context.Context, request *fs.AddInactionTargetUserRequest) *fs.AddInactionTargetUserResponse
func (*GenericAddInactionTargetUserExecutor) OnResponse ¶
func (ge *GenericAddInactionTargetUserExecutor) OnResponse(ctx context.Context, request *fs.AddInactionTargetUserRequest, response *fs.AddInactionTargetUserResponse) *fs.AddInactionTargetUserResponse
type GenericAddInactionTargetUserExecutorBulk ¶
type GenericAddInactionTargetUserExecutorBulk struct {
AddInactionTargetUserBulkInterface AddInactionTargetUserBulkInterface
}
var BulkAddInactionTargetUserExecutor *GenericAddInactionTargetUserExecutorBulk
func (*GenericAddInactionTargetUserExecutorBulk) OnError ¶
func (ge *GenericAddInactionTargetUserExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, response *fs.BulkAddInactionTargetUserResponse, err error) *fs.BulkAddInactionTargetUserResponse
func (*GenericAddInactionTargetUserExecutorBulk) OnRequest ¶
func (ge *GenericAddInactionTargetUserExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest) *fs.BulkAddInactionTargetUserResponse
func (*GenericAddInactionTargetUserExecutorBulk) OnResponse ¶
func (ge *GenericAddInactionTargetUserExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddInactionTargetUserRequest, response *fs.BulkAddInactionTargetUserResponse) *fs.BulkAddInactionTargetUserResponse
type GenericAddNewCampaignExecutor ¶
type GenericAddNewCampaignExecutor struct {
AddNewCampaignInterface AddNewCampaignInterface
}
var AddNewCampaignExecutor *GenericAddNewCampaignExecutor
func (*GenericAddNewCampaignExecutor) OnError ¶
func (ge *GenericAddNewCampaignExecutor) OnError(ctx context.Context, request *fs.AddNewCampaignRequest, response *fs.AddNewCampaignResponse, err error) *fs.AddNewCampaignResponse
func (*GenericAddNewCampaignExecutor) OnRequest ¶
func (ge *GenericAddNewCampaignExecutor) OnRequest(ctx context.Context, request *fs.AddNewCampaignRequest) *fs.AddNewCampaignResponse
func (*GenericAddNewCampaignExecutor) OnResponse ¶
func (ge *GenericAddNewCampaignExecutor) OnResponse(ctx context.Context, request *fs.AddNewCampaignRequest, response *fs.AddNewCampaignResponse) *fs.AddNewCampaignResponse
type GenericAddNewCampaignExecutorBulk ¶
type GenericAddNewCampaignExecutorBulk struct {
AddNewCampaignBulkInterface AddNewCampaignBulkInterface
}
var BulkAddNewCampaignExecutor *GenericAddNewCampaignExecutorBulk
func (*GenericAddNewCampaignExecutorBulk) OnError ¶
func (ge *GenericAddNewCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddNewCampaignRequest, response *fs.BulkAddNewCampaignResponse, err error) *fs.BulkAddNewCampaignResponse
func (*GenericAddNewCampaignExecutorBulk) OnRequest ¶
func (ge *GenericAddNewCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddNewCampaignRequest) *fs.BulkAddNewCampaignResponse
func (*GenericAddNewCampaignExecutorBulk) OnResponse ¶
func (ge *GenericAddNewCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddNewCampaignRequest, response *fs.BulkAddNewCampaignResponse) *fs.BulkAddNewCampaignResponse
type GenericAddQueryCampaignExecutor ¶
type GenericAddQueryCampaignExecutor struct {
AddQueryCampaignInterface AddQueryCampaignInterface
}
var AddQueryCampaignExecutor *GenericAddQueryCampaignExecutor
func (*GenericAddQueryCampaignExecutor) OnError ¶
func (ge *GenericAddQueryCampaignExecutor) OnError(ctx context.Context, request *fs.AddQueryCampaignRequest, response *fs.AddQueryCampaignResponse, err error) *fs.AddQueryCampaignResponse
func (*GenericAddQueryCampaignExecutor) OnRequest ¶
func (ge *GenericAddQueryCampaignExecutor) OnRequest(ctx context.Context, request *fs.AddQueryCampaignRequest) *fs.AddQueryCampaignResponse
func (*GenericAddQueryCampaignExecutor) OnResponse ¶
func (ge *GenericAddQueryCampaignExecutor) OnResponse(ctx context.Context, request *fs.AddQueryCampaignRequest, response *fs.AddQueryCampaignResponse) *fs.AddQueryCampaignResponse
type GenericAddQueryCampaignExecutorBulk ¶
type GenericAddQueryCampaignExecutorBulk struct {
AddQueryCampaignBulkInterface AddQueryCampaignBulkInterface
}
var BulkAddQueryCampaignExecutor *GenericAddQueryCampaignExecutorBulk
func (*GenericAddQueryCampaignExecutorBulk) OnError ¶
func (ge *GenericAddQueryCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, response *fs.BulkAddQueryCampaignResponse, err error) *fs.BulkAddQueryCampaignResponse
func (*GenericAddQueryCampaignExecutorBulk) OnRequest ¶
func (ge *GenericAddQueryCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddQueryCampaignRequest) *fs.BulkAddQueryCampaignResponse
func (*GenericAddQueryCampaignExecutorBulk) OnResponse ¶
func (ge *GenericAddQueryCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddQueryCampaignRequest, response *fs.BulkAddQueryCampaignResponse) *fs.BulkAddQueryCampaignResponse
type GenericAddTargetUserExecutor ¶
type GenericAddTargetUserExecutor struct {
AddTargetUserInterface AddTargetUserInterface
}
var AddTargetUserExecutor *GenericAddTargetUserExecutor
func (*GenericAddTargetUserExecutor) OnError ¶
func (ge *GenericAddTargetUserExecutor) OnError(ctx context.Context, request *fs.AddTargetUserRequest, response *fs.AddTargetUserResponse, err error) *fs.AddTargetUserResponse
func (*GenericAddTargetUserExecutor) OnRequest ¶
func (ge *GenericAddTargetUserExecutor) OnRequest(ctx context.Context, request *fs.AddTargetUserRequest) *fs.AddTargetUserResponse
func (*GenericAddTargetUserExecutor) OnResponse ¶
func (ge *GenericAddTargetUserExecutor) OnResponse(ctx context.Context, request *fs.AddTargetUserRequest, response *fs.AddTargetUserResponse) *fs.AddTargetUserResponse
type GenericAddTargetUserExecutorBulk ¶
type GenericAddTargetUserExecutorBulk struct {
AddTargetUserBulkInterface AddTargetUserBulkInterface
}
var BulkAddTargetUserExecutor *GenericAddTargetUserExecutorBulk
func (*GenericAddTargetUserExecutorBulk) OnError ¶
func (ge *GenericAddTargetUserExecutorBulk) OnError(ctx context.Context, request *fs.BulkAddTargetUserRequest, response *fs.BulkAddTargetUserResponse, err error) *fs.BulkAddTargetUserResponse
func (*GenericAddTargetUserExecutorBulk) OnRequest ¶
func (ge *GenericAddTargetUserExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkAddTargetUserRequest) *fs.BulkAddTargetUserResponse
func (*GenericAddTargetUserExecutorBulk) OnResponse ¶
func (ge *GenericAddTargetUserExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkAddTargetUserRequest, response *fs.BulkAddTargetUserResponse) *fs.BulkAddTargetUserResponse
type GenericAthenaQueryExecutor ¶
type GenericAthenaQueryExecutor struct {
AthenaQueryInterface AthenaQueryInterface
}
var AthenaQueryExecutor *GenericAthenaQueryExecutor
func (*GenericAthenaQueryExecutor) OnError ¶
func (ge *GenericAthenaQueryExecutor) OnError(ctx context.Context, request *fs.AthenaQueryRequest, response *fs.AthenaQueryResponse, err error) *fs.AthenaQueryResponse
func (*GenericAthenaQueryExecutor) OnRequest ¶
func (ge *GenericAthenaQueryExecutor) OnRequest(ctx context.Context, request *fs.AthenaQueryRequest) *fs.AthenaQueryResponse
func (*GenericAthenaQueryExecutor) OnResponse ¶
func (ge *GenericAthenaQueryExecutor) OnResponse(ctx context.Context, request *fs.AthenaQueryRequest, response *fs.AthenaQueryResponse) *fs.AthenaQueryResponse
type GenericCampaignExecutor ¶
type GenericCampaignExecutor struct {
CampaignInterface CampaignInterface
}
var CampaignExecutor *GenericCampaignExecutor
func (*GenericCampaignExecutor) OnData ¶
func (ge *GenericCampaignExecutor) OnData(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse) *fs.CampaignResponse
func (*GenericCampaignExecutor) OnError ¶
func (ge *GenericCampaignExecutor) OnError(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse, err error) *fs.CampaignResponse
func (*GenericCampaignExecutor) OnRequest ¶
func (ge *GenericCampaignExecutor) OnRequest(ctx context.Context, request *fs.CampaignRequest) *fs.CampaignResponse
func (*GenericCampaignExecutor) OnResponse ¶
func (ge *GenericCampaignExecutor) OnResponse(ctx context.Context, request *fs.CampaignRequest, response *fs.CampaignResponse) *fs.CampaignResponse
type GenericFilterCampaignExecutor ¶
type GenericFilterCampaignExecutor struct {
FilterCampaignInterface FilterCampaignInterface
}
var FilterCampaignExecutor *GenericFilterCampaignExecutor
func (*GenericFilterCampaignExecutor) OnError ¶
func (ge *GenericFilterCampaignExecutor) OnError(ctx context.Context, request *fs.FilterCampaignRequest, response *fs.FilterCampaignResponse, err error) *fs.FilterCampaignResponse
func (*GenericFilterCampaignExecutor) OnRequest ¶
func (ge *GenericFilterCampaignExecutor) OnRequest(ctx context.Context, request *fs.FilterCampaignRequest) *fs.FilterCampaignResponse
func (*GenericFilterCampaignExecutor) OnResponse ¶
func (ge *GenericFilterCampaignExecutor) OnResponse(ctx context.Context, request *fs.FilterCampaignRequest, response *fs.FilterCampaignResponse) *fs.FilterCampaignResponse
type GenericFilterUserJourneyCampaignExecutor ¶
type GenericFilterUserJourneyCampaignExecutor struct {
FilterUserJourneyCampaignInterface FilterUserJourneyCampaignInterface
}
var FilterUserJourneyCampaignExecutor *GenericFilterUserJourneyCampaignExecutor
func (*GenericFilterUserJourneyCampaignExecutor) OnData ¶
func (ge *GenericFilterUserJourneyCampaignExecutor) OnData(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse) *fs.FilterUserJourneyCampaignResponse
func (*GenericFilterUserJourneyCampaignExecutor) OnError ¶
func (ge *GenericFilterUserJourneyCampaignExecutor) OnError(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse, err error) *fs.FilterUserJourneyCampaignResponse
func (*GenericFilterUserJourneyCampaignExecutor) OnRequest ¶
func (ge *GenericFilterUserJourneyCampaignExecutor) OnRequest(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest) *fs.FilterUserJourneyCampaignResponse
func (*GenericFilterUserJourneyCampaignExecutor) OnResponse ¶
func (ge *GenericFilterUserJourneyCampaignExecutor) OnResponse(ctx context.Context, request *fs.FilterUserJourneyCampaignRequest, response *fs.FilterUserJourneyCampaignResponse) *fs.FilterUserJourneyCampaignResponse
type GenericFindCampaignByIdExecutor ¶
type GenericFindCampaignByIdExecutor struct {
FindCampaignByIdInterface FindCampaignByIdInterface
}
var FindCampaignByIdExecutor *GenericFindCampaignByIdExecutor
func (*GenericFindCampaignByIdExecutor) OnData ¶
func (ge *GenericFindCampaignByIdExecutor) OnData(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse) *fs.FindCampaignByIdResponse
func (*GenericFindCampaignByIdExecutor) OnError ¶
func (ge *GenericFindCampaignByIdExecutor) OnError(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse, err error) *fs.FindCampaignByIdResponse
func (*GenericFindCampaignByIdExecutor) OnRequest ¶
func (ge *GenericFindCampaignByIdExecutor) OnRequest(ctx context.Context, request *fs.FindCampaignByIdRequest) *fs.FindCampaignByIdResponse
func (*GenericFindCampaignByIdExecutor) OnResponse ¶
func (ge *GenericFindCampaignByIdExecutor) OnResponse(ctx context.Context, request *fs.FindCampaignByIdRequest, response *fs.FindCampaignByIdResponse) *fs.FindCampaignByIdResponse
type GenericFindCampaignTemplateByIdExecutor ¶
type GenericFindCampaignTemplateByIdExecutor struct {
FindCampaignTemplateByIdInterface FindCampaignTemplateByIdInterface
}
var FindCampaignTemplateByIdExecutor *GenericFindCampaignTemplateByIdExecutor
func (*GenericFindCampaignTemplateByIdExecutor) OnData ¶
func (ge *GenericFindCampaignTemplateByIdExecutor) OnData(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse) *fs.FindCampaignTemplateByIdResponse
func (*GenericFindCampaignTemplateByIdExecutor) OnError ¶
func (ge *GenericFindCampaignTemplateByIdExecutor) OnError(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse, err error) *fs.FindCampaignTemplateByIdResponse
func (*GenericFindCampaignTemplateByIdExecutor) OnRequest ¶
func (ge *GenericFindCampaignTemplateByIdExecutor) OnRequest(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest) *fs.FindCampaignTemplateByIdResponse
func (*GenericFindCampaignTemplateByIdExecutor) OnResponse ¶
func (ge *GenericFindCampaignTemplateByIdExecutor) OnResponse(ctx context.Context, request *fs.FindCampaignTemplateByIdRequest, response *fs.FindCampaignTemplateByIdResponse) *fs.FindCampaignTemplateByIdResponse
type GenericFindInactionTargetUserByCampaignIdExecutor ¶
type GenericFindInactionTargetUserByCampaignIdExecutor struct {
FindInactionTargetUserByCampaignIdInterface FindInactionTargetUserByCampaignIdInterface
}
var FindInactionTargetUserByCampaignIdExecutor *GenericFindInactionTargetUserByCampaignIdExecutor
func (*GenericFindInactionTargetUserByCampaignIdExecutor) OnData ¶
func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnData(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse) *fs.FindInactionTargetUserByCampaignIdResponse
func (*GenericFindInactionTargetUserByCampaignIdExecutor) OnError ¶
func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnError(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse, err error) *fs.FindInactionTargetUserByCampaignIdResponse
func (*GenericFindInactionTargetUserByCampaignIdExecutor) OnRequest ¶
func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnRequest(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest) *fs.FindInactionTargetUserByCampaignIdResponse
func (*GenericFindInactionTargetUserByCampaignIdExecutor) OnResponse ¶
func (ge *GenericFindInactionTargetUserByCampaignIdExecutor) OnResponse(ctx context.Context, request *fs.FindInactionTargetUserByCampaignIdRequest, response *fs.FindInactionTargetUserByCampaignIdResponse) *fs.FindInactionTargetUserByCampaignIdResponse
type GenericFindQueryCampaignExecutor ¶
type GenericFindQueryCampaignExecutor struct {
FindQueryCampaignInterface FindQueryCampaignInterface
}
var FindQueryCampaignExecutor *GenericFindQueryCampaignExecutor
func (*GenericFindQueryCampaignExecutor) OnData ¶
func (ge *GenericFindQueryCampaignExecutor) OnData(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse) *fs.FindQueryCampaignResponse
func (*GenericFindQueryCampaignExecutor) OnError ¶
func (ge *GenericFindQueryCampaignExecutor) OnError(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse, err error) *fs.FindQueryCampaignResponse
func (*GenericFindQueryCampaignExecutor) OnRequest ¶
func (ge *GenericFindQueryCampaignExecutor) OnRequest(ctx context.Context, request *fs.FindQueryCampaignRequest) *fs.FindQueryCampaignResponse
func (*GenericFindQueryCampaignExecutor) OnResponse ¶
func (ge *GenericFindQueryCampaignExecutor) OnResponse(ctx context.Context, request *fs.FindQueryCampaignRequest, response *fs.FindQueryCampaignResponse) *fs.FindQueryCampaignResponse
type GenericFindTargetUserByIdExecutor ¶
type GenericFindTargetUserByIdExecutor struct {
FindTargetUserByIdInterface FindTargetUserByIdInterface
}
var FindTargetUserByIdExecutor *GenericFindTargetUserByIdExecutor
func (*GenericFindTargetUserByIdExecutor) OnData ¶
func (ge *GenericFindTargetUserByIdExecutor) OnData(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse) *fs.FindTargetUserByIdResponse
func (*GenericFindTargetUserByIdExecutor) OnError ¶
func (ge *GenericFindTargetUserByIdExecutor) OnError(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse, err error) *fs.FindTargetUserByIdResponse
func (*GenericFindTargetUserByIdExecutor) OnRequest ¶
func (ge *GenericFindTargetUserByIdExecutor) OnRequest(ctx context.Context, request *fs.FindTargetUserByIdRequest) *fs.FindTargetUserByIdResponse
func (*GenericFindTargetUserByIdExecutor) OnResponse ¶
func (ge *GenericFindTargetUserByIdExecutor) OnResponse(ctx context.Context, request *fs.FindTargetUserByIdRequest, response *fs.FindTargetUserByIdResponse) *fs.FindTargetUserByIdResponse
type GenericFindUserJourneyCampaignByIdExecutor ¶
type GenericFindUserJourneyCampaignByIdExecutor struct {
FindUserJourneyCampaignByIdInterface FindUserJourneyCampaignByIdInterface
}
var FindUserJourneyCampaignByIdExecutor *GenericFindUserJourneyCampaignByIdExecutor
func (*GenericFindUserJourneyCampaignByIdExecutor) OnData ¶
func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnData(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse) *fs.FindUserJourneyCampaignByIdResponse
func (*GenericFindUserJourneyCampaignByIdExecutor) OnError ¶
func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnError(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse, err error) *fs.FindUserJourneyCampaignByIdResponse
func (*GenericFindUserJourneyCampaignByIdExecutor) OnRequest ¶
func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnRequest(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest) *fs.FindUserJourneyCampaignByIdResponse
func (*GenericFindUserJourneyCampaignByIdExecutor) OnResponse ¶
func (ge *GenericFindUserJourneyCampaignByIdExecutor) OnResponse(ctx context.Context, request *fs.FindUserJourneyCampaignByIdRequest, response *fs.FindUserJourneyCampaignByIdResponse) *fs.FindUserJourneyCampaignByIdResponse
type GenericGetDynamicDataByKeyExecutor ¶
type GenericGetDynamicDataByKeyExecutor struct {
GetDynamicDataByKeyInterface GetDynamicDataByKeyInterface
}
var GetDynamicDataByKeyExecutor *GenericGetDynamicDataByKeyExecutor
func (*GenericGetDynamicDataByKeyExecutor) OnData ¶
func (ge *GenericGetDynamicDataByKeyExecutor) OnData(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse) *fs.GetDynamicDataByKeyResponse
func (*GenericGetDynamicDataByKeyExecutor) OnError ¶
func (ge *GenericGetDynamicDataByKeyExecutor) OnError(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse, err error) *fs.GetDynamicDataByKeyResponse
func (*GenericGetDynamicDataByKeyExecutor) OnRequest ¶
func (ge *GenericGetDynamicDataByKeyExecutor) OnRequest(ctx context.Context, request *fs.GetDynamicDataByKeyRequest) *fs.GetDynamicDataByKeyResponse
func (*GenericGetDynamicDataByKeyExecutor) OnResponse ¶
func (ge *GenericGetDynamicDataByKeyExecutor) OnResponse(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse) *fs.GetDynamicDataByKeyResponse
type GenericScheduleUserJourneyCampaignExecutor ¶
type GenericScheduleUserJourneyCampaignExecutor struct {
ScheduleUserJourneyCampaignInterface ScheduleUserJourneyCampaignInterface
}
var ScheduleUserJourneyCampaignExecutor *GenericScheduleUserJourneyCampaignExecutor
func (*GenericScheduleUserJourneyCampaignExecutor) OnData ¶
func (ge *GenericScheduleUserJourneyCampaignExecutor) OnData(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse) *fs.ScheduleUserJourneyCampaignResponse
func (*GenericScheduleUserJourneyCampaignExecutor) OnError ¶
func (ge *GenericScheduleUserJourneyCampaignExecutor) OnError(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse, err error) *fs.ScheduleUserJourneyCampaignResponse
func (*GenericScheduleUserJourneyCampaignExecutor) OnRequest ¶
func (ge *GenericScheduleUserJourneyCampaignExecutor) OnRequest(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest) *fs.ScheduleUserJourneyCampaignResponse
func (*GenericScheduleUserJourneyCampaignExecutor) OnResponse ¶
func (ge *GenericScheduleUserJourneyCampaignExecutor) OnResponse(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse) *fs.ScheduleUserJourneyCampaignResponse
type GenericTestCampaignByIdExecutor ¶
type GenericTestCampaignByIdExecutor struct {
TestCampaignByIdInterface TestCampaignByIdInterface
}
var TestCampaignByIdExecutor *GenericTestCampaignByIdExecutor
func (*GenericTestCampaignByIdExecutor) OnError ¶
func (ge *GenericTestCampaignByIdExecutor) OnError(ctx context.Context, request *fs.TestCampaignByIdRequest, response *fs.TestCampaignByIdResponse, err error) *fs.TestCampaignByIdResponse
func (*GenericTestCampaignByIdExecutor) OnRequest ¶
func (ge *GenericTestCampaignByIdExecutor) OnRequest(ctx context.Context, request *fs.TestCampaignByIdRequest) *fs.TestCampaignByIdResponse
func (*GenericTestCampaignByIdExecutor) OnResponse ¶
func (ge *GenericTestCampaignByIdExecutor) OnResponse(ctx context.Context, request *fs.TestCampaignByIdRequest, response *fs.TestCampaignByIdResponse) *fs.TestCampaignByIdResponse
type GenericTestNewCampaignExecutor ¶
type GenericTestNewCampaignExecutor struct {
TestNewCampaignInterface TestNewCampaignInterface
}
var TestNewCampaignExecutor *GenericTestNewCampaignExecutor
func (*GenericTestNewCampaignExecutor) OnError ¶
func (ge *GenericTestNewCampaignExecutor) OnError(ctx context.Context, request *fs.TestNewCampaignRequest, response *fs.TestNewCampaignResponse, err error) *fs.TestNewCampaignResponse
func (*GenericTestNewCampaignExecutor) OnRequest ¶
func (ge *GenericTestNewCampaignExecutor) OnRequest(ctx context.Context, request *fs.TestNewCampaignRequest) *fs.TestNewCampaignResponse
func (*GenericTestNewCampaignExecutor) OnResponse ¶
func (ge *GenericTestNewCampaignExecutor) OnResponse(ctx context.Context, request *fs.TestNewCampaignRequest, response *fs.TestNewCampaignResponse) *fs.TestNewCampaignResponse
type GenericUpdateCampaignExecutor ¶
type GenericUpdateCampaignExecutor struct {
UpdateCampaignInterface UpdateCampaignInterface
}
var UpdateCampaignExecutor *GenericUpdateCampaignExecutor
func (*GenericUpdateCampaignExecutor) OnError ¶
func (ge *GenericUpdateCampaignExecutor) OnError(ctx context.Context, request *fs.UpdateCampaignRequest, response *fs.UpdateCampaignResponse, err error) *fs.UpdateCampaignResponse
func (*GenericUpdateCampaignExecutor) OnRequest ¶
func (ge *GenericUpdateCampaignExecutor) OnRequest(ctx context.Context, request *fs.UpdateCampaignRequest) (*fs.UpdateCampaignResponse, *fs.AddNewCampaignRequest)
func (*GenericUpdateCampaignExecutor) OnResponse ¶
func (ge *GenericUpdateCampaignExecutor) OnResponse(ctx context.Context, request *fs.UpdateCampaignRequest, response *fs.UpdateCampaignResponse) *fs.UpdateCampaignResponse
type GenericUpdateCampaignExecutorBulk ¶
type GenericUpdateCampaignExecutorBulk struct {
UpdateCampaignBulkInterface UpdateCampaignBulkInterface
}
var BulkUpdateCampaignExecutor *GenericUpdateCampaignExecutorBulk
func (*GenericUpdateCampaignExecutorBulk) OnError ¶
func (ge *GenericUpdateCampaignExecutorBulk) OnError(ctx context.Context, request *fs.BulkUpdateCampaignRequest, response *fs.BulkUpdateCampaignResponse, err error) *fs.BulkUpdateCampaignResponse
func (*GenericUpdateCampaignExecutorBulk) OnRequest ¶
func (ge *GenericUpdateCampaignExecutorBulk) OnRequest(ctx context.Context, request *fs.BulkUpdateCampaignRequest) *fs.BulkUpdateCampaignResponse
func (*GenericUpdateCampaignExecutorBulk) OnResponse ¶
func (ge *GenericUpdateCampaignExecutorBulk) OnResponse(ctx context.Context, request *fs.BulkUpdateCampaignRequest, response *fs.BulkUpdateCampaignResponse) *fs.BulkUpdateCampaignResponse
type GenericUserJourneyCampaignExecutor ¶
type GenericUserJourneyCampaignExecutor struct {
UserJourneyCampaignInterface UserJourneyCampaignInterface
}
var UserJourneyCampaignExecutor *GenericUserJourneyCampaignExecutor
func (*GenericUserJourneyCampaignExecutor) OnData ¶
func (ge *GenericUserJourneyCampaignExecutor) OnData(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse) *fs.UserJourneyCampaignResponse
func (*GenericUserJourneyCampaignExecutor) OnError ¶
func (ge *GenericUserJourneyCampaignExecutor) OnError(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse, err error) *fs.UserJourneyCampaignResponse
func (*GenericUserJourneyCampaignExecutor) OnRequest ¶
func (ge *GenericUserJourneyCampaignExecutor) OnRequest(ctx context.Context, request *fs.UserJourneyCampaignRequest) *fs.UserJourneyCampaignResponse
func (*GenericUserJourneyCampaignExecutor) OnResponse ¶
func (ge *GenericUserJourneyCampaignExecutor) OnResponse(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse) *fs.UserJourneyCampaignResponse
type GetDynamicDataByKeyController ¶
type GetDynamicDataByKeyController struct { }
func (*GetDynamicDataByKeyController) OnData ¶
func (rc *GetDynamicDataByKeyController) OnData(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse) *fs.GetDynamicDataByKeyResponse
func (*GetDynamicDataByKeyController) OnError ¶
func (rc *GetDynamicDataByKeyController) OnError(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse, err error) *fs.GetDynamicDataByKeyResponse
func (*GetDynamicDataByKeyController) OnRequest ¶
func (rc *GetDynamicDataByKeyController) OnRequest(ctx context.Context, request *fs.GetDynamicDataByKeyRequest) *fs.GetDynamicDataByKeyResponse
func (*GetDynamicDataByKeyController) OnResponse ¶
func (rc *GetDynamicDataByKeyController) OnResponse(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse) *fs.GetDynamicDataByKeyResponse
type GetDynamicDataByKeyInterface ¶
type GetDynamicDataByKeyInterface interface { OnRequest(ctx context.Context, request *fs.GetDynamicDataByKeyRequest) *fs.GetDynamicDataByKeyResponse OnData(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse) *fs.GetDynamicDataByKeyResponse OnError(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse, err error) *fs.GetDynamicDataByKeyResponse OnResponse(ctx context.Context, request *fs.GetDynamicDataByKeyRequest, response *fs.GetDynamicDataByKeyResponse) *fs.GetDynamicDataByKeyResponse }
type ScheduleUserJourneyCampaignController ¶
type ScheduleUserJourneyCampaignController struct { }
func (*ScheduleUserJourneyCampaignController) OnData ¶
func (rc *ScheduleUserJourneyCampaignController) OnData(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse) *fs.ScheduleUserJourneyCampaignResponse
func (*ScheduleUserJourneyCampaignController) OnError ¶
func (rc *ScheduleUserJourneyCampaignController) OnError(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse, err error) *fs.ScheduleUserJourneyCampaignResponse
func (*ScheduleUserJourneyCampaignController) OnRequest ¶
func (rc *ScheduleUserJourneyCampaignController) OnRequest(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest) *fs.ScheduleUserJourneyCampaignResponse
func (*ScheduleUserJourneyCampaignController) OnResponse ¶
func (rc *ScheduleUserJourneyCampaignController) OnResponse(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse) *fs.ScheduleUserJourneyCampaignResponse
type ScheduleUserJourneyCampaignInterface ¶
type ScheduleUserJourneyCampaignInterface interface { OnRequest(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest) *fs.ScheduleUserJourneyCampaignResponse OnData(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse) *fs.ScheduleUserJourneyCampaignResponse OnError(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse, err error) *fs.ScheduleUserJourneyCampaignResponse OnResponse(ctx context.Context, request *fs.ScheduleUserJourneyCampaignRequest, response *fs.ScheduleUserJourneyCampaignResponse) *fs.ScheduleUserJourneyCampaignResponse }
type TestCampaignByIdController ¶
type TestCampaignByIdController struct { }
func (*TestCampaignByIdController) OnError ¶
func (rc *TestCampaignByIdController) OnError(ctx context.Context, request *fs.TestCampaignByIdRequest, response *fs.TestCampaignByIdResponse, err error) *fs.TestCampaignByIdResponse
func (*TestCampaignByIdController) OnRequest ¶
func (rc *TestCampaignByIdController) OnRequest(ctx context.Context, request *fs.TestCampaignByIdRequest) *fs.TestCampaignByIdResponse
func (*TestCampaignByIdController) OnResponse ¶
func (rc *TestCampaignByIdController) OnResponse(ctx context.Context, request *fs.TestCampaignByIdRequest, response *fs.TestCampaignByIdResponse) *fs.TestCampaignByIdResponse
type TestCampaignByIdInterface ¶
type TestCampaignByIdInterface interface { OnRequest(ctx context.Context, request *fs.TestCampaignByIdRequest) *fs.TestCampaignByIdResponse OnError(ctx context.Context, request *fs.TestCampaignByIdRequest, response *fs.TestCampaignByIdResponse, err error) *fs.TestCampaignByIdResponse OnResponse(ctx context.Context, request *fs.TestCampaignByIdRequest, response *fs.TestCampaignByIdResponse) *fs.TestCampaignByIdResponse }
type TestNewCampaignController ¶
type TestNewCampaignController struct { }
func (*TestNewCampaignController) OnError ¶
func (rc *TestNewCampaignController) OnError(ctx context.Context, request *fs.TestNewCampaignRequest, response *fs.TestNewCampaignResponse, err error) *fs.TestNewCampaignResponse
func (*TestNewCampaignController) OnRequest ¶
func (rc *TestNewCampaignController) OnRequest(ctx context.Context, request *fs.TestNewCampaignRequest) *fs.TestNewCampaignResponse
func (*TestNewCampaignController) OnResponse ¶
func (rc *TestNewCampaignController) OnResponse(ctx context.Context, request *fs.TestNewCampaignRequest, response *fs.TestNewCampaignResponse) *fs.TestNewCampaignResponse
type TestNewCampaignInterface ¶
type TestNewCampaignInterface interface { OnRequest(ctx context.Context, request *fs.TestNewCampaignRequest) *fs.TestNewCampaignResponse OnError(ctx context.Context, request *fs.TestNewCampaignRequest, response *fs.TestNewCampaignResponse, err error) *fs.TestNewCampaignResponse OnResponse(ctx context.Context, request *fs.TestNewCampaignRequest, response *fs.TestNewCampaignResponse) *fs.TestNewCampaignResponse }
type UpdateCampaignBulkInterface ¶
type UpdateCampaignBulkInterface interface { OnRequest(ctx context.Context, request *fs.BulkUpdateCampaignRequest) *fs.BulkUpdateCampaignResponse OnError(ctx context.Context, request *fs.BulkUpdateCampaignRequest, response *fs.BulkUpdateCampaignResponse, err error) *fs.BulkUpdateCampaignResponse OnResponse(ctx context.Context, request *fs.BulkUpdateCampaignRequest, response *fs.BulkUpdateCampaignResponse) *fs.BulkUpdateCampaignResponse }
type UpdateCampaignController ¶
type UpdateCampaignController struct { }
func (*UpdateCampaignController) OnError ¶
func (rc *UpdateCampaignController) OnError(ctx context.Context, request *fs.UpdateCampaignRequest, response *fs.UpdateCampaignResponse, err error) *fs.UpdateCampaignResponse
func (*UpdateCampaignController) OnRequest ¶
func (rc *UpdateCampaignController) OnRequest(ctx context.Context, request *fs.UpdateCampaignRequest) *fs.UpdateCampaignResponse
func (*UpdateCampaignController) OnResponse ¶
func (rc *UpdateCampaignController) OnResponse(ctx context.Context, request *fs.UpdateCampaignRequest, response *fs.UpdateCampaignResponse) *fs.UpdateCampaignResponse
type UpdateCampaignInterface ¶
type UpdateCampaignInterface interface { OnRequest(ctx context.Context, request *fs.UpdateCampaignRequest) *fs.UpdateCampaignResponse OnError(ctx context.Context, request *fs.UpdateCampaignRequest, response *fs.UpdateCampaignResponse, err error) *fs.UpdateCampaignResponse OnResponse(ctx context.Context, request *fs.UpdateCampaignRequest, response *fs.UpdateCampaignResponse) *fs.UpdateCampaignResponse }
type UpdateCampaignVO ¶
type UpdateCampaignVO struct { CronExpression sql.NullString Status sql.NullString Attributes sql.NullString CampaignID sql.NullInt64 }
type UserDetail ¶
type UserJourneyCampaignController ¶
type UserJourneyCampaignController struct { }
func (*UserJourneyCampaignController) OnData ¶
func (rc *UserJourneyCampaignController) OnData(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse) *fs.UserJourneyCampaignResponse
func (*UserJourneyCampaignController) OnError ¶
func (rc *UserJourneyCampaignController) OnError(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse, err error) *fs.UserJourneyCampaignResponse
func (*UserJourneyCampaignController) OnRequest ¶
func (rc *UserJourneyCampaignController) OnRequest(ctx context.Context, request *fs.UserJourneyCampaignRequest) *fs.UserJourneyCampaignResponse
func (*UserJourneyCampaignController) OnResponse ¶
func (rc *UserJourneyCampaignController) OnResponse(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse) *fs.UserJourneyCampaignResponse
type UserJourneyCampaignInterface ¶
type UserJourneyCampaignInterface interface { OnRequest(ctx context.Context, request *fs.UserJourneyCampaignRequest) *fs.UserJourneyCampaignResponse OnData(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse) *fs.UserJourneyCampaignResponse OnError(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse, err error) *fs.UserJourneyCampaignResponse OnResponse(ctx context.Context, request *fs.UserJourneyCampaignRequest, response *fs.UserJourneyCampaignResponse) *fs.UserJourneyCampaignResponse }
Source Files ¶
- AddCampaign.go
- AddCampaignTemplate.go
- AddDynamicData.go
- AddInactionTargetUser.go
- AddNewCampaign.go
- AddQueryCampaign.go
- AddTargetUser.go
- AthenaQuery.go
- Campaign.go
- Constants.go
- ControlGroup.go
- FilterCampaign.go
- FilterUserJourneyCampaigns.go
- FindCampaignById.go
- FindCampaignTemplateById.go
- FindInactionTargetUserByCampaignId.go
- FindQueryCampaign.go
- FindTargetUserById.go
- FindUserJourneyCampaignById.go
- GetDynamicDataByKey.go
- GetDynamicMediaByCampaignId.go
- ScheduleUserJourneyCampaign.go
- TestCampaignById.go
- TestNewCampaign.go
- UpdateCampaign.go
- UserJourneyCampaign.go
- helper.go
- hook.go
- mappers.go
- models.go
- producer.go
Click to show internal directories.
Click to hide internal directories.