proxy

Mar 15, 2024

Changes in this version

+ const NetCostKind

+ const ScenarioKind

Feb 25, 2024

Changes in this version

+ const DigitalTwinKind

+ const SimulationKind

+ const TrafficModelKind

Dec 15, 2023

Changes in this version

+ func ListKinds() []string

+ type ImportStatistics struct

+ ErrorMessages []string

+ NumFailed int

+ NumSucceeded int

type QueryAgent

+ RedisClient *redis.Client

+ func (qa *QueryAgent) RedisGet(ctx context.Context, req *RedisRequest) (*RawResponse, error)

+ type RawResponse struct

+ Result string

+ type RedisRequest struct

+ Key string

+ type ResourceLocator struct

+ Kind string

+ Name string

+ Namespace string

+ func ListResources(ctx context.Context, c client.Client) ([]*ResourceLocator, error)

type SourceType

+ const Redis

Nov 29, 2023

Changes in this version

+ type BiChanDataPoint struct

+ Series string

+ ValueY float64

+ type BiChanResponse struct

+ Result []*BiChanDataPoint

+ type ChanType int8

+ const BiChan

+ const TriChan

+ type CheckHTTPHealthRequest struct

+ URL string

+ type ErrorResponse struct

+ Message string

+ type ExportResourceInfo struct

+ Kind string

type LabelSelector

+ func (ls *LabelSelector) GetSeriesFromPromMetric(m model.Metric) (string, error)

+ func (ls *LabelSelector) GetSeriesFromRedisRange(r redistimeseries.Range) (string, error)

+ type PromRequest struct

+ EndTimestamp UnixTimestamp

+ LabelSelector []string

+ Query string

+ StartTimestamp UnixTimestamp

+ Step int64

type QueryAgent

+ RedisTSClient *redistimeseries.Client

+ func (qa *QueryAgent) PromQuery(ctx context.Context, req *PromRequest) (*BiChanResponse, error)

+ func (qa *QueryAgent) PromQueryRange(ctx context.Context, req *PromRequest) (*TriChanResponse, error)

+ func (qa *QueryAgent) RedisTSMultiGet(ctx context.Context, req *RedisTSRequest) (*BiChanResponse, error)

+ func (qa *QueryAgent) RedisTSMultiRange(ctx context.Context, req *RedisTSRequest) (*TriChanResponse, error)

+ type RedisTSRequest struct

+ EndTimestamp UnixTimestamp

+ Filters []string

+ LabelSelector []string

+ StartTimestamp UnixTimestamp

+ type SourceType int8

+ const Prometheus

+ const RedisTimeSeries

+ type TriChanDataPoint struct

+ Series string

+ ValueX float64

+ ValueY float64

+ type TriChanResponse struct

+ Result []*TriChanDataPoint

Sep 13, 2023

Changes in this version

+ const CostExporterKind

+ const DatasetKind

+ const ExperimentKind

+ const LoadPatternKind

+ const PipelineKind

+ const PlantDCoreKind

+ const SchemaKind

+ func AddFileToZip(zw *zip.Writer, name string, content []byte) error

+ func ExportResources(ctx context.Context, c client.Client, resInfoList []ResourceInfo) (*bytes.Buffer, error)

+ func GetDataSet(ctx context.Context, c client.Client, namespace string, name string) (*windtunnelv1alpha1.DataSet, error)

+ func GetSampleDataSet(ctx context.Context, c client.Client, namespace string, datasetName string) (string, *bytes.Buffer, error)

+ type ImportResourcesStatistics struct

+ ErrorMessages []string

+ NumFailed int

+ NumSucceeded int

+ func ImportResources(ctx context.Context, c client.Client, buf *bytes.Buffer) (*ImportResourcesStatistics, error)

+ type ResourceInfo struct

+ Kind string

Sep 3, 2023

Changes in this version

+ const CostExporterPlural

+ const DATA_SOURCE_PROM

+ const DATA_SOURCE_REDIS

+ const DatasetPlural

+ const ExperimentPlural

+ const LoadPatternPlural

+ const PipelinePlural

+ const PlantDCorePlural

+ const SchemaPlural

+ func AddFileToTar(tw *tar.Writer, name string, content []byte) error

+ func CheckPipelineHealth(ctx context.Context, c client.Client, URL string, HealthCheckEndpoint string) error

+ func CreateNamespace(ctx context.Context, client client.Client, namespaceName string) (namespaceExists, creationFailed error)

+ func CreateObject(ctx context.Context, c client.Client, newObj client.Object, kind string) (objectExists, creationFailed error)

+ func DeleteNamespace(ctx context.Context, client client.Client, namespaceName string) (namespaceNotFound, deletionFailed error)

+ func DeleteObject(ctx context.Context, c client.Client, kind, namespace, name string) (objectNotFound, deletionFailed error)

+ func ForObject(kind string) client.Object

+ func ForObjectList(kind string) client.ObjectList

+ func GetDataset(ctx context.Context, c client.Client, namespace string, name string) (*windtunnelv1alpha1.DataSet, error)

+ func GetIndexByName(schemas []windtunnelv1alpha1.SchemaSelector, schemaName string) (int, bool)

+ func GetObject(ctx context.Context, c client.Client, kind, namespace, name string) (client.Object, error)

+ func GetObjectList(ctx context.Context, c client.Client, kind, namespace string) (client.ObjectList, error)

+ func GetSampleDataset(ctx context.Context, c client.Client, namespace string, datasetName string) (string, *bytes.Buffer, error)

+ func GetSchema(ctx context.Context, c client.Client, namespace string, name string) (*windtunnelv1alpha1.Schema, error)

+ func ListNamespaces(ctx context.Context, client client.Client) (*corev1.NamespaceList, error)

+ func SampleValueToFloatPointer(v model.SampleValue) *float64

+ func UpdateObject(ctx context.Context, c client.Client, updated client.Object, kind string) (notFound, updationFailed error)

+ type CustomResourceMeta struct

+ Kind string

+ Name string

+ Namespace string

+ type CustomResourceWrapper struct

+ type ExportResourcesInfo struct

+ Metadata []CustomResourceMeta

+ type HealthCheckMeta struct

+ HealthCheckEndpoint string

+ URL string

+ type LabelSelector struct

+ TargetLabels []string

+ func NewLabelSelector(labels []string) *LabelSelector

+ func (s *LabelSelector) GetSeriesFromMetric(labelSet model.Metric) string

+ type NamespaceInfo struct

+ Name string

+ Namespace string

+ type QueryAgent struct

+ PromAPI v1.API

+ func NewQueryAgent(url string) (*QueryAgent, error)

+ func (c *QueryAgent) QueryBiChann(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ func (c *QueryAgent) QueryBiChannProm(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ func (c *QueryAgent) QueryBiChannRedis(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ func (c *QueryAgent) QueryTriChann(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ func (c *QueryAgent) QueryTriChannProm(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ func (c *QueryAgent) QueryTriChannRedis(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ type QueryClient interface

+ QueryBiChann func(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ QueryTriChann func(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ type QueryParam struct

+ EndTimestamp UnixTimestamp

+ Keys []string

+ LabelSelector []string

+ Query string

+ StartTimestamp UnixTimestamp

+ Step int64

+ type QueryRequest struct

+ Param QueryParam

+ Source string

+ type QueryResult struct

+ Result []ResultPoint

+ type ResultPoint struct

+ Series string

+ ValueX *float64

+ ValueY *float64

+ type UnixTimestamp struct

+ func (ts *UnixTimestamp) UnmarshalJSON(b []byte) (err error)