Documentation
¶
Index ¶
- func LoadCsvContent(ioReader io.Reader, name string) (*data.Frame, error)
- func RandomWalk(query backend.DataQuery, model JSONModel, index int) *data.Frame
- type JSONModel
- type Scenario
- type Service
- func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
- func (s *Service) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
- func (s *Service) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
- func (s *Service) RunStream(ctx context.Context, request *backend.RunStreamRequest, ...) error
- func (s *Service) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoadCsvContent ¶
LoadCsvContent should be moved to the SDK
Types ¶
type JSONModel ¶
type JSONModel struct {
ScenarioID string `json:"scenarioId"`
SeriesCount int `json:"seriesCount"`
StringInput string `json:"stringInput"`
Lines int64 `json:"lines"`
IncludeLevelColumn bool `json:"includeLevelColumn"`
StartValue float64 `json:"startValue"`
Spread float64 `json:"spread"`
Noise float64 `json:"noise"`
Drop float64 `json:"drop"`
Min *float64 `json:"min,omitempty"`
Max *float64 `json:"max,omitempty"`
Labels string `json:"labels"`
WithNil bool `json:"withNil"`
PulseWave pulseWave `json:"pulseWave"`
Alias string `json:"alias"`
// Cannot specify a type for csvWave since legacy queries
// does not follow the same format as the new ones (and there is no migration).
CSVWave interface{} `json:"csvWave"`
CSVContent string `json:"csvContent"`
CSVFileName string `json:"csvFileName"`
DropPercent float64 `json:"dropPercent"`
}
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func ProvideService ¶
func ProvideService() *Service
func (*Service) CallResource ¶
func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error
func (*Service) PublishStream ¶
func (s *Service) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
func (*Service) QueryData ¶
func (s *Service) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
func (*Service) RunStream ¶
func (s *Service) RunStream(ctx context.Context, request *backend.RunStreamRequest, sender *backend.StreamSender) error
func (*Service) SubscribeStream ¶
func (s *Service) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.