testdatasource

Documentation

Index

• func LoadCsvContent(ioReader io.Reader, name string) (*data.Frame, error)
• func RandomWalk(query backend.DataQuery, model *simplejson.Json, index int) *data.Frame
• type Scenario
• type Service
  • func ProvideService(cfg *setting.Cfg, features featuremgmt.FeatureToggles) *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 *simplejson.Json, index int) *data.Frame

Types

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(cfg *setting.Cfg, features featuremgmt.FeatureToggles) *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)