Documentation ¶
Index ¶
- Variables
- func GetTLS(host, cacheDir string) (*tls.Config, error)
- func ParseDuration(expr string) (time.Duration, error)
- type ApiFrontendBasicStage
- func (stage *ApiFrontendBasicStage) Fetch(request *mortarpb.FetchRequest, client mortarpb.Mortar_FetchServer) error
- func (stage *ApiFrontendBasicStage) GetAPIKey(ctx context.Context, request *mortarpb.GetAPIKeyRequest) (*mortarpb.APIKeyResponse, error)
- func (stage *ApiFrontendBasicStage) GetQueue() chan *Request
- func (stage *ApiFrontendBasicStage) GetUpstream() Stage
- func (stage *ApiFrontendBasicStage) Qualify(ctx context.Context, request *mortarpb.QualifyRequest) (*mortarpb.QualifyResponse, error)
- func (stage *ApiFrontendBasicStage) SetUpstream(upstream Stage)
- func (stage *ApiFrontendBasicStage) String() string
- type ApiFrontendBasicStageConfig
- type ApiFrontendWAVEAuthStage
- func (stage *ApiFrontendWAVEAuthStage) Fetch(request *mortarpb.FetchRequest, client mortarpb.Mortar_FetchServer) error
- func (stage *ApiFrontendWAVEAuthStage) GetAPIKey(ctx context.Context, request *mortarpb.GetAPIKeyRequest) (*mortarpb.APIKeyResponse, error)
- func (stage *ApiFrontendWAVEAuthStage) GetQueue() chan *Request
- func (stage *ApiFrontendWAVEAuthStage) GetUpstream() Stage
- func (stage *ApiFrontendWAVEAuthStage) Qualify(ctx context.Context, request *mortarpb.QualifyRequest) (*mortarpb.QualifyResponse, error)
- func (stage *ApiFrontendWAVEAuthStage) SetUpstream(upstream Stage)
- func (stage *ApiFrontendWAVEAuthStage) String() string
- type ApiFrontendWAVEAuthStageConfig
- type BrickQueryStage
- type BrickQueryStageConfig
- type CognitoAuth
- type CognitoAuthConfig
- type Config
- type InfluxDBTimeseriesQueryStage
- type InfluxDBTimeseriesStageConfig
- type Request
- type SimpleLoadGenStage
- type Stage
- type TimeseriesQueryStage
- type TimeseriesStageConfig
- type WAVEConfig
- type WAVEMQConfig
- type WAVEMQFrontendStage
- func (stage *WAVEMQFrontendStage) Fetch(request *mortarpb.FetchRequest, client mortarpb.Mortar_FetchServer) error
- func (stage *WAVEMQFrontendStage) GetQueue() chan *Request
- func (stage *WAVEMQFrontendStage) GetUpstream() Stage
- func (stage *WAVEMQFrontendStage) Qualify(ctx context.Context, request *mortarpb.QualifyRequest) (*mortarpb.QualifyResponse, error)
- func (stage *WAVEMQFrontendStage) SetUpstream(upstream Stage)
- func (stage *WAVEMQFrontendStage) String() string
- type WAVEMQFrontendStageConfig
Constants ¶
This section is empty.
Variables ¶
View Source
var MAX_TIMEOUT = time.Second * 300
View Source
var TS_BATCH_SIZE = 500
Functions ¶
Types ¶
type ApiFrontendBasicStage ¶
func NewApiFrontendBasicStage ¶
func NewApiFrontendBasicStage(cfg *ApiFrontendBasicStageConfig) (*ApiFrontendBasicStage, error)
func (*ApiFrontendBasicStage) Fetch ¶
func (stage *ApiFrontendBasicStage) Fetch(request *mortarpb.FetchRequest, client mortarpb.Mortar_FetchServer) error
pull data from Mortar gets called from frontend by GRPC server
func (*ApiFrontendBasicStage) GetAPIKey ¶
func (stage *ApiFrontendBasicStage) GetAPIKey(ctx context.Context, request *mortarpb.GetAPIKeyRequest) (*mortarpb.APIKeyResponse, error)
func (*ApiFrontendBasicStage) GetQueue ¶
func (stage *ApiFrontendBasicStage) GetQueue() chan *Request
func (*ApiFrontendBasicStage) GetUpstream ¶
func (stage *ApiFrontendBasicStage) GetUpstream() Stage
get the stage we pull from
func (*ApiFrontendBasicStage) Qualify ¶
func (stage *ApiFrontendBasicStage) Qualify(ctx context.Context, request *mortarpb.QualifyRequest) (*mortarpb.QualifyResponse, error)
identify which sites meet the requirements of the queries
func (*ApiFrontendBasicStage) SetUpstream ¶
func (stage *ApiFrontendBasicStage) SetUpstream(upstream Stage)
set the stage we pull from
func (*ApiFrontendBasicStage) String ¶
func (stage *ApiFrontendBasicStage) String() string
type ApiFrontendWAVEAuthStage ¶
func NewApiFrontendWAVEAuthStage ¶
func NewApiFrontendWAVEAuthStage(cfg *ApiFrontendWAVEAuthStageConfig) (*ApiFrontendWAVEAuthStage, error)
func (*ApiFrontendWAVEAuthStage) Fetch ¶
func (stage *ApiFrontendWAVEAuthStage) Fetch(request *mortarpb.FetchRequest, client mortarpb.Mortar_FetchServer) error
pull data from Mortar gets called from frontend by GRPC server
func (*ApiFrontendWAVEAuthStage) GetAPIKey ¶
func (stage *ApiFrontendWAVEAuthStage) GetAPIKey(ctx context.Context, request *mortarpb.GetAPIKeyRequest) (*mortarpb.APIKeyResponse, error)
func (*ApiFrontendWAVEAuthStage) GetQueue ¶
func (stage *ApiFrontendWAVEAuthStage) GetQueue() chan *Request
func (*ApiFrontendWAVEAuthStage) GetUpstream ¶
func (stage *ApiFrontendWAVEAuthStage) GetUpstream() Stage
get the stage we pull from
func (*ApiFrontendWAVEAuthStage) Qualify ¶
func (stage *ApiFrontendWAVEAuthStage) Qualify(ctx context.Context, request *mortarpb.QualifyRequest) (*mortarpb.QualifyResponse, error)
identify which sites meet the requirements of the queries
func (*ApiFrontendWAVEAuthStage) SetUpstream ¶
func (stage *ApiFrontendWAVEAuthStage) SetUpstream(upstream Stage)
set the stage we pull from
func (*ApiFrontendWAVEAuthStage) String ¶
func (stage *ApiFrontendWAVEAuthStage) String() string
type BrickQueryStage ¶
func NewBrickQueryStage ¶
func NewBrickQueryStage(cfg *BrickQueryStageConfig) (*BrickQueryStage, error)
func (*BrickQueryStage) GetQueue ¶
func (stage *BrickQueryStage) GetQueue() chan *Request
blocks on internal channel until next "Context" is ready
func (*BrickQueryStage) GetUpstream ¶
func (stage *BrickQueryStage) GetUpstream() Stage
get the stage we pull from
func (*BrickQueryStage) SetUpstream ¶
func (stage *BrickQueryStage) SetUpstream(upstream Stage)
set the stage we pull from
func (*BrickQueryStage) String ¶
func (stage *BrickQueryStage) String() string
type BrickQueryStageConfig ¶
type CognitoAuth ¶
func NewCognitoAuth ¶
func NewCognitoAuth(cfg CognitoAuthConfig) (*CognitoAuth, error)
type CognitoAuthConfig ¶
type Config ¶
type Config struct { // configuration for amazon cognito Cognito CognitoAuthConfig // wavemq frontend config WAVEMQ WAVEMQConfig // WAVE auth frontend config WAVE WAVEConfig HodConfig string ListenAddr string BTrDBAddr string InfluxDBAddr string InfluxDBUser string InfluxDBPass string PrometheusAddr string TLSCrtFile string TLSKeyFile string }
func ReadConfig ¶
type InfluxDBTimeseriesQueryStage ¶
func NewInfluxDBTimeseriesQueryStage ¶
func NewInfluxDBTimeseriesQueryStage(cfg *InfluxDBTimeseriesStageConfig) (*InfluxDBTimeseriesQueryStage, error)
func (*InfluxDBTimeseriesQueryStage) GetQueue ¶
func (stage *InfluxDBTimeseriesQueryStage) GetQueue() chan *Request
func (*InfluxDBTimeseriesQueryStage) GetUpstream ¶
func (stage *InfluxDBTimeseriesQueryStage) GetUpstream() Stage
func (*InfluxDBTimeseriesQueryStage) SetUpstream ¶
func (stage *InfluxDBTimeseriesQueryStage) SetUpstream(upstream Stage)
func (*InfluxDBTimeseriesQueryStage) String ¶
func (stage *InfluxDBTimeseriesQueryStage) String() string
type Request ¶
func NewFetchRequest ¶
func NewFetchRequest(ctx context.Context, fetch *mortarpb.FetchRequest) *Request
func NewQualifyRequest ¶
func NewQualifyRequest(ctx context.Context, qualify *mortarpb.QualifyRequest) *Request
type SimpleLoadGenStage ¶
type SimpleLoadGenStage struct {
// contains filtered or unexported fields
}
func NewSimpleLoadGenStage ¶
func NewSimpleLoadGenStage(contexts ...func() *Request) *SimpleLoadGenStage
func (*SimpleLoadGenStage) GetQueue ¶
func (stage *SimpleLoadGenStage) GetQueue() chan *Request
blocks on internal channel until next "*Request" is ready
func (*SimpleLoadGenStage) GetUpstream ¶
func (stage *SimpleLoadGenStage) GetUpstream() Stage
func (*SimpleLoadGenStage) SetUpstream ¶
func (stage *SimpleLoadGenStage) SetUpstream(upstream Stage)
set the stage we pull from
func (*SimpleLoadGenStage) String ¶
func (stage *SimpleLoadGenStage) String() string
type TimeseriesQueryStage ¶
func NewTimeseriesQueryStage ¶
func NewTimeseriesQueryStage(cfg *TimeseriesStageConfig) (*TimeseriesQueryStage, error)
func (*TimeseriesQueryStage) GetQueue ¶
func (stage *TimeseriesQueryStage) GetQueue() chan *Request
func (*TimeseriesQueryStage) GetUpstream ¶
func (stage *TimeseriesQueryStage) GetUpstream() Stage
func (*TimeseriesQueryStage) SetUpstream ¶
func (stage *TimeseriesQueryStage) SetUpstream(upstream Stage)
func (*TimeseriesQueryStage) String ¶
func (stage *TimeseriesQueryStage) String() string
type TimeseriesStageConfig ¶
type WAVEConfig ¶
type WAVEMQConfig ¶
type WAVEMQFrontendStage ¶
type WAVEMQFrontendStage struct {
// contains filtered or unexported fields
}
func NewWAVEMQFrontendStage ¶
func NewWAVEMQFrontendStage(cfg *WAVEMQFrontendStageConfig) (*WAVEMQFrontendStage, error)
func (*WAVEMQFrontendStage) Fetch ¶
func (stage *WAVEMQFrontendStage) Fetch(request *mortarpb.FetchRequest, client mortarpb.Mortar_FetchServer) error
pull data from Mortar gets called from frontend by GRPC server
func (*WAVEMQFrontendStage) GetQueue ¶
func (stage *WAVEMQFrontendStage) GetQueue() chan *Request
func (*WAVEMQFrontendStage) GetUpstream ¶
func (stage *WAVEMQFrontendStage) GetUpstream() Stage
get the stage we pull from
func (*WAVEMQFrontendStage) Qualify ¶
func (stage *WAVEMQFrontendStage) Qualify(ctx context.Context, request *mortarpb.QualifyRequest) (*mortarpb.QualifyResponse, error)
func (*WAVEMQFrontendStage) SetUpstream ¶
func (stage *WAVEMQFrontendStage) SetUpstream(upstream Stage)
set the stage we pull from
func (*WAVEMQFrontendStage) String ¶
func (stage *WAVEMQFrontendStage) String() string
Click to show internal directories.
Click to hide internal directories.