Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

xd_rsync

package module

Go to main page

Versions in this module

v1

v1.5.0

Sep 5, 2024

Changes in this version

type XdProduct

+ StockLastEntrance *time.Time

+ StockLastExit *time.Time

v1.4.0

Aug 16, 2024

Changes in this version

type XdProduct

+ AvailableQuantity float64

+ SKU string

+ StockSyncStamp *time.Time

v1.3.0

Aug 10, 2024

Changes in this version

+ type MessagePublishInput struct

+ Message string

+ MessageGroupId string

v1.2.0

Aug 7, 2024

Changes in this version

+ type XdProductsChunksWithMutex struct

+ Chunks *map[int]XdProducts

+ func (c *XdProductsChunksWithMutex) GetList(list *XdProducts)

+ func (c *XdProductsChunksWithMutex) UpdateChunk(index int, productsList *XdProducts)

v1.1.0

Aug 6, 2024

Changes in this version

type Config

+ DatadogConfig *DatadogConfig

+ SyncFrequency time.Duration

+ type DatadogConfig struct

+ ApiKey *string

+ EventBaseFields *map[string]interface{}

+ IngestHost *string

v1.0.0

Aug 5, 2024

Changes in this version

+ var ErrProductJsonNotValid = fmt.Errorf("emitted product JSON is not valid")

+ type Config struct

+ AwsRegion string

+ CloseOnFinish bool

+ DSN string

+ Environment string

+ IsProductionMode bool

+ Queues *QueuesConfig

+ type DatabaseService interface

+ GetPaginatedPricedProducts func(ts *time.Time, limit int, offset int) (*XdProducts, error)

+ GetPricedProducts func() (*XdProducts, error)

+ GetPricedProductsCount func(ts *time.Time) (int, error)

+ GetPricedProductsSinceTimestamp func(ts *time.Time) (*XdProducts, error)

+ GetProductByReferece func(id string) (*XdProduct, error)

+ GetProductsByReferece func(ids []string) (*XdProducts, error)

+ type QueuesConfig struct

+ ProductUpdatesSnsQueueArn string

+ type SNSService interface

+ SendMessage func(topicArn string, message string) error

+ SendMessagesBatch func(topicArn string, messages []string) (int, []error)

+ type XdProduct struct

+ CurrentStock float64

+ Description string

+ KeyId string

+ RetailPrice1 float64

+ RetailPrice2 float64

+ RetailPrice3 float64

+ ShortName1 string

+ SyncStamp *time.Time

+ func (p *XdProduct) GetKnownColumns() []string

+ func (p *XdProduct) GetKnownColumnsQuerySelectors() string

+ func (p *XdProduct) GetPrimaryKeyColumnName() string

+ func (p *XdProduct) GetTableName() string

+ func (p *XdProduct) ToJSON() (string, error)

+ type XdProducts []XdProduct

+ func (ps *XdProducts) GetKnownColumnsQuerySelectors() string

+ func (ps *XdProducts) GetPrimaryKeyColumnName() string

+ func (ps *XdProducts) GetTableName() string

+ func (ps *XdProducts) ToJSON() (string, error)

+ type XdRsyncInstance struct

+ Config *Config

+ Logger *logger.Logger

+ Services *XdRsyncServices

+ type XdRsyncServices struct

+ Database DatabaseService

+ SNS SNSService