sync

Documentation

Index

• Constants
• func GetMigrationList() (ml *migration.List)
• func SyncUpsert(db *sql.Connection, itemID int, input []*model.SyncQueue) (err error)
• type Provider
• type Service
  • func NewService(p Provider) *Service
  • func (s *Service) Process(db *sql.Connection, serviceName string, maxGoRoutines int) (err error)

Constants

const (
	ECode060201 = e.Code0602 + "01"
	ECode060202 = e.Code0602 + "02"
	ECode060203 = e.Code0602 + "03"
)

const (
	MaxGoRoutinesAllowed    = 1000 // The maximum allowed number of go routines
	DefaultMaxNumGoRoutines = 25

	ECode060101 = e.Code0601 + "01"
	ECode060102 = e.Code0601 + "02"
	ECode060103 = e.Code0601 + "03"
	ECode060104 = e.Code0601 + "04"
	ECode060105 = e.Code0601 + "05"
	ECode060106 = e.Code0601 + "06"
)

const (
	MIGRATION_CODE = "sync"
)

Functions

func GetMigrationList

func GetMigrationList() (ml *migration.List)

GetMigrationList returns this packages migration list

func SyncUpsert

func SyncUpsert(db *sql.Connection, itemID int, input []*model.SyncQueue) (err error)

SyncUpsert performs the DB operation to upsert a record in the sync_queue

Types

type Provider

type Provider interface {
	GetSyncQueueObject(itemID int, syncItemType string) *model.SyncQueue
	HandleItemQueue(db *sql.Connection, item *model.SyncQueue) (err error)
	Send(db *sql.Connection, so *model.SyncQueue) (err error)
}

Provider interface for the sync services

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(p Provider) *Service

NewService returns an instance of a service provider

func (*Service) Process

func (s *Service) Process(db *sql.Connection, serviceName string,
	maxGoRoutines int) (err error)