hook

package
v0.0.1 Latest Latest
Warning

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

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

Documentation

Index

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 FindNextEngagementVerticesArgs

func FindNextEngagementVerticesArgs(campaignId int64, engagementVertexId int64) []interface{}

func FindPreviousEngagementVertexArgs

func FindPreviousEngagementVertexArgs(campaignId int64, engagementVertexId int64) []interface{}

func FindUserJourneyCampaignByIdArgs

func FindUserJourneyCampaignByIdArgs(request *fs.FindUserJourneyCampaignByIdRequest) []interface{}

func FindUserJourneyCampaignEdgesByIdArgs

func FindUserJourneyCampaignEdgesByIdArgs(request *fs.FindUserJourneyCampaignByIdRequest, vertexType string) []interface{}

func GenerateRandomUserIds

func GenerateRandomUserIds(userIds []int64, controlGroupPercentage int32) []int64

func GetActorTypeUsingNamespace

func GetActorTypeUsingNamespace(namespace common.NameSpace) int32

func GetCampaignQueryType

func GetCampaignQueryType(ctx context.Context, campaignId int64) (common.CampaignQueryType, error)

func GetImageMetaData

func GetImageMetaData(languageCode common.LanguageCode, imageMap map[common.LanguageCode]string) string

func GetInQueryWithValues

func GetInQueryWithValues(arr []int64, query string) string

func GetIndexInRow

func GetIndexInRow(row []string, fieldName string) int

func GetIndexOfId

func GetIndexOfId(rowData []string) int

func GetInt64Value

func GetInt64Value(index int, arr []string) int64

func GetPlaceholderData

func GetPlaceholderData(val []string, indexFieldMap map[int64]string) []*ce.Placeholder

func GetPlaceholderIndexFieldMap

func GetPlaceholderIndexFieldMap(val []string) map[int64]string

func GetStartEngagementVertex

func GetStartEngagementVertex(ctx context.Context, campaignId int64) (int64, error)

func GetStringValue

func GetStringValue(index int, arr []string) string

func GetUserFilterQueries

func GetUserFilterQueries(namespace string, response *fs.FindCampaignByIdResponse) []string

func GetUserJourneyTargetUsersArgs

func GetUserJourneyTargetUsersArgs(campaignId int64, engagementsVertexId int64, referenceId string) []interface{}

func GetUserJourneyWorkflowId

func GetUserJourneyWorkflowId(campaignId int64, engagementVertexId int64) string

func GetUserJourneyWorkflowParentReferenceId

func GetUserJourneyWorkflowParentReferenceId(campaignId int64, engagementVertexId int64) string

func GetWaitDuration

func GetWaitDuration(ctx context.Context, waitDuration int64, waitTime time.Time, waitType string) time.Duration

func GetWorkflowId

func GetWorkflowId(campaignId int64) string

func IsPresent

func IsPresent(bloomFilter *bloom.BloomFilter, userId int64) bool

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 OutputQueryLog

func OutputQueryLog(log string, logLevel string, error error, query string)

func PostStartUpHook

func PostStartUpHook()

func PreStartUpHook

func PreStartUpHook()

func UpdateCampaignArgs

func UpdateCampaignArgs(model *UpdateCampaignVO) []interface{}

Types

type AddCampaignController

type AddCampaignController struct {
}

func (*AddCampaignController) OnError

func (*AddCampaignController) OnRequest

func (*AddCampaignController) OnResponse

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 AddCampaignTemplateController

type AddCampaignTemplateController struct {
}

func (*AddCampaignTemplateController) OnError

func (*AddCampaignTemplateController) OnRequest

func (*AddCampaignTemplateController) OnResponse

type AddDynamicDataController

type AddDynamicDataController struct {
}

func (*AddDynamicDataController) OnError

func (*AddDynamicDataController) OnRequest

func (*AddDynamicDataController) OnResponse

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 AddEdgeVO

type AddEdgeVO struct {
	CampaignId            sql.NullInt64
	VertexType            sql.NullString
	FromVertexId          sql.NullInt64
	ToVertexId            sql.NullInt64
	WaitDuration          sql.NullInt64
	WaitTime              sql.NullTime
	WaitType              sql.NullString
	MessageDeliveryStates sql.NullString
}

type AddEngagementVertexVO

type AddEngagementVertexVO struct {
	CampaignId   sql.NullInt64
	TemplateName sql.NullString
	Attributes   sql.NullString
	AthenaQuery  sql.NullString
	Channel      sql.NullString
}

type AddInactionTargetUserController

type AddInactionTargetUserController struct {
}

func (*AddInactionTargetUserController) OnError

func (*AddInactionTargetUserController) OnRequest

func (*AddInactionTargetUserController) OnResponse

type AddNewCampaignController

type AddNewCampaignController struct {
}

func (*AddNewCampaignController) OnError

func (*AddNewCampaignController) OnRequest

func (*AddNewCampaignController) OnResponse

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 AddQueryCampaignController

type AddQueryCampaignController struct {
}

func (*AddQueryCampaignController) OnError

func (*AddQueryCampaignController) OnRequest

func (*AddQueryCampaignController) OnResponse

type AddTargetUserController

type AddTargetUserController struct {
}

func (*AddTargetUserController) OnError

func (*AddTargetUserController) OnRequest

func (*AddTargetUserController) OnResponse

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 (*AthenaQueryController) OnRequest

func (*AthenaQueryController) OnResponse

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 (*BulkAddCampaignController) OnRequest

func (*BulkAddCampaignController) OnResponse

type BulkAddCampaignTemplateController

type BulkAddCampaignTemplateController struct {
}

func (*BulkAddCampaignTemplateController) OnError

func (*BulkAddCampaignTemplateController) OnRequest

type BulkAddDynamicDataController

type BulkAddDynamicDataController struct {
}

func (*BulkAddDynamicDataController) OnError

func (*BulkAddDynamicDataController) OnRequest

func (*BulkAddDynamicDataController) OnResponse

type BulkAddInactionTargetUserController

type BulkAddInactionTargetUserController struct {
}

func (*BulkAddInactionTargetUserController) OnRequest

type BulkAddNewCampaignController

type BulkAddNewCampaignController struct {
}

func (*BulkAddNewCampaignController) OnError

func (*BulkAddNewCampaignController) OnRequest

func (*BulkAddNewCampaignController) OnResponse

type BulkAddQueryCampaignController

type BulkAddQueryCampaignController struct {
}

func (*BulkAddQueryCampaignController) OnError

func (*BulkAddQueryCampaignController) OnRequest

func (*BulkAddQueryCampaignController) OnResponse

type BulkAddTargetUserController

type BulkAddTargetUserController struct {
}

func (*BulkAddTargetUserController) OnError

func (*BulkAddTargetUserController) OnRequest

func (*BulkAddTargetUserController) OnResponse

type BulkUpdateCampaignController

type BulkUpdateCampaignController struct {
}

func (*BulkUpdateCampaignController) OnError

func (*BulkUpdateCampaignController) OnRequest

func (*BulkUpdateCampaignController) OnResponse

type CampaignController

type CampaignController struct {
}

func (*CampaignController) OnData

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

type DeleteEngagementVerticesVO struct {
	CampaignId sql.NullInt64
}

func MakeDeleteEngagementVerticesVO

func MakeDeleteEngagementVerticesVO(campaignId int64) *DeleteEngagementVerticesVO

type DeleteUserJourneyVerticesVO

type DeleteUserJourneyVerticesVO struct {
	CampaignId sql.NullInt64
}

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 (*FilterCampaignController) OnRequest

func (*FilterCampaignController) OnResponse

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) OnRequest

type FindCampaignByIdController

type FindCampaignByIdController struct {
}

func (*FindCampaignByIdController) OnData

func (*FindCampaignByIdController) OnError

func (*FindCampaignByIdController) OnRequest

func (*FindCampaignByIdController) OnResponse

type FindCampaignTemplateByIdController

type FindCampaignTemplateByIdController struct {
}

func (*FindCampaignTemplateByIdController) OnRequest

type FindEdgesVO

type FindEdgesVO struct {
	Id                    sql.NullInt64
	CampaignId            sql.NullInt64
	VertexType            sql.NullString
	FromVertexId          sql.NullInt64
	ToVertexId            sql.NullInt64
	WaitDuration          sql.NullInt64
	WaitTime              sql.NullTime
	WaitType              sql.NullString
	MessageDeliveryStates sql.NullString
	BaseVO                BaseVO
}

type FindEngagementStartVertexVO

type FindEngagementStartVertexVO struct {
	ID sql.NullInt64
}

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 FindNextEngagementVertexVO

type FindNextEngagementVertexVO struct {
	Id                    sql.NullInt64
	MessageDeliveryStates sql.NullString
	WaitDuration          sql.NullInt64
	WaitTime              sql.NullTime
	WaitType              sql.NullString
}

func GetNextEngagementVertices

func GetNextEngagementVertices(ctx context.Context, campaignId int64, engagementVertexId int64) ([]FindNextEngagementVertexVO, error)

type FindPreviousEngagementVertexVO

type FindPreviousEngagementVertexVO struct {
	Id                    sql.NullInt64
	MessageDeliveryStates sql.NullString
}

type FindQueryCampaignController

type FindQueryCampaignController struct {
}

func (*FindQueryCampaignController) OnData

func (*FindQueryCampaignController) OnError

func (*FindQueryCampaignController) OnRequest

func (*FindQueryCampaignController) OnResponse

type FindTargetUserByIdController

type FindTargetUserByIdController struct {
}

func (*FindTargetUserByIdController) OnData

func (*FindTargetUserByIdController) OnError

func (*FindTargetUserByIdController) OnRequest

func (*FindTargetUserByIdController) OnResponse

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) OnRequest

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 (*GenericAddCampaignExecutor) OnRequest

func (*GenericAddCampaignExecutor) OnResponse

type GenericAddCampaignExecutorBulk

type GenericAddCampaignExecutorBulk struct {
	AddCampaignBulkInterface AddCampaignBulkInterface
}
var BulkAddCampaignExecutor *GenericAddCampaignExecutorBulk

func (*GenericAddCampaignExecutorBulk) OnError

func (*GenericAddCampaignExecutorBulk) OnRequest

func (*GenericAddCampaignExecutorBulk) OnResponse

type GenericAddCampaignTemplateExecutor

type GenericAddCampaignTemplateExecutor struct {
	AddCampaignTemplateInterface AddCampaignTemplateInterface
}
var AddCampaignTemplateExecutor *GenericAddCampaignTemplateExecutor

func (*GenericAddCampaignTemplateExecutor) OnError

func (*GenericAddCampaignTemplateExecutor) OnRequest

func (*GenericAddCampaignTemplateExecutor) OnResponse

type GenericAddCampaignTemplateExecutorBulk

type GenericAddCampaignTemplateExecutorBulk struct {
	AddCampaignTemplateBulkInterface AddCampaignTemplateBulkInterface
}
var BulkAddCampaignTemplateExecutor *GenericAddCampaignTemplateExecutorBulk

func (*GenericAddCampaignTemplateExecutorBulk) OnError

func (*GenericAddCampaignTemplateExecutorBulk) OnRequest

func (*GenericAddCampaignTemplateExecutorBulk) OnResponse

type GenericAddDynamicDataExecutor

type GenericAddDynamicDataExecutor struct {
	AddDynamicDataInterface AddDynamicDataInterface
}
var AddDynamicDataExecutor *GenericAddDynamicDataExecutor

func (*GenericAddDynamicDataExecutor) OnError

func (*GenericAddDynamicDataExecutor) OnRequest

func (*GenericAddDynamicDataExecutor) OnResponse

type GenericAddDynamicDataExecutorBulk

type GenericAddDynamicDataExecutorBulk struct {
	AddDynamicDataBulkInterface AddDynamicDataBulkInterface
}
var BulkAddDynamicDataExecutor *GenericAddDynamicDataExecutorBulk

func (*GenericAddDynamicDataExecutorBulk) OnError

func (*GenericAddDynamicDataExecutorBulk) OnRequest

func (*GenericAddDynamicDataExecutorBulk) OnResponse

type GenericAddInactionTargetUserExecutor

type GenericAddInactionTargetUserExecutor struct {
	AddInactionTargetUserInterface AddInactionTargetUserInterface
}
var AddInactionTargetUserExecutor *GenericAddInactionTargetUserExecutor

func (*GenericAddInactionTargetUserExecutor) OnError

func (*GenericAddInactionTargetUserExecutor) OnRequest

func (*GenericAddInactionTargetUserExecutor) OnResponse

type GenericAddInactionTargetUserExecutorBulk

type GenericAddInactionTargetUserExecutorBulk struct {
	AddInactionTargetUserBulkInterface AddInactionTargetUserBulkInterface
}
var BulkAddInactionTargetUserExecutor *GenericAddInactionTargetUserExecutorBulk

func (*GenericAddInactionTargetUserExecutorBulk) OnRequest

type GenericAddNewCampaignExecutor

type GenericAddNewCampaignExecutor struct {
	AddNewCampaignInterface AddNewCampaignInterface
}
var AddNewCampaignExecutor *GenericAddNewCampaignExecutor

func (*GenericAddNewCampaignExecutor) OnError

func (*GenericAddNewCampaignExecutor) OnRequest

func (*GenericAddNewCampaignExecutor) OnResponse

type GenericAddNewCampaignExecutorBulk

type GenericAddNewCampaignExecutorBulk struct {
	AddNewCampaignBulkInterface AddNewCampaignBulkInterface
}
var BulkAddNewCampaignExecutor *GenericAddNewCampaignExecutorBulk

func (*GenericAddNewCampaignExecutorBulk) OnError

func (*GenericAddNewCampaignExecutorBulk) OnRequest

func (*GenericAddNewCampaignExecutorBulk) OnResponse

type GenericAddQueryCampaignExecutor

type GenericAddQueryCampaignExecutor struct {
	AddQueryCampaignInterface AddQueryCampaignInterface
}
var AddQueryCampaignExecutor *GenericAddQueryCampaignExecutor

func (*GenericAddQueryCampaignExecutor) OnError

func (*GenericAddQueryCampaignExecutor) OnRequest

func (*GenericAddQueryCampaignExecutor) OnResponse

type GenericAddQueryCampaignExecutorBulk

type GenericAddQueryCampaignExecutorBulk struct {
	AddQueryCampaignBulkInterface AddQueryCampaignBulkInterface
}
var BulkAddQueryCampaignExecutor *GenericAddQueryCampaignExecutorBulk

func (*GenericAddQueryCampaignExecutorBulk) OnError

func (*GenericAddQueryCampaignExecutorBulk) OnRequest

func (*GenericAddQueryCampaignExecutorBulk) OnResponse

type GenericAddTargetUserExecutor

type GenericAddTargetUserExecutor struct {
	AddTargetUserInterface AddTargetUserInterface
}
var AddTargetUserExecutor *GenericAddTargetUserExecutor

func (*GenericAddTargetUserExecutor) OnError

func (*GenericAddTargetUserExecutor) OnRequest

func (*GenericAddTargetUserExecutor) OnResponse

type GenericAddTargetUserExecutorBulk

type GenericAddTargetUserExecutorBulk struct {
	AddTargetUserBulkInterface AddTargetUserBulkInterface
}
var BulkAddTargetUserExecutor *GenericAddTargetUserExecutorBulk

func (*GenericAddTargetUserExecutorBulk) OnError

func (*GenericAddTargetUserExecutorBulk) OnRequest

func (*GenericAddTargetUserExecutorBulk) OnResponse

type GenericAthenaQueryExecutor

type GenericAthenaQueryExecutor struct {
	AthenaQueryInterface AthenaQueryInterface
}
var AthenaQueryExecutor *GenericAthenaQueryExecutor

func (*GenericAthenaQueryExecutor) OnError

func (*GenericAthenaQueryExecutor) OnRequest

func (*GenericAthenaQueryExecutor) OnResponse

type GenericCampaignExecutor

type GenericCampaignExecutor struct {
	CampaignInterface CampaignInterface
}
var CampaignExecutor *GenericCampaignExecutor

func (*GenericCampaignExecutor) OnData

func (*GenericCampaignExecutor) OnError

func (*GenericCampaignExecutor) OnRequest

func (*GenericCampaignExecutor) OnResponse

type GenericFilterCampaignExecutor

type GenericFilterCampaignExecutor struct {
	FilterCampaignInterface FilterCampaignInterface
}
var FilterCampaignExecutor *GenericFilterCampaignExecutor

func (*GenericFilterCampaignExecutor) OnError

func (*GenericFilterCampaignExecutor) OnRequest

func (*GenericFilterCampaignExecutor) OnResponse

type GenericFilterUserJourneyCampaignExecutor

type GenericFilterUserJourneyCampaignExecutor struct {
	FilterUserJourneyCampaignInterface FilterUserJourneyCampaignInterface
}
var FilterUserJourneyCampaignExecutor *GenericFilterUserJourneyCampaignExecutor

func (*GenericFilterUserJourneyCampaignExecutor) OnRequest

type GenericFindCampaignByIdExecutor

type GenericFindCampaignByIdExecutor struct {
	FindCampaignByIdInterface FindCampaignByIdInterface
}
var FindCampaignByIdExecutor *GenericFindCampaignByIdExecutor

func (*GenericFindCampaignByIdExecutor) OnData

func (*GenericFindCampaignByIdExecutor) OnError

func (*GenericFindCampaignByIdExecutor) OnRequest

func (*GenericFindCampaignByIdExecutor) OnResponse

type GenericFindCampaignTemplateByIdExecutor

type GenericFindCampaignTemplateByIdExecutor struct {
	FindCampaignTemplateByIdInterface FindCampaignTemplateByIdInterface
}
var FindCampaignTemplateByIdExecutor *GenericFindCampaignTemplateByIdExecutor

func (*GenericFindCampaignTemplateByIdExecutor) OnError

func (*GenericFindCampaignTemplateByIdExecutor) OnRequest

type GenericFindInactionTargetUserByCampaignIdExecutor

type GenericFindInactionTargetUserByCampaignIdExecutor struct {
	FindInactionTargetUserByCampaignIdInterface FindInactionTargetUserByCampaignIdInterface
}
var FindInactionTargetUserByCampaignIdExecutor *GenericFindInactionTargetUserByCampaignIdExecutor

type GenericFindQueryCampaignExecutor

type GenericFindQueryCampaignExecutor struct {
	FindQueryCampaignInterface FindQueryCampaignInterface
}
var FindQueryCampaignExecutor *GenericFindQueryCampaignExecutor

func (*GenericFindQueryCampaignExecutor) OnData

func (*GenericFindQueryCampaignExecutor) OnError

func (*GenericFindQueryCampaignExecutor) OnRequest

func (*GenericFindQueryCampaignExecutor) OnResponse

type GenericFindTargetUserByIdExecutor

type GenericFindTargetUserByIdExecutor struct {
	FindTargetUserByIdInterface FindTargetUserByIdInterface
}
var FindTargetUserByIdExecutor *GenericFindTargetUserByIdExecutor

func (*GenericFindTargetUserByIdExecutor) OnData

func (*GenericFindTargetUserByIdExecutor) OnError

func (*GenericFindTargetUserByIdExecutor) OnRequest

func (*GenericFindTargetUserByIdExecutor) OnResponse

type GenericFindUserJourneyCampaignByIdExecutor

type GenericFindUserJourneyCampaignByIdExecutor struct {
	FindUserJourneyCampaignByIdInterface FindUserJourneyCampaignByIdInterface
}
var FindUserJourneyCampaignByIdExecutor *GenericFindUserJourneyCampaignByIdExecutor

func (*GenericFindUserJourneyCampaignByIdExecutor) OnRequest

type GenericGetDynamicDataByKeyExecutor

type GenericGetDynamicDataByKeyExecutor struct {
	GetDynamicDataByKeyInterface GetDynamicDataByKeyInterface
}
var GetDynamicDataByKeyExecutor *GenericGetDynamicDataByKeyExecutor

func (*GenericGetDynamicDataByKeyExecutor) OnData

func (*GenericGetDynamicDataByKeyExecutor) OnError

func (*GenericGetDynamicDataByKeyExecutor) OnRequest

func (*GenericGetDynamicDataByKeyExecutor) OnResponse

type GenericScheduleUserJourneyCampaignExecutor

type GenericScheduleUserJourneyCampaignExecutor struct {
	ScheduleUserJourneyCampaignInterface ScheduleUserJourneyCampaignInterface
}
var ScheduleUserJourneyCampaignExecutor *GenericScheduleUserJourneyCampaignExecutor

func (*GenericScheduleUserJourneyCampaignExecutor) OnRequest

type GenericTestCampaignByIdExecutor

type GenericTestCampaignByIdExecutor struct {
	TestCampaignByIdInterface TestCampaignByIdInterface
}
var TestCampaignByIdExecutor *GenericTestCampaignByIdExecutor

func (*GenericTestCampaignByIdExecutor) OnError

func (*GenericTestCampaignByIdExecutor) OnRequest

func (*GenericTestCampaignByIdExecutor) OnResponse

type GenericTestNewCampaignExecutor

type GenericTestNewCampaignExecutor struct {
	TestNewCampaignInterface TestNewCampaignInterface
}
var TestNewCampaignExecutor *GenericTestNewCampaignExecutor

func (*GenericTestNewCampaignExecutor) OnError

func (*GenericTestNewCampaignExecutor) OnRequest

func (*GenericTestNewCampaignExecutor) OnResponse

type GenericUpdateCampaignExecutor

type GenericUpdateCampaignExecutor struct {
	UpdateCampaignInterface UpdateCampaignInterface
}
var UpdateCampaignExecutor *GenericUpdateCampaignExecutor

func (*GenericUpdateCampaignExecutor) OnError

func (*GenericUpdateCampaignExecutor) OnRequest

func (*GenericUpdateCampaignExecutor) OnResponse

type GenericUpdateCampaignExecutorBulk

type GenericUpdateCampaignExecutorBulk struct {
	UpdateCampaignBulkInterface UpdateCampaignBulkInterface
}
var BulkUpdateCampaignExecutor *GenericUpdateCampaignExecutorBulk

func (*GenericUpdateCampaignExecutorBulk) OnError

func (*GenericUpdateCampaignExecutorBulk) OnRequest

func (*GenericUpdateCampaignExecutorBulk) OnResponse

type GenericUserJourneyCampaignExecutor

type GenericUserJourneyCampaignExecutor struct {
	UserJourneyCampaignInterface UserJourneyCampaignInterface
}
var UserJourneyCampaignExecutor *GenericUserJourneyCampaignExecutor

func (*GenericUserJourneyCampaignExecutor) OnData

func (*GenericUserJourneyCampaignExecutor) OnError

func (*GenericUserJourneyCampaignExecutor) OnRequest

func (*GenericUserJourneyCampaignExecutor) OnResponse

type GetDynamicDataByKeyController

type GetDynamicDataByKeyController struct {
}

func (*GetDynamicDataByKeyController) OnData

func (*GetDynamicDataByKeyController) OnError

func (*GetDynamicDataByKeyController) OnRequest

func (*GetDynamicDataByKeyController) OnResponse

type KvPairs

type KvPairs struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type ScheduleUserJourneyCampaignController

type ScheduleUserJourneyCampaignController struct {
}

func (*ScheduleUserJourneyCampaignController) OnRequest

type TestCampaignByIdController

type TestCampaignByIdController struct {
}

func (*TestCampaignByIdController) OnError

func (*TestCampaignByIdController) OnRequest

func (*TestCampaignByIdController) OnResponse

type TestNewCampaignController

type TestNewCampaignController struct {
}

func (*TestNewCampaignController) OnError

func (*TestNewCampaignController) OnRequest

func (*TestNewCampaignController) OnResponse

type UpdateCampaignController

type UpdateCampaignController struct {
}

func (*UpdateCampaignController) OnError

func (*UpdateCampaignController) OnRequest

func (*UpdateCampaignController) OnResponse

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 UserDetail struct {
	Id               int64
	LangKey          string
	MobileNumber     string
	Email            string
	PushToken        string
	ModifiedOn       int64
	AppId            string
	ActorType        string
	SecondaryLangKey string
	Location         string
}

type UserJourneyCampaignController

type UserJourneyCampaignController struct {
}

func (*UserJourneyCampaignController) OnData

func (*UserJourneyCampaignController) OnError

func (*UserJourneyCampaignController) OnRequest

func (*UserJourneyCampaignController) OnResponse

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL