amplitude

Documentation

Index

• Constants
• func NewAmplitude(ctx context.Context, sourceConfig *base.SourceConfig, ...) (base.Driver, error)
• func TestAmplitude(sourceConfig *base.SourceConfig) error
• type Amplitude
  • func (a *Amplitude) Close() error
  • func (a *Amplitude) GetAllAvailableIntervals() ([]*base.TimeInterval, error)
  • func (a *Amplitude) GetCollectionMetaKey() string
  • func (a *Amplitude) GetCollectionTable() string
  • func (a *Amplitude) GetObjectsFor(interval *base.TimeInterval, objectsLoader base.ObjectsLoader) error
  • func (a *Amplitude) GetRefreshWindow() (time.Duration, error)
  • func (a *Amplitude) ReplaceTables() bool
  • func (a *Amplitude) Type() string
• type AmplitudeAdapter
  • func NewAmplitudeAdapter(apiKey, secretKey, server string, config *adapters.HTTPConfiguration) (*AmplitudeAdapter, error)
  • func (a *AmplitudeAdapter) Close() error
  • func (a *AmplitudeAdapter) GetAnnotations() ([]map[string]interface{}, error)
  • func (a *AmplitudeAdapter) GetCohorts() ([]map[string]interface{}, error)
  • func (a *AmplitudeAdapter) GetEvents(interval *base.TimeInterval) ([]map[string]interface{}, error)
  • func (a *AmplitudeAdapter) GetSessions(interval *base.TimeInterval) ([]map[string]interface{}, error)
  • func (a *AmplitudeAdapter) GetStatus() error
  • func (a *AmplitudeAdapter) GetUsers(interval *base.TimeInterval, collectionName string) ([]map[string]interface{}, error)
• type AmplitudeConfig
  • func (ac *AmplitudeConfig) Validate() error

Constants

const (
	AmplitudeActiveUsers     = "active_users"
	AmplitudeAnnotations     = "annotations"
	AmplitudeAverageSessions = "average_sessions"
	AmplitudeCohorts         = "cohorts"
	AmplitudeEvents          = "events"
	AmplitudeNewUsers        = "new_users"
)

Functions

func NewAmplitude

func NewAmplitude(ctx context.Context, sourceConfig *base.SourceConfig, collection *base.Collection) (base.Driver, error)

NewAmplitude returns configured Amplitude driver instance

func TestAmplitude

func TestAmplitude(sourceConfig *base.SourceConfig) error

TestAmplitude tests connection to Amplitude without creating Driver instance

Types

type Amplitude

type Amplitude struct {
	base.IntervalDriver
	// contains filtered or unexported fields
}

Amplitude is an Amplitude driver. It is used in syncing data from Amplitude.

func (*Amplitude) Close

func (a *Amplitude) Close() error

func (*Amplitude) GetAllAvailableIntervals

func (a *Amplitude) GetAllAvailableIntervals() ([]*base.TimeInterval, error)

func (*Amplitude) GetCollectionMetaKey

func (a *Amplitude) GetCollectionMetaKey() string

func (*Amplitude) GetCollectionTable

func (a *Amplitude) GetCollectionTable() string

func (*Amplitude) GetObjectsFor

func (a *Amplitude) GetObjectsFor(interval *base.TimeInterval, objectsLoader base.ObjectsLoader) error

func (*Amplitude) GetRefreshWindow

func (a *Amplitude) GetRefreshWindow() (time.Duration, error)

func (*Amplitude) ReplaceTables

func (a *Amplitude) ReplaceTables() bool

func (*Amplitude) Type

func (a *Amplitude) Type() string

type AmplitudeAdapter

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

func NewAmplitudeAdapter

func NewAmplitudeAdapter(apiKey, secretKey, server string, config *adapters.HTTPConfiguration) (*AmplitudeAdapter, error)

func (*AmplitudeAdapter) Close

func (a *AmplitudeAdapter) Close() error

func (*AmplitudeAdapter) GetAnnotations

func (a *AmplitudeAdapter) GetAnnotations() ([]map[string]interface{}, error)

func (*AmplitudeAdapter) GetCohorts

func (a *AmplitudeAdapter) GetCohorts() ([]map[string]interface{}, error)

func (*AmplitudeAdapter) GetEvents

func (a *AmplitudeAdapter) GetEvents(interval *base.TimeInterval) ([]map[string]interface{}, error)

func (*AmplitudeAdapter) GetSessions

func (a *AmplitudeAdapter) GetSessions(interval *base.TimeInterval) ([]map[string]interface{}, error)

func (*AmplitudeAdapter) GetStatus

func (a *AmplitudeAdapter) GetStatus() error

func (*AmplitudeAdapter) GetUsers

func (a *AmplitudeAdapter) GetUsers(interval *base.TimeInterval, collectionName string) ([]map[string]interface{}, error)

type AmplitudeConfig

type AmplitudeConfig struct {
	ApiKey    string `mapstructure:"api_key" json:"api_key,omitempty" yaml:"api_key,omitempty"`
	SecretKey string `mapstructure:"secret_key" json:"secret_key,omitempty" yaml:"secret_key,omitempty"`
	Server    string `mapstructure:"server" json:"server,omitempty" yaml:"server,omitempty"`
}

func (*AmplitudeConfig) Validate

func (ac *AmplitudeConfig) Validate() error