Documentation
¶
Index ¶
- Variables
- func CallUpsertOrderTask(c context.Context, campaign *campaign.Campaign, order *order.Order)
- func CallUpsertUserTask(c context.Context, campaign *campaign.Campaign, user *user.User)
- func ImportMissingOrders(c *gin.Context)
- func ImportMissingUsers(c *gin.Context)
- func ImportOrders(c *gin.Context)
- func ImportProductVariant(c *gin.Context)
- func ImportUsers(c *gin.Context)
- func PopulateMissingUserSFIds(c *gin.Context)
Constants ¶
This section is empty.
Variables ¶
var ImportMissingOrdersTask = parallel.New("sf-import-missing-order-task", func(db *datastore.Datastore, order *order.Order, campaign campaign.Campaign) {
})
UpsertMissingOrderTask upserts orders not synchronized into salesforce
var ImportMissingUsersTask = parallel.New("sf-import-missing-user-task", func(db *datastore.Datastore, user *user.User, campaign campaign.Campaign) {
})
UpsertMissingUserTask upserts users not synchronized into salesforce
var ImportOrdersTask = parallel.New("sf-import-order-task", func(db *datastore.Datastore, order *order.Order, campaign campaign.Campaign) {
})
UpsertOrderTask upserts orders into salesforce
var ImportProductVariantsTask = parallel.New("sf-import-product-task", func(db *datastore.Datastore, variant *variant.Variant, campaign campaign.Campaign) {
})
UpsertOrderTask upserts users into salesforce
var ImportUsersTask = parallel.New("sf-import-user-task", func(db *datastore.Datastore, user *user.User, campaign *campaign.Campaign) {
})
UpsertUserTask upserts users into salesforce
var PopulateMissingUserSFIdsTask = parallel.New("sf-populate-user-ids", func(db *datastore.Datastore, usr *user.User, campaign campaign.Campaign) {
})
PopulateMissingUserSFIdsTask adds all missing salesforce ids for users
var PullUpdatedOrdersTask = delay.Func("SalesforcePullUpdatedOrderTask", func(c context.Context) {
})
PullUpdatedTask gets recently(20 minutes ago) updated Contact and upserts them as Orders
var PullUpdatedSinceCleanUpTask = delay.Func("SalesforcePullUpdatedSinceCleanUpTask", func(c context.Context) {
})
PullUpdatedTask gets recently(20 minutes ago) updated Contact and upserts them as Users
var PullUpdatedUsersTask = delay.Func("SalesforcePullUpdatedUsersTask", func(c context.Context) {
})
PullUpdatedTask gets recently(20 minutes ago) updated Contact and upserts them as Users
var UpsertOrderTask = delay.Func("SalesforceUpsertOrderTask", func(c context.Context, campaign *campaign.Campaign, order *order.Order) {
})
UpsertOrderTask upserts users into salesforce
var UpsertUserTask = delay.Func("SalesforceUpsertUserTask", func(c context.Context, campaign *campaign.Campaign, user *user.User) {
})
Deferred Tasks UpsertUserTask upserts a contact into salesforce
Functions ¶
func CallUpsertOrderTask ¶
CallUpsertOrderTask calls the task queue delay function with the passed in params
func CallUpsertUserTask ¶
Wrappers to deferred function calls for type sanity CallUpsertUserTask calls the task queue delay function with the passed in params Values are used instead of pointers since we envoke a RPC
func ImportMissingOrders ¶
ImportMissingOrders upserts all orders not synchronized into salesforce
func ImportMissingUsers ¶
ImportMissingUsers upserts all users not synchronized into salesforce
func ImportOrders ¶
ImportOrders upserts all orders into salesforce
func ImportProductVariant ¶
ImportOrders upserts all orders into salesforce
func PopulateMissingUserSFIds ¶
PopulateMissingUserSFIds ensures all users have salesforce ids
Types ¶
This section is empty.
Source Files