datasource

Feb 27, 2024

Changes in this version

type StravaDatasourceInstance

+ func (ds *StravaDatasourceInstance) SaveRefreshToken(token string) error

+ type StravaDatasourcePlugin struct

+ func NewStravaDatasourcePlugin(dataDir string, saToken string) *StravaDatasourcePlugin

+ func (ds *StravaDatasourcePlugin) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

+ func (ds *StravaDatasourcePlugin) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

+ func (ds *StravaDatasourcePlugin) ResetAccessTokenHandler(rw http.ResponseWriter, req *http.Request)

+ func (ds *StravaDatasourcePlugin) ResetCacheHandler(rw http.ResponseWriter, req *http.Request)

+ func (ds *StravaDatasourcePlugin) RootHandler(rw http.ResponseWriter, req *http.Request)

+ func (ds *StravaDatasourcePlugin) StravaAPIHandler(rw http.ResponseWriter, req *http.Request)

+ func (ds *StravaDatasourcePlugin) StravaAuthHandler(rw http.ResponseWriter, req *http.Request)

Aug 8, 2023

Changes in this version

type StravaAPIRequest

+ AccessToken string

Sep 9, 2022

Changes in this version

+ type AuthCache struct

+ func GetAuthCache() *AuthCache

+ type DSAuthCache struct

+ func GetDSAuthCache(dsId int64) *DSAuthCache

+ func (d *DSAuthCache) GetRefreshToken() string

+ func (d *DSAuthCache) SetRefreshToken(t string)

type StravaDatasource

+ func (ds *StravaDatasource) ResetCacheHandler(rw http.ResponseWriter, req *http.Request)

type StravaDatasourceInstance

+ func (ds *StravaDatasourceInstance) GetRefreshToken() (string, error)

Aug 29, 2022

Changes in this version

+ const MaxTasks

+ func HashByte(data []byte) string

+ type ActivityDTO = struct

+ Id int64

type DSCache

+ func (c *DSCache) Flush()

+ func (c *DSCache) SetWithExpiration(request string, response interface{}, d time.Duration)

+ func (c *DSCache) SetWithNoExpiration(request string, response interface{}, d time.Duration)

+ type PrefetchStreamTask struct

type StravaDatasourceInstance

+ func (ds *StravaDatasourceInstance) ResetCache()

+ func (ds *StravaDatasourceInstance) StravaAPIQueryWithCache(requestHash string) func(context.Context, *StravaAPIRequest) (*StravaApiResourceResponse, error)

+ type StravaDatasourceSettingsDTO struct

+ CacheTTL string

+ ClientID string

+ StravaAuthType string

+ type StravaPrefetcher struct

+ func NewStravaPrefetcher(depth int, ds *StravaDatasourceInstance) *StravaPrefetcher

+ func (p *StravaPrefetcher) GetActivities() ([]string, error)

+ func (p *StravaPrefetcher) PrefetchActivities(activities []string)

+ func (p *StravaPrefetcher) PrefetchActivitiesVariable(limit int)

+ func (p *StravaPrefetcher) PrefetchActivity(activityId string)

+ func (p *StravaPrefetcher) PrefetchActivityStreams(activityId string)

+ func (p *StravaPrefetcher) Run()

Dec 27, 2021

Changes in this version

type DSCache

+ func (c *DSCache) Delete(request string)

type StravaDatasource

+ func (ds *StravaDatasource) ResetAccessTokenHandler(rw http.ResponseWriter, req *http.Request)

type StravaDatasourceInstance

+ func (ds *StravaDatasourceInstance) ResetAccessToken() error

Oct 14, 2020

Changes in this version

+ const StravaAPITokenUrl

+ const StravaAPIUrl

+ const StravaApiQueryType

+ const StravaAuthQueryType

+ var ErrAlertingNotSupported = errors.New("alerting not supported")

+ func HashDatasourceInfo(dsInfo *backend.DataSourceInstanceSettings) string

+ func HashString(text string) string

+ type DSCache struct

+ func NewDSCache(dsInfo *backend.DataSourceInstanceSettings, ttl time.Duration, ...) *DSCache

+ func (c *DSCache) BuildDSCacheKey(request string) string

+ func (c *DSCache) Get(request string) (interface{}, bool)

+ func (c *DSCache) Load(request string) (string, error)

+ func (c *DSCache) Save(request string, response interface{}) error

+ func (c *DSCache) Set(request string, response interface{}, d time.Duration)

+ func (c *DSCache) SetDefault(request string, response interface{})

+ type QueryModel struct

+ ActivityStat string

+ ActivityType string

+ Format string

+ Interval string

+ QueryType string

+ TimeRange backend.TimeRange

+ func ReadQuery(query backend.DataQuery) (QueryModel, error)

+ type StravaAPIRequest struct

+ Endpoint string

+ Params map[string]json.RawMessage

+ type StravaApiResourceResponse struct

+ Result interface{}

+ func BuildAPIResponse(apiResponse []byte) (*StravaApiResourceResponse, error)

+ type StravaAuthRequest struct

+ AuthCode string

+ type StravaAuthResourceResponse struct

+ Result interface{}

+ type StravaDatasource struct

+ func NewStravaDatasource(dataDir string) *StravaDatasource

+ func (ds *StravaDatasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

+ func (ds *StravaDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

+ func (ds *StravaDatasource) RootHandler(rw http.ResponseWriter, req *http.Request)

+ func (ds *StravaDatasource) StravaAPIHandler(rw http.ResponseWriter, req *http.Request)

+ func (ds *StravaDatasource) StravaAuthHandler(rw http.ResponseWriter, req *http.Request)

+ type StravaDatasourceInstance struct

+ func (ds *StravaDatasourceInstance) ExchangeToken(authCode string) (*TokenExchangeResponse, error)

+ func (ds *StravaDatasourceInstance) GetAccessToken() (string, error)

+ func (ds *StravaDatasourceInstance) RefreshAccessToken(refreshToken string) (*TokenExchangeResponse, error)

+ func (ds *StravaDatasourceInstance) StravaAPIQuery(ctx context.Context, query *StravaAPIRequest) (*StravaApiResourceResponse, error)

+ func (ds *StravaDatasourceInstance) StravaAuthQuery(ctx context.Context, req *StravaAuthRequest) (*StravaAuthResourceResponse, error)

+ type TokenExchangeResponse struct

+ AccessToken string

+ AccessTokenExpAt int64

+ RefreshToken string