testdatasource

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 ProvideService() *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)

Functions

func LoadCsvContent

func LoadCsvContent(ioReader io.Reader, name string) (*data.Frame, error)

LoadCsvContent should be moved to the SDK

func RandomWalk

func RandomWalk(query backend.DataQuery, model JSONModel, index int) *data.Frame

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 Scenario

type Scenario struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	StringInput string `json:"stringInput"`
	Description string `json:"description"`
	// contains filtered or unexported fields
}

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)