tracker

Documentation

Index

• Variables
• type TrackerConsumer
  • func NewConsumer(conn *amqp.Connection, mongo *mongo.Client) (TrackerConsumer, error)
  • func (consumer *TrackerConsumer) Listen() error
• type TrackerEntry
• type TrackerPayload
• type TrackerPublisher
  • func (t *TrackerPublisher) SetAMQPConnection(connection *amqp.Connection)
  • func (t *TrackerPublisher) TrackUserCW(tp *TrackerPayload)
  • func (t *TrackerPublisher) TrackUserSearch(tp *TrackerPayload)

Variables

var CWType string = "tracker.user.cw"

var SearchType string = "tracker.user.search"

Types

type TrackerConsumer

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

func NewConsumer

func NewConsumer(conn *amqp.Connection, mongo *mongo.Client) (TrackerConsumer, error)

func (*TrackerConsumer) Listen

func (consumer *TrackerConsumer) Listen() error

type TrackerEntry

type TrackerEntry struct {
	ID                  string    `bson:"_id,omitempty" json:"id,omitempty"`
	Bid                 string    `bson:"bid" json:"bid"`
	Type                string    `bson:"type" json:"type"`
	Phone               string    `bson:"phone" json:"phone"`
	Name                string    `bson:"name" json:"name"`
	Email               string    `bson:"email" json:"email"`
	UtmSource           string    `bson:"utm_source" json:"utm_source"`
	UtmMedium           string    `bson:"utm_medium" json:"utm_medium"`
	UtmCampaignId       string    `bson:"utm_campaign_id" json:"utm_campaign_id"`
	UtmCampaignName     string    `bson:"utm_campaign_name" json:"utm_campaign_name"`
	Lat                 float64   `bson:"lat,omitempty" json:"lat,omitempty"`
	Lng                 float64   `bson:"lng,omitempty" json:"lng,omitempty"`
	FloorNumber         int32     `bson:"floorNumber,omitempty" json:"floorNumber,omitempty"`
	TotalPrice          int32     `bson:"totalPrice,omitempty" json:"totalPrice,omitempty"`
	PricePerSqFt        int32     `bson:"pricePerSqFt,omitempty" json:"pricePerSqFt,omitempty"`
	AreaInSqft          int32     `bson:"areaInSqft,omitempty" json:"areaInSqft,omitempty"`
	Address             string    `bson:"address" json:"address"`
	IpAddress           string    `bson:"ip_address" json:"ip_address"`
	City                string    `bson:"city" json:"city"`
	CbSearchListSize    string    `bson:"cb_search_list_size" json:"cb_search_list_size"`
	GoSearchListSize    string    `bson:"go_search_list_size" json:"go_search_list_size"`
	TotalSearchListSize string    `bson:"total_search_list_size" json:"total_search_list_size"`
	UpdatedAt           int64     `bson:"updated_at" json:"updated_at"`
	CreatedAt           time.Time `bson:"created_at" json:"created_at"`
}

type TrackerPayload

type TrackerPayload struct {
	Bid                 string  `json:"bid"`
	Type                string  `json:"type"`
	Phone               string  `json:"phone"`
	Name                string  `json:"name"`
	Email               string  `json:"email"`
	UtmSource           string  `json:"utm_source"`
	UtmMedium           string  `json:"utm_medium"`
	UtmCampaignId       string  `json:"utm_campaign_id"`
	UtmCampaignName     string  `json:"utm_campaign_name"`
	Lat                 float64 `json:"lat,omitempty"`
	Lng                 float64 `json:"lng,omitempty"`
	FloorNumber         int32   `json:"floorNumber,omitempty"`
	TotalPrice          int32   `json:"totalPrice,omitempty"`
	PricePerSqFt        int32   `json:"pricePerSqFt,omitempty"`
	AreaInSqft          int32   `json:"areaInSqft,omitempty"`
	Address             string  `json:"address"`
	IpAddress           string  `json:"ipAddress"`
	City                string  `json:"city"`
	CbSearchListSize    string  `json:"cb_search_list_size"`
	GoSearchListSize    string  `json:"go_search_list_size"`
	TotalSearchListSize string  `json:"total_search_list_size"`
}

type TrackerPublisher

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

func (*TrackerPublisher) SetAMQPConnection

func (t *TrackerPublisher) SetAMQPConnection(connection *amqp.Connection)

func (*TrackerPublisher) TrackUserCW

func (t *TrackerPublisher) TrackUserCW(tp *TrackerPayload)

func (*TrackerPublisher) TrackUserSearch

func (t *TrackerPublisher) TrackUserSearch(tp *TrackerPayload)