testdatasource

Documentation

Index

• func GetJSONModel(j json.RawMessage) (kinds.TestDataQuery, error)
• func LoadCsvContent(ioReader io.Reader, name string) (*data.Frame, error)
• func RandomWalk(query backend.DataQuery, model kinds.TestDataQuery, index int) *data.Frame
• type Scenario
• type Service
  • func ProvideService() *Service
  • func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
  • func (s *Service) CheckHealth(_ context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (s *Service) CollectMetrics(ctx context.Context, req *backend.CollectMetricsRequest) (*backend.CollectMetricsResult, error)
  • func (s *Service) ConvertObject(ctx context.Context, req *backend.ConversionRequest) (*backend.ConversionResponse, error)
  • func (s *Service) MutateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.MutationResponse, 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)
  • func (s *Service) ValidateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.ValidationResponse, error)

Functions

func GetJSONModel

func GetJSONModel(j json.RawMessage) (kinds.TestDataQuery, error)

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 kinds.TestDataQuery, index int) *data.Frame

Types

type Scenario

type Scenario struct {
	ID kinds.TestDataQueryType `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) CheckHealth

func (s *Service) CheckHealth(_ context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*Service) CollectMetrics

func (s *Service) CollectMetrics(ctx context.Context, req *backend.CollectMetricsRequest) (*backend.CollectMetricsResult, error)

CollectMetricsHandler handles metric collection.

func (*Service) ConvertObject

func (s *Service) ConvertObject(ctx context.Context, req *backend.ConversionRequest) (*backend.ConversionResponse, error)

ConvertObject implements backend.AdmissionHandler.

func (*Service) MutateAdmission

func (s *Service) MutateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.MutationResponse, error)

MutateAdmission implements backend.AdmissionHandler.

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)

func (*Service) ValidateAdmission

func (s *Service) ValidateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.ValidationResponse, error)

ValidateAdmission implements backend.AdmissionHandler.