beater

Documentation

Index

• Constants
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type Ganalyticsbeat
  • func (bt *Ganalyticsbeat) DownloadAndPublish(timeNow int, timeStart int, timeEnd int) error
  • func (bt *Ganalyticsbeat) DownloadRealtimeAndPublish(currentTime time.Time) error
  • func (bt *Ganalyticsbeat) Run(b *beat.Beat) error
  • func (bt *Ganalyticsbeat) Stop()

Constants

const (
	STATEFILE_NAME      = "ganalyticsbeat.state"
	OFFSET_PAST_MINUTES = 30
	MAX_RETRIES         = 30
)

Functions

func New

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

Creates beater

Types

type Ganalyticsbeat

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

func (*Ganalyticsbeat) DownloadAndPublish

func (bt *Ganalyticsbeat) DownloadAndPublish(timeNow int, timeStart int, timeEnd int) error

func (*Ganalyticsbeat) DownloadRealtimeAndPublish

func (bt *Ganalyticsbeat) DownloadRealtimeAndPublish(currentTime time.Time) error

func (*Ganalyticsbeat) Run

func (bt *Ganalyticsbeat) Run(b *beat.Beat) error

func (*Ganalyticsbeat) Stop

func (bt *Ganalyticsbeat) Stop()