intsnowflake

Documentation

Index

• func ToSnowflakeConfig(fileName string) (*gosnowflake.Config, error)
• type Config
• type SFFlags
  • func (f *SFFlags) InitFlags(fs *flag.FlagSet) error
  • func (f *SFFlags) NewStravaDatabase() (intsql.StravaDatabase, error)
  • func (f *SFFlags) PostProcessFlags(fs *flag.FlagSet) error
• type SFStrava
  • func New(configFileName string, etlTableName string) SFStrava
  • func (sdb *SFStrava) Close() error
  • func (sdb *SFStrava) DB() *sql.DB
  • func (sdb *SFStrava) FilterKnownActivityIds(activityIds []int64) ([]int64, error)
  • func (sdb *SFStrava) InitAndValidateSchema() error
  • func (sdb *SFStrava) MergeActivities() error
  • func (sdb *SFStrava) OpenDB() error
  • func (sdb *SFStrava) UploadActivityJson(activities []util.Jsonable) error

Functions

func ToSnowflakeConfig

func ToSnowflakeConfig(fileName string) (*gosnowflake.Config, error)

Types

type Config

type Config struct {
	Account        string `json:"account"`
	User           string `json:"user"`
	PrivateKeyFile string `json:"private_key_file"`
}

type SFFlags

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

func (*SFFlags) InitFlags

func (f *SFFlags) InitFlags(fs *flag.FlagSet) error

func (*SFFlags) NewStravaDatabase

func (f *SFFlags) NewStravaDatabase() (intsql.StravaDatabase, error)

NewStravaDatabase implements intsql.Flags.

func (*SFFlags) PostProcessFlags

func (f *SFFlags) PostProcessFlags(fs *flag.FlagSet) error

type SFStrava

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

func New

func New(configFileName string, etlTableName string) SFStrava

func (*SFStrava) Close

func (sdb *SFStrava) Close() error

Close implements intsql.StravaDatabase.

func (*SFStrava) DB

func (sdb *SFStrava) DB() *sql.DB

func (*SFStrava) FilterKnownActivityIds

func (sdb *SFStrava) FilterKnownActivityIds(activityIds []int64) ([]int64, error)

FilterKnownActivityIds implements intsql.StravaDatabase.

func (*SFStrava) InitAndValidateSchema

func (sdb *SFStrava) InitAndValidateSchema() error

InitAndValidateSchema implements intsql.StravaDatabase.

func (*SFStrava) MergeActivities

func (sdb *SFStrava) MergeActivities() error

MergeActivities implements intsql.StravaDatabase.

func (*SFStrava) OpenDB

func (sdb *SFStrava) OpenDB() error

OpenDB implements intsql.StravaDatabase.

func (*SFStrava) UploadActivityJson

func (sdb *SFStrava) UploadActivityJson(activities []util.Jsonable) error

UploadActivityJson implements intsql.StravaDatabase.