warehouse

type BaseExportFields struct {
	IndvId                     int64
	UserId                     int64
	SessionId                  int64
	PageId                     int64
	UserCreated                time.Time
	UserAppKey                 string
	UserDisplayName            string
	UserEmail                  string
	EventStart                 time.Time
	EventType                  string
	EventSubType               string
	EventCustomName            string
	EventTargetText            string
	EventTargetSelector        string
	EventPageOffset            int64
	EventSessionOffset         int64
	EventModFrustrated         int64
	EventModDead               int64
	EventModError              int64
	EventModSuspicious         int64
	EventVarErrorKind          string
	EventVarFields             string
	EventWebSourceFileUrl      string
	EventFirstInputDelay       int64
	EventCumulativeLayoutShift float64
	SessionStart               time.Time
	PageName                   string
	PageStart                  time.Time
	PageDuration               int64
	PageActiveDuration         int64
	PageUrl                    string
	PageRefererUrl             string
	PageIp                     string
	PageLatLong                string
	PageUserAgent              string
	PageBrowser                string
	PageBrowserVersion         string
	PageDevice                 string
	PagePlatform               string
	PageOperatingSystem        string
	PageScreenWidth            int64
	PageScreenHeight           int64
	PageViewportWidth          int64
	PageViewportHeight         int64
	PageNumEvents              int32
	PageNumDerivedEvents       int32
	PageNumInfos               int64
	PageNumWarnings            int64
	PageNumErrors              int64
	PageClusterId              int64
	PageMaxScrollDepthPercent  int64
	LoadDomContentTime         int64
	LoadEventTime              int64
	LoadFirstPaintTime         int64
	LoadLargestPaintTime       int64
	ReqUrl                     string
	ReqMethod                  string
	ReqStatus                  int64
	CustomVars                 string
}

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

type Database interface {
	Syncable
	LoadToWarehouse(storageRef string, start time.Time) error
	ValueToString(val interface{}, isTime bool) string
	GetExportTableColumns() []string

	// InitExportTable should attempt to create the table in the database. If the table doesn't exist, the provided
	// schema should be applied to the table and this function should return `true`, assuming an error didn't occur.
	// If the table existed, this should return false to signal that follow-up schema validation is necessary.
	InitExportTable(Schema) (bool, error)

	// ApplyExportSchema will attempt to update the schema in the database to the provided schema.
	// The provided schema must be compatible, or this will fail. Compatible schemas will have existing columns
	// in the same order as they are currently ordered in the table and can also add new columns to the end.
	ApplyExportSchema(Schema) error
}

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

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

type MobileFields struct {
	AppName               string
	AppPackageName        string
	AppDeviceModel        string
	AppDeviceVendor       string
	AppVersion            string
	AppOsVersion          string
	AppViewName           string
	EventMobileSourceFile string
}

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

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

type Schema []WarehouseField

type Storage interface {
	Syncable
	SaveFile(ctx context.Context, name string, reader io.Reader) (string, error)
	ReadFile(ctx context.Context, name string) (io.Reader, error)
	DeleteFile(ctx context.Context, name string) error
	GetFileReference(name string) string
	GetFilePrefix() string
}

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

type Syncable interface {
	LastSyncPoint(ctx context.Context) (time.Time, error)
	SaveSyncPoint(ctx context.Context, endTime time.Time) error
}

type ValueToStringFn func(val interface{}, isTime bool) string

type WarehouseField struct {
	// The name of the field as it exists in the database.
	// By default this will match the `FullStoryFieldName`, but may not match for certain fields
	// if they've been renamed in the export. (e.g. "PageAgent").
	// If the database contains columns that are not part of the FullStory export, this field will still be populated.
	DBName string

	// The name of the field from FullStory.
	// This can be empty if an existing database table contains columns that FullStory does not include
	// in the export. This value, if non-empty, is used as part of the `CreateExport` request in the
	// `DataExportClient`
	FullStoryFieldName string

	// FieldType should be used by each database implementation to specify the datatype
	// for this column. This is only used when creating or modifying a database's schema.
	// If the `FullStoryFieldName` is blank, then this should be nil.
	FieldType reflect.Type
}