controller

Documentation

Index

• type EntitySchema
  • func (es *EntitySchema) Validate(payload *app.Entity) error
• type Event
• type RefererResolver
  • func (ref *RefererResolver) SetCurrent(curl string)
• type TrackController
  • func NewTrackController(service *goa.Service, ep sarama.AsyncProducer, ps model.PropertyStorage, ...) *TrackController
  • func (c *TrackController) Commerce(ctx *app.CommerceTrackContext) error
  • func (c *TrackController) Entity(ctx *app.EntityTrackContext) error
  • func (c *TrackController) Event(ctx *app.EventTrackContext) error
  • func (c *TrackController) Pageview(ctx *app.PageviewTrackContext) error

Types

type EntitySchema

type EntitySchema model.EntitySchema

EntitySchema represents extendended entity schema definition with validation capability.

func (*EntitySchema) Validate

func (es *EntitySchema) Validate(payload *app.Entity) error

Validate validates provided entity against provided schema.

type Event

type Event struct {
	Action   string                 `json:"action"`
	Category string                 `json:"category"`
	Fields   map[string]interface{} `json:"fields"`
	Value    float64                `json:"value"`
}

Event represents Influx event structure

type RefererResolver

type RefererResolver struct {
	Referer       *refererparser.RefererResult
	InternalHosts []string
}

RefererResolver extends behavior of snowplow RefererResult

func (*RefererResolver) SetCurrent

func (ref *RefererResolver) SetCurrent(curl string)

SetCurrent sets the current URL in the underlying RefererResult and attempts to resolve "internal" status.

The status is based on referer/current URL hosts comparison or based on list of internal hosts provided to RefererResolver (whichever is true).

type TrackController

type TrackController struct {
	*goa.Controller
	EventProducer       sarama.AsyncProducer
	PropertyStorage     model.PropertyStorage
	EntitySchemaStorage model.EntitySchemaStorage
	InternalHosts       []string
}

TrackController implements the track resource.

func NewTrackController

func NewTrackController(service *goa.Service, ep sarama.AsyncProducer, ps model.PropertyStorage, ess model.EntitySchemaStorage, ih []string) *TrackController

NewTrackController creates a track controller.

func (*TrackController) Commerce

func (c *TrackController) Commerce(ctx *app.CommerceTrackContext) error

Commerce runs the commerce action.

func (*TrackController) Entity

func (c *TrackController) Entity(ctx *app.EntityTrackContext) error

Entity runs the entity action.

func (*TrackController) Event

func (c *TrackController) Event(ctx *app.EventTrackContext) error

Event runs the event action.

func (*TrackController) Pageview

func (c *TrackController) Pageview(ctx *app.PageviewTrackContext) error

Pageview runs the pageview action.