views

Jan 31, 2024

Changes in this version

type Metric

+ CreatorID data.Nullable[string]

+ ExitsBeforeStart data.Nullable[float64]

+ GeoHash data.Nullable[string]

+ ViewerID data.Nullable[string]

type ViewershipEventRow

+ CreatorID bigquery.NullString

+ ExitsBeforeStart bigquery.NullFloat64

+ GeoHash bigquery.NullString

+ ViewerID bigquery.NullString

Jun 9, 2023

Changes in this version

type Client

+ func (c *Client) QueryEvents(ctx context.Context, spec QuerySpec, assetID, streamID string) ([]Metric, error)

+ func (c *Client) QuerySummary(ctx context.Context, playbackID string) (*Metric, error)

type Metric

+ LegacyViewCount *int64

type ViewSummaryRow

+ LegacyViewCount bigquery.NullInt64

May 9, 2023

Changes in this version

+ func ToDStorageURL(playbackID string) string

+ type BigQuery interface

+ QueryViewsEvents func(ctx context.Context, spec QuerySpec) ([]ViewershipEventRow, error)

+ QueryViewsSummary func(ctx context.Context, playbackID string) (*ViewSummaryRow, error)

+ func NewBigQuery(opts BigQueryOptions) (BigQuery, error)

+ type BigQueryOptions struct

+ BigQueryCredentialsJSON string

+ MaxBytesBilledPerBigQuery int64

+ ViewershipEventsTable string

+ ViewershipSummaryTable string

type Client

+ func (c *Client) Deprecated_GetTotalViews(ctx context.Context, id string) ([]TotalViews, error)

+ func (c *Client) Query(ctx context.Context, spec QuerySpec, assetID, streamID string) ([]Metric, error)

+ type Metric struct

+ Browser *string

+ BrowserEngine *string

+ CPU *string

+ Continent *string

+ Country *string

+ DStorageURL string

+ Device *string

+ DeviceType *string

+ ErrorRate *float64

+ ExistsBeforeStart *float64

+ OS *string

+ PlaybackID string

+ PlaytimeMins float64

+ RebufferRatio *float64

+ Subdivision *string

+ TimeZone *string

+ Timestamp *int64

+ TtffMs *float64

+ ViewCount int64

+ type Prometheus struct

+ func NewPrometheus(config promClient.Config) (*Prometheus, error)

+ func (c *Prometheus) QueryStartViews(ctx context.Context, asset *livepeer.Asset) (int64, error)

+ type QueryFilter struct

+ CreatorID string

+ PlaybackID string

+ UserID string

+ type QuerySpec struct

+ BreakdownBy []string

+ Detailed bool

+ Filter QueryFilter

+ From *time.Time

+ TimeStep string

+ To *time.Time

+ func (s QuerySpec) GetSummaryQueryArgs() (playbackID string, ok bool)

+ type ViewSummaryRow struct

+ DStorageURL string

+ PlaybackID string

+ PlaytimeMins float64

+ ViewCount int64

+ type ViewershipEventRow struct

+ Browser bigquery.NullString

+ BrowserEngine bigquery.NullString

+ CPU bigquery.NullString

+ Continent bigquery.NullString

+ Country bigquery.NullString

+ DStorageURL string

+ Device bigquery.NullString

+ DeviceType bigquery.NullString

+ ErrorRate bigquery.NullFloat64

+ ExistsBeforeStart bigquery.NullFloat64

+ OS bigquery.NullString

+ PlaybackID string

+ PlaytimeMins float64

+ RebufferRatio bigquery.NullFloat64

+ Subdivision bigquery.NullString

+ TimeInterval time.Time

+ TimeZone bigquery.NullString

+ TtffMs bigquery.NullFloat64

+ ViewCount int64

Sep 17, 2022

Changes in this version

+ var ErrAssetNotFound = errors.New("asset not found")

Sep 9, 2022

Changes in this version

+ type Client struct

+ func NewClient(opts ClientOptions) (*Client, error)

+ func (c *Client) GetTotalViews(ctx context.Context, id string) ([]TotalViews, error)

+ type ClientOptions struct

+ Livepeer livepeer.ClientOptions

+ Prometheus promClient.Config

+ type TotalViews struct

+ ID string

+ StartViews int64