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) TrackTxError(tp *TxTracker)
  • func (t *TrackerPublisher) TrackUserCW(tp *TrackerPayload)
  • func (t *TrackerPublisher) TrackUserSearch(tp *TrackerPayload)
• type TxTracker

Variables

var CWType string = "tracker.user.cw"

var SearchType string = "tracker.user.search"

var TxType string = "tracker.tx.error"

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,omitempty" json:"bid,omitempty"`
	Type                string    `bson:"type,omitempty" json:"type,omitempty"`
	Phone               string    `bson:"phone,omitempty" json:"phone,omitempty"`
	Name                string    `bson:"name,omitempty" json:"name,omitempty"`
	Email               string    `bson:"email,omitempty" json:"email,omitempty"`
	UtmSource           string    `bson:"utm_source,omitempty" json:"utm_source,omitempty"`
	UtmMedium           string    `bson:"utm_medium,omitempty" json:"utm_medium,omitempty"`
	UtmCampaignId       string    `bson:"utm_campaign_id,omitempty" json:"utm_campaign_id,omitempty"`
	UtmCampaignName     string    `bson:"utm_campaign_name,omitempty" json:"utm_campaign_name,omitempty"`
	Lat                 float64   `bson:"lat,omitempty" json:"lat,omitempty"`
	Lng                 float64   `bson:"lng,omitempty" json:"lng,omitempty"`
	FloorNumber         int32     `bson:"floorNumber,omitempty" json:"floorNumber,omitempty"`
	PricePerSqFt        int32     `bson:"pricePerSqFt,omitempty" json:"pricePerSqFt,omitempty"`
	AreaInSqft          int32     `bson:"areaInSqft,omitempty" json:"areaInSqft,omitempty"`
	ClicworthPrice      int32     `bson:"clicworthPrice,omitempty" json:"clicworthPrice,omitempty"`
	LowClicworthPrice   int32     `bson:"lowClicworthPrice,omitempty" json:"lowClicworthPrice,omitempty"`
	HighClicworthPrice  int32     `bson:"highClicworthPrice,omitempty" json:"highClicworthPrice,omitempty"`
	ConfidenceLevel     string    `bson:"confidenceLevel,omitempty" json:"confidenceLevel,omitempty"`
	IsGoogleSearch      bool      `bson:"isGoogleSearch,omitempty" json:"isGoogleSearch,omitempty"`
	CBProjectId         string    `bson:"cbprojectid,omitempty" json:"cbprojectid,omitempty"`
	Address             string    `bson:"address,omitempty" json:"address,omitempty"`
	IpAddress           string    `bson:"ip_address,omitempty" json:"ip_address,omitempty"`
	City                string    `bson:"city,omitempty" json:"city,omitempty"`
	CbSearchListSize    string    `bson:"cb_search_list_size,omitempty" json:"cb_search_list_size,omitempty"`
	GoSearchListSize    string    `bson:"go_search_list_size,omitempty" json:"go_search_list_size,omitempty"`
	TotalSearchListSize string    `bson:"total_search_list_size,omitempty" json:"total_search_list_size,omitempty"`
	UpdatedAt           int64     `bson:"updated_at,omitempty" json:"updated_at,omitempty"`
	CreatedAt           time.Time `bson:"created_at,omitempty" json:"created_at,omitempty"`
}

type TrackerPayload

type TrackerPayload struct {
	Bid                 string  `json:"bid,omitempty"`
	Type                string  `json:"type,omitempty"`
	Phone               string  `json:"phone,omitempty"`
	Name                string  `json:"name,omitempty"`
	Email               string  `json:"email,omitempty"`
	UtmSource           string  `json:"utm_source,omitempty"`
	UtmMedium           string  `json:"utm_medium,omitempty"`
	UtmCampaignId       string  `json:"utm_campaign_id,omitempty"`
	UtmCampaignName     string  `json:"utm_campaign_name,omitempty"`
	Lat                 float64 `json:"lat,omitempty"`
	Lng                 float64 `json:"lng,omitempty"`
	FloorNumber         int32   `json:"floorNumber,omitempty"`
	PricePerSqFt        int32   `json:"pricePerSqFt,omitempty"`
	AreaInSqft          int32   `json:"areaInSqft,omitempty"`
	Address             string  `json:"address,omitempty"`
	IpAddress           string  `json:"ipAddress,omitempty"`
	City                string  `json:"city,omitempty"`
	CbSearchListSize    string  `json:"cb_search_list_size,omitempty"`
	GoSearchListSize    string  `json:"go_search_list_size,omitempty"`
	TotalSearchListSize string  `json:"total_search_list_size,omitempty"`
	ClicworthPrice      int32   `json:"clicworthPrice,omitempty"`
	LowClicworthPrice   int32   `json:"lowClicworthPrice,omitempty"`
	HighClicworthPrice  int32   `json:"highClicworthPrice,omitempty"`
	ConfidenceLevel     string  `json:"confidenceLevel,omitempty"`
	IsGoogleSearch      bool    `json:"isGoogleSearch,omitempty"`
	CBProjectId         string  `json:"cbprojectid,omitempty"`
}

type TrackerPublisher

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

func (*TrackerPublisher) SetAMQPConnection

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

func (*TrackerPublisher) TrackTxError

func (t *TrackerPublisher) TrackTxError(tp *TxTracker)

func (*TrackerPublisher) TrackUserCW

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

func (*TrackerPublisher) TrackUserSearch

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

type TxTracker

type TxTracker struct {
	IP                       string   `bson:"ip,omitempty" json:"ip,omitempty"`
	BID                      string   `bson:"bid,omitempty" json:"bid,omitempty"`
	UserId                   string   `bson:"userid,omitempty" json:"userid,omitempty"`
	UserTodayTxFetchCount    int32    `bson:"usertodaytxfetchcount,omitempty" json:"usertodaytxfetchcount,omitempty"`
	UserTotalTxFetchCount    int32    `bson:"usertotaltxfetchcount,omitempty" json:"usertotaltxfetchcount,omitempty"`
	IPTodayTxFetchCount      int32    `bson:"iptodaytxfetchcount,omitempty" json:"iptodaytxfetchcount,omitempty"`
	IPTotalTxFetchCount      int32    `bson:"iptotaltxfetchcount,omitempty" json:"iptotaltxfetchcount,omitempty"`
	UserDayLimitReached      bool     `bson:"userdaylimitreached,omitempty" json:"userdaylimitreached,omitempty"`
	UserDayLimitReachedDate  int64    `bson:"userdaylimitreacheddate,omitempty" json:"userdaylimitreacheddate,omitempty"`
	IPDayLimitReached        bool     `bson:"ipdaylimitreached,omitempty" json:"ipdaylimitreached,omitempty"`
	IPDayLimitReachedDate    [3]int64 `bson:"ipdaylimitreacheddate,omitempty" json:"ipdaylimitreacheddate,omitempty"`
	UserBlocked              bool     `bson:"userblocked,omitempty" json:"userblocked,omitempty"`
	IPBlocked                bool     `bson:"ipblocked,omitempty" json:"ipblocked,omitempty"`
	UpdatedAt                int64    `bson:"updated_at,omitempty" json:"updated_at,omitempty"`
	CreatedAt                int64    `bson:"created_at,omitempty" json:"created_at,omitempty"`
	UserBlockedAt            int64    `bson:"userblocked_at,omitempty" json:"userblocked_at,omitempty"`
	IPBlockedAt              int64    `bson:"ipblocked_at,omitempty" json:"ipblocked_at,omitempty"`
	Remarks                  string   `bson:"remarks,omitempty" json:"remarks,omitempty"`
	IPTodayAddressFetchCount int32    `bson:"iptodayaddressfetchcount,omitempty" json:"iptodayaddressfetchcount,omitempty"`
}