snowplow

Documentation

Index

• Constants
• type Dimension
• type Page
• type PagePingEvent
• type PageViewEvent
• type SnowplowEvent
• type SnowplowInput
  • func (i *SnowplowInput) EnvelopeBuilder(c *gin.Context, conf *config.Config, metadata *meta.CollectorMeta) []envelope.Envelope
  • func (i *SnowplowInput) Handler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc
  • func (i *SnowplowInput) Initialize(engine *gin.Engine, manifold *manifold.Manifold, conf *config.Config, ...) error
  • func (i *SnowplowInput) SquawkboxHandler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc
• type StructEvent
• type TransactionEvent
• type TransactionItemEvent

Constants

const (
	PAGE_PING               = "page_ping"
	PAGE_PING_SCHEMA        = "io.silverton/snowplow/page_ping/v1.0.json"
	PAGE_VIEW               = "page_view"
	PAGE_VIEW_SCHEMA        = "io.silverton/snowplow/page_view/v1.0.json"
	STRUCT_EVENT            = "struct_event"
	STRUCT_EVENT_SCHEMA     = "io.silverton/snowplow/struct/v1.0.json"
	TRANSACTION             = "transaction"
	TRANSACTION_SCHEMA      = "io.silverton/snowplow/transaction/v1.0.json"
	TRANSACTION_ITEM        = "transaction_item"
	TRANSACTION_ITEM_SCHEMA = "io.silverton/snowplow/transaction_item/v1.0.json"
	AD_IMPRESSION           = "ad_impression" // NOTE - already a self-describing envelope.
	UNKNOWN_EVENT           = "unknown_event"
	UNKNOWN_SCHEMA          = "unknown_schema"
	SELF_DESCRIBING_EVENT   = "self_describing"
	IGLU                    = "iglu"
)

Types

type Dimension

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

type Page

type Page struct {
	Url      string                 `json:"url"`
	Title    *string                `json:"title"`
	Scheme   string                 `json:"scheme"`
	Host     string                 `json:"host"`
	Port     string                 `json:"port"`
	Path     string                 `json:"path"`
	Query    map[string]interface{} `json:"query"`
	Fragment *string                `json:"fragment"`
	Medium   *string                `json:"medium"`
	Source   *string                `json:"source"`
	Term     *string                `json:"term"`
	Content  *string                `json:"content"`
	Campaign *string                `json:"campaign"`
}

type PagePingEvent

type PagePingEvent struct {
	PpXOffsetMin *int64 `json:"pp_xoffset_min"`
	PpXOffsetMax *int64 `json:"pp_xoffset_max"`
	PpYOffsetMin *int64 `json:"pp_yoffset_min"`
	PpYOffsetMax *int64 `json:"pp_yoffset_max"`
}

type PageViewEvent

type PageViewEvent struct{}

type SnowplowEvent

type SnowplowEvent struct {
	// Application parameters - https://docs.snowplowanalytics.com/docs/collecting-data/collecting-from-own-applications/snowplow-tracker-protocol/#common-parameters-platform-and-event-independent
	NameTracker            *string                         `json:"name_tracker"`
	AppId                  *string                         `json:"app_id"`
	Platform               string                          `json:"platform"`
	EtlTstamp              *time.Time                      `json:"etl_tstamp"`
	DvceCreatedTstamp      *time.Time                      `json:"dvce_created_tstamp"`
	DvceSentTstamp         *time.Time                      `json:"dvce_sent_tstamp"`
	TrueTstamp             *time.Time                      `json:"true_tstamp"`
	CollectorTstamp        time.Time                       `json:"collector_tstamp"`
	DerivedTstamp          time.Time                       `json:"derived_tstamp"`
	OsTimezone             *string                         `json:"os_timezone"`
	Event                  string                          `json:"event"`
	TxnId                  *string                         `json:"txn_id"`
	EventId                *string                         `json:"event_id"`
	EventFingerprint       uuid.UUID                       `json:"event_fingerprint"`
	TrackerVersion         *string                         `json:"v_tracker"`
	CollectorVersion       *string                         `json:"v_collector"`
	EtlVersion             *string                         `json:"v_etl"`
	DomainUserid           *string                         `json:"domain_userid"`
	NetworkUserid          *string                         `json:"network_userid"`
	Userid                 *string                         `json:"user_id"`
	DomainSessionIdx       *int64                          `json:"domain_sessionidx"`
	DomainSessionId        *string                         `json:"domain_sessionid"`
	UserIpAddress          *string                         `json:"user_ipaddress"`
	Useragent              *string                         `json:"useragent"`
	UserFingerprint        *string                         `json:"user_fingerprint"`
	MacAddress             *string                         `json:"mac_address"`
	PageUrl                *string                         `json:"page_url"`
	PageTitle              *string                         `json:"page_title"`
	PageUrlScheme          *string                         `json:"page_urlscheme"`
	PageUrlHost            *string                         `json:"page_urlhost"`
	PageUrlPort            *string                         `json:"page_urlport"`
	PageUrlPath            *string                         `json:"page_urlpath"`
	PageUrlQuery           *map[string]interface{}         `json:"page_urlquery"`
	PageUrlFragment        *string                         `json:"page_urlfragment"`
	MktMedium              *string                         `json:"mkt_medium"`
	MktSource              *string                         `json:"mkt_source"`
	MktTerm                *string                         `json:"mkt_term"`
	MktContent             *string                         `json:"mkt_content"`
	MktCampaign            *string                         `json:"mkt_campaign"`
	PageReferrer           *string                         `json:"page_referrer"`
	RefrUrlScheme          *string                         `json:"refr_urlscheme"`
	RefrUrlHost            *string                         `json:"refr_urlhost"`
	RefrUrlPort            *string                         `json:"refr_urlport"`
	RefrUrlPath            *string                         `json:"refr_urlpath"`
	RefrUrlQuery           *map[string]interface{}         `json:"refr_urlquery"`
	RefrUrlFragment        *string                         `json:"refr_urlfragment"`
	RefrMedium             *string                         `json:"refr_medium"`
	RefrSource             *string                         `json:"refr_source"`
	RefrTerm               *string                         `json:"refr_term"`
	RefrContent            *string                         `json:"refr_content"`
	RefrCampaign           *string                         `json:"refr_campaign"`
	RefrDomainUserId       *string                         `json:"refr_domain_userid"` // FIXME!
	RefrDomainTstamp       *time.Time                      `json:"refr_domain_tstamp"` // FIXME!
	BrCookies              *bool                           `json:"br_cookies"`
	BrLang                 *string                         `json:"br_lang"`
	BrFeaturesPdf          *bool                           `json:"br_features_pdf"`
	BrFeaturesQuicktime    *bool                           `json:"br_features_quicktime"`
	BrFeaturesRealplayer   *bool                           `json:"br_features_realplayer"`
	BrFeaturesWindowsmedia *bool                           `json:"br_features_windowsmedia"`
	BrFeaturesDirector     *bool                           `json:"br_features_director"`
	BrFeaturesFlash        *bool                           `json:"br_features_flash"`
	BrFeaturesJava         *bool                           `json:"br_features_java"`
	BrFeaturesGears        *bool                           `json:"br_features_gears"`
	BrFeaturesSilverlight  *bool                           `json:"br_features_silverlight"`
	BrColordepth           *int64                          `json:"br_colordepth"`
	ViewportSize           *string                         `json:"viewport_size"`
	BrViewWidth            *int                            `json:"br_viewwidth"`
	BrViewHeight           *int                            `json:"br_viewheight"`
	DocCharset             *string                         `json:"doc_charset"`
	DocSize                *string                         `json:"doc_size"`
	DocWidth               *int                            `json:"doc_width"`
	DocHeight              *int                            `json:"doc_height"`
	DvceScreenResolution   *string                         `json:"dvce_screenresolution"`
	DvceScreenWidth        *int                            `json:"dvce_screenwidth"`
	DvceScreenHeight       *int                            `json:"dvce_screenheight"`
	Contexts               *envelope.Contexts              `json:"contexts"`
	SelfDescribingEvent    *envelope.SelfDescribingPayload `json:"self_describing_event"`
	PpXOffsetMin           *int64                          `json:"pp_xoffset_min"`
	PpXOffsetMax           *int64                          `json:"pp_xoffset_max"`
	PpYOffsetMin           *int64                          `json:"pp_yoffset_min"`
	PpYOffsetMax           *int64                          `json:"pp_yoffset_max"`
	SeCategory             *string                         `json:"se_category"`
	SeAction               *string                         `json:"se_action"`
	SeLabel                *string                         `json:"se_label"`
	SeProperty             *string                         `json:"se_property"`
	SeValue                *float64                        `json:"se_value"`
	TrOrderId              *string                         `json:"tr_orderid"`
	TrAffiliation          *string                         `json:"tr_affiliation"`
	TrTotal                *float64                        `json:"tr_total"`
	TrTax                  *float64                        `json:"tr_tax"`
	TrShipping             *float64                        `json:"tr_shipping"`
	TrCity                 *string                         `json:"tr_city"`
	TrState                *string                         `json:"tr_state"`
	TrCountry              *string                         `json:"tr_country"`
	TrCurrency             *string                         `json:"tr_currency"`
	TiOrderId              *string                         `json:"ti_orderid"`
	TiSku                  *string                         `json:"ti_sku"`
	TiName                 *string                         `json:"ti_name"`
	TiCategory             *string                         `json:"ti_category"`
	TiPrice                *float64                        `json:"ti_price,string"`
	TiQuantity             *int64                          `json:"ti_quantity"`
	TiCurrency             *string                         `json:"ti_currency"`
	EventVendor            *string                         `json:"event_vendor"`
	EventName              *string                         `json:"event_name"`
	EventFormat            *string                         `json:"event_format"`
	EventVersion           *string                         `json:"event_version"`
}

type SnowplowInput

type SnowplowInput struct{}

func (*SnowplowInput) EnvelopeBuilder

func (i *SnowplowInput) EnvelopeBuilder(c *gin.Context, conf *config.Config, metadata *meta.CollectorMeta) []envelope.Envelope

func (*SnowplowInput) Handler

func (i *SnowplowInput) Handler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc

func (*SnowplowInput) Initialize

func (i *SnowplowInput) Initialize(engine *gin.Engine, manifold *manifold.Manifold, conf *config.Config, metadata *meta.CollectorMeta) error

func (*SnowplowInput) SquawkboxHandler

func (i *SnowplowInput) SquawkboxHandler(m manifold.Manifold, conf config.Config, metadata *meta.CollectorMeta) gin.HandlerFunc

type StructEvent

type StructEvent struct {
	SeCategory *string  `json:"se_category"`
	SeAction   *string  `json:"se_action"`
	SeLabel    *string  `json:"se_label"`
	SeProperty *string  `json:"se_property"`
	SeValue    *float64 `json:"se_value"`
}

type TransactionEvent

type TransactionEvent struct {
	TrOrderId     *string  `json:"tr_orderid"`
	TrAffiliation *string  `json:"tr_affiliation"`
	TrTotal       *float64 `json:"tr_total"`
	TrTax         *float64 `json:"tr_tax"`
	TrShipping    *float64 `json:"tr_shipping"`
	TrCity        *string  `json:"tr_city"`
	TrState       *string  `json:"tr_state"`
	TrCountry     *string  `json:"tr_country"`
	TrCurrency    *string  `json:"tr_currency"`
}

type TransactionItemEvent

type TransactionItemEvent struct {
	TiOrderId  *string  `json:"ti_orderid"`
	TiSku      *string  `json:"ti_sku"`
	TiName     *string  `json:"ti_name"`
	TiCategory *string  `json:"ti_category"`
	TiPrice    *float64 `json:"ti_price"`
	TiQuantity *int64   `json:"ti_quantity"`
	TiCurrency *string  `json:"ti_currency"`
}