models

Nov 12, 2021

Changes in this version

+ type PerformanceTestConfigFile struct

+ Config *SMP.PerformanceTestConfig

+ ServiceMesh *SMP.ServiceMesh

Nov 5, 2021

Changes in this version

+ const BrokerURLCtxKey

type HandlerConfig

+ BrokerEndpointURL *string

+ type PerformanceTestConfig struct

+ ID uuid.UUID

+ PerformanceTestConfigBytes []byte

+ UpdatedAt time.Time

+ type SMIResultsPersister struct

+ DB *database.Handler

+ func (s *SMIResultsPersister) DeleteResult(key uuid.UUID) error

+ func (s *SMIResultsPersister) GetResults(page, pageSize uint64) ([]byte, error)

+ func (s *SMIResultsPersister) UpdateResult(key uuid.UUID, res SmiResultWithID) error

+ func (s *SMIResultsPersister) WriteResult(key uuid.UUID, result []byte) error

+ type SessionPreferencePersister struct

+ DB *database.Handler

+ func (s *SessionPreferencePersister) DeleteFromPersister(userID string) error

+ func (s *SessionPreferencePersister) ReadFromPersister(userID string) (*Preference, error)

+ func (s *SessionPreferencePersister) WriteToPersister(userID string, data *Preference) error

+ type SmiResultWithID struct

+ ID uuid.UUID

+ type TestProfilesPersister struct

+ DB *database.Handler

+ func (s *TestProfilesPersister) DeleteTestConfig(key uuid.UUID) error

+ func (s *TestProfilesPersister) GetTestConfig(key uuid.UUID) (*SMP.PerformanceTestConfig, error)

+ func (s *TestProfilesPersister) GetTestConfigs(page, pageSize uint64) ([]byte, error)

+ func (s *TestProfilesPersister) UpdateTestConfig(key uuid.UUID, p PerformanceTestConfig) error

+ func (s *TestProfilesPersister) WriteTestConfig(key uuid.UUID, result []byte) error

+ type UserPreference struct

+ ID string

+ PreferenceBytes []byte

Nov 1, 2021

Changes in this version

type HandlerInterface

+ ExtensionsVersionHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

type NavigatorExtension

+ OnClickCallback int

type RunnerResults

+ ActualDuration uint64

+ RequestedDuration string

Oct 8, 2021

Changes in this version

type HandlerInterface

+ OAMComponentDetailByIDHandler func(rw http.ResponseWriter, r *http.Request)

+ OAMComponentDetailsHandler func(rw http.ResponseWriter, r *http.Request)

Sep 26, 2021

Changes in this version

type HandlerInterface

+ FilterFileHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

Sep 17, 2021

Changes in this version

+ const ErrGettingSeededComponentsCode

+ const ErrSavingSeededComponentsCode

+ func ErrGettingSeededComponents(err error, content string) error

+ func ErrSavingSeededComponents(err error, content string) error

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) CleanupSeeded(seededUUIDs []uuid.UUID)

+ func (l *DefaultLocalProvider) SeedContent(log logger.Handler) ([]uuid.UUID, error)

Aug 27, 2021

Changes in this version

type K8SConfig

+ Contexts []K8SContext

Aug 13, 2021

Changes in this version

+ const ErrFetchDataCode

+ const ErrIndexOutOfRangeCode

+ const ErrSessionCopyCode

+ const PerfObjCtxKey

+ const TokenCtxKey

+ const UserCtxKey

+ var ErrIndexOutOfRange = errors.New(ErrIndexOutOfRangeCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ func ErrFetchData(err error) error

+ func ErrSessionCopy(err error) error

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) DeleteMesheryPatternResource(token, resourceID string) error

type HandlerInterface

+ AdaptersHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

type MesheryResult

+ CreatedAt string

+ UpdatedAt string

+ UserID string

type Provider

+ DeleteMesheryPatternResource func(token, resourceID string) error

type RemoteProvider

+ func (l *RemoteProvider) DeleteMesheryPatternResource(token, resourceID string) error

Jul 25, 2021

Changes in this version

type HandlerInterface

+ UserPrefsHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

Jul 21, 2021

Changes in this version

+ const ErrApplicationFileNameCode

+ const ErrCopyCode

+ const ErrDBConnectionCode

+ const ErrDBDeleteCode

+ const ErrDBLockCode

+ const ErrDBOpenCode

+ const ErrDBPutCode

+ const ErrDBRLockCode

+ const ErrDBReadCode

+ const ErrDataReadCode

+ const ErrDecodeBase64Code

+ const ErrDeleteCode

+ const ErrEncodingCode

+ const ErrEncodingPEMCode

+ const ErrFetchCode

+ const ErrFieldCode

+ const ErrFilterFileNameCode

+ const ErrFolderStatCode

+ const ErrGenerateUUIDCode

+ const ErrGetTokenCode

+ const ErrGrafanaBoardsCode

+ const ErrGrafanaDashboardCode

+ const ErrGrafanaDataCode

+ const ErrGrafanaDataSourceCode

+ const ErrGrafanaOrgCode

+ const ErrInvalidCapabilityCode

+ const ErrJWKsKeysCode

+ const ErrLoadgeneratorCode

+ const ErrLocalProviderSupportCode

+ const ErrMakeDirCode

+ const ErrMarshalCode

+ const ErrMarshalPKIXCode

+ const ErrNilConfigDataCode

+ const ErrNilJWKsCode

+ const ErrNilKeysCode

+ const ErrNilQueryCode

+ const ErrPageNumberCode

+ const ErrPageSizeCode

+ const ErrParsingTestCode

+ const ErrPatternFileNameCode

+ const ErrPerfIDCode

+ const ErrPostCode

+ const ErrPraseUnverifiedCode

+ const ErrPrometheusGetNodesCode

+ const ErrPrometheusLabelSeriesCode

+ const ErrPrometheusQueryRangeCode

+ const ErrPrometheusStaticBoardCode

+ const ErrProtocolCode

+ const ErrResultDataCode

+ const ErrResultIDCode

+ const ErrTestClientCode

+ const ErrTestEndpointCode

+ const ErrTokenClaimsCode

+ const ErrTokenClientCheckCode

+ const ErrTokenDecodeCode

+ const ErrTokenExpiredCode

+ const ErrTokenPraseCode

+ const ErrTokenRefreshCode

+ const ErrUnableToPersistsResultCode

+ const ErrUnmarshalCode

+ const ErrUserIDCode

+ const ErrValidURLCode

+ var ErrApplicationFileName = errors.New(ErrApplicationFileNameCode, errors.Alert, []string{ ... }, []string{ ... }, ...)

+ var ErrDBConnection = errors.New(ErrDBConnectionCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrField = errors.New(ErrFieldCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrFilterFileName = errors.New(ErrFilterFileNameCode, errors.Alert, []string{ ... }, []string{ ... }, ...)

+ var ErrLoadgenerator = errors.New(ErrLoadgeneratorCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrLocalProviderSupport = errors.New(ErrLocalProviderSupportCode, errors.Alert, []string{ ... }, []string{}, ...)

+ var ErrNilConfigData = errors.New(ErrNilConfigDataCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrNilJWKs = errors.New(ErrNilJWKsCode, errors.Alert, []string{ ... }, []string{ ... }, []string{}, ...)

+ var ErrNilKeys = errors.New(ErrNilKeysCode, errors.Alert, []string{ ... }, []string{ ... }, []string{}, ...)

+ var ErrNilQuery = errors.New(ErrNilQueryCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrParsingTest = errors.New(ErrParsingTestCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrPatternFileName = errors.New(ErrPatternFileNameCode, errors.Alert, []string{ ... }, []string{ ... }, ...)

+ var ErrProtocol = errors.New(ErrProtocolCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrResultID = errors.New(ErrResultIDCode, errors.Alert, []string{ ... }, []string{ ... }, []string{}, ...)

+ var ErrTestClient = errors.New(ErrTestClientCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrTestEndpoint = errors.New(ErrTestEndpointCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrTokenClaims = errors.New(ErrTokenClaimsCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrTokenExpired = errors.New(ErrTokenExpiredCode, errors.Alert, []string{ ... }, []string{ ... }, ...)

+ var ErrUserID = errors.New(ErrUserIDCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ var ErrValidURL = errors.New(ErrValidURLCode, errors.Alert, []string{ ... }, []string{}, []string{}, ...)

+ func ErrCopy(err error, obj string) error

+ func ErrDBDelete(err error, user string) error

+ func ErrDBLock(err error) error

+ func ErrDBOpen(err error) error

+ func ErrDBPut(err error) error

+ func ErrDBRLock(err error) error

+ func ErrDBRead(err error) error

+ func ErrDataRead(err error, r string) error

+ func ErrDecodeBase64(err error, obj string) error

+ func ErrDelete(err error, obj string, statusCode int) error

+ func ErrEncoding(err error, obj string) error

+ func ErrEncodingPEM(err error) error

+ func ErrFetch(err error, obj string, statusCode int) error

+ func ErrFolderStat(err error, dir string) error

+ func ErrGenerateUUID(err error) error

+ func ErrGetToken(err error) error

+ func ErrGrafanaBoards(err error) error

+ func ErrGrafanaDashboard(err error, UID string) error

+ func ErrGrafanaData(err error, apiEndpoint string) error

+ func ErrGrafanaDataSource(err error, ds string) error

+ func ErrGrafanaOrg(err error) error

+ func ErrInvalidCapability(capability string, provider string) error

+ func ErrJWKsKeys(err error) error

+ func ErrMakeDir(err error, dir string) error

+ func ErrMarshal(err error, obj string) error

+ func ErrMarshalPKIX(err error) error

+ func ErrPageNumber(err error) error

+ func ErrPageSize(err error) error

+ func ErrPerfID(err error) error

+ func ErrPost(err error, obj string, statusCode int) error

+ func ErrPraseUnverified(err error) error

+ func ErrPrometheusGetNodes(err error) error

+ func ErrPrometheusLabelSeries(err error) error

+ func ErrPrometheusQueryRange(err error, query string, startTime, endTime time.Time, step time.Duration) error

+ func ErrPrometheusStaticBoard(err error) error

+ func ErrResultData() error

+ func ErrTokenClientCheck(err error) error

+ func ErrTokenDecode(err error) error

+ func ErrTokenPrase(err error) error

+ func ErrTokenRefresh(err error) error

+ func ErrUnableToPersistsResult(err error) error

+ func ErrUnmarshal(err error, obj string) error

type HandlerInterface

+ GraphqlMiddleware func(http.Handler) func(http.ResponseWriter, *http.Request, *Preference, *User, Provider)

Jul 14, 2021

Changes in this version

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) GetMesheryFilterFile(req *http.Request, filterID string) ([]byte, error)

type HandlerInterface

+ GetMesheryFilterFileHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

type MesheryFilterPersister

+ func (mfp *MesheryFilterPersister) GetMesheryFilterFile(id uuid.UUID) ([]byte, error)

type Provider

+ GetMesheryFilterFile func(req *http.Request, filterID string) ([]byte, error)

type RemoteProvider

+ func (l *RemoteProvider) GetMesheryFilterFile(req *http.Request, filterID string) ([]byte, error)

Jul 10, 2021

Changes in this version

+ type SchedulesAPIResponse struct

+ Page uint

+ PageSize uint

+ Schedules []Schedule

+ TotalCount uint

Jul 9, 2021

Changes in this version

type HandlerConfig

+ GraphQLHandler http.Handler

+ GraphQLPlaygroundHandler http.Handler

type HandlerInterface

+ GetGraphQLHandler func() http.Handler

+ GetGraphQLPlaygroundHandler func() http.Handler

type ProviderProperties

+ ProviderURL string

Jul 5, 2021

Changes in this version

+ const ErrGrafanaClientCode

+ func ErrGrafanaClient(err error) error

type DefaultLocalProvider

+ MesheryPatternResourcePersister *PatternResourcePersister

+ func (l *DefaultLocalProvider) DeleteMesheryResource(token, resourceID string) error

+ func (l *DefaultLocalProvider) GetMesheryPatternResource(token, resourceID string) (*PatternResource, error)

+ func (l *DefaultLocalProvider) GetMesheryPatternResources(token, page, pageSize, search, order, name, namespace, typ, oamType string) (*PatternResourcePage, error)

+ func (l *DefaultLocalProvider) SaveMesheryPatternResource(token string, resource *PatternResource) (*PatternResource, error)

type Feature

+ const PersistMesheryPatternResources

type HandlerInterface

+ ApplicationFileHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ type PatternResource struct

+ CreatedAt *time.Time

+ Deleted bool

+ ID *uuid.UUID

+ Name string

+ Namespace string

+ OAMType string

+ Type string

+ UpdatedAt *time.Time

+ UserID *uuid.UUID

+ type PatternResourcePage struct

+ Page uint64

+ PageSize uint64

+ Resources []*PatternResource

+ TotalCount int

+ type PatternResourcePersister struct

+ DB *database.Handler

+ func (prp *PatternResourcePersister) DeletePatternResource(id uuid.UUID) error

+ func (prp *PatternResourcePersister) Exists(name, namespace, typ, oamType string) bool

+ func (prp *PatternResourcePersister) GetPatternResource(id uuid.UUID) (*PatternResource, error)

+ func (prp *PatternResourcePersister) GetPatternResourceByAttributes(name, namespace, typ, oamType string) (*PatternResource, error)

+ func (prp *PatternResourcePersister) GetPatternResources(search, order, name, namespace, typ, oamType string, page, pageSize uint64) (*PatternResourcePage, error)

+ func (prp *PatternResourcePersister) SavePatternResource(pr *PatternResource) (*PatternResource, error)

+ type PreferenceParams struct

+ AnonymousPerfResults bool

+ AnonymousUsageStats bool

type Provider

+ DeleteMesheryResource func(token, resourceID string) error

+ GetMesheryPatternResource func(token, resourceID string) (*PatternResource, error)

+ GetMesheryPatternResources func(token, page, pageSize, search, order, name, namespace, typ, oamType string) (*PatternResourcePage, error)

+ SaveMesheryPatternResource func(token string, resource *PatternResource) (*PatternResource, error)

type RemoteProvider

+ func (l *RemoteProvider) DeleteMesheryResource(token, resourceID string) error

+ func (l *RemoteProvider) GetMesheryPatternResource(token, resourceID string) (*PatternResource, error)

+ func (l *RemoteProvider) GetMesheryPatternResources(token, page, pageSize, search, order, name, namespace, typ, oamType string) (*PatternResourcePage, error)

+ func (l *RemoteProvider) SaveMesheryPatternResource(token string, resource *PatternResource) (*PatternResource, error)

Jun 30, 2021

Changes in this version

+ type GrafanaConfigParams struct

+ GrafanaAPIKey string

+ GrafanaURL string

+ type PerformanceProfileParameters struct

+ ConcurrentRequest int

+ Duration string

+ Endpoints []string

+ LoadGenerators []string

+ Name string

+ QPS int

+ ServiceMesh string

+ type PerformanceTestParameters struct

+ ConcurrentRequest int

+ Duration string

+ LoadGenerator string

+ Name string

+ QPS int

+ ServiceMesh string

+ TestID strfmt.UUID

+ Time int

+ URL string

Jun 24, 2021

Changes in this version

type DefaultLocalProvider

+ MesheryApplicationPersister *MesheryApplicationPersister

+ func (l *DefaultLocalProvider) DeleteMesheryApplication(req *http.Request, applicationID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetMesheryApplication(req *http.Request, applicationID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetMesheryApplications(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) RemoteApplicationFile(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

+ func (l *DefaultLocalProvider) SaveMesheryApplication(tokenString string, application *MesheryApplication) ([]byte, error)

type Feature

+ const PersistMesheryApplications

type HandlerInterface

+ ApplicationFileRequestHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ DeleteMesheryApplicationHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GetMesheryApplicationHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ type MesheryApplicationPage struct

+ Applications []*MesheryApplication

+ Page uint64

+ PageSize uint64

+ TotalCount int

+ type MesheryApplicationPersister struct

+ DB *database.Handler

+ func (maap *MesheryApplicationPersister) DeleteMesheryApplication(id uuid.UUID) ([]byte, error)

+ func (maap *MesheryApplicationPersister) GetMesheryApplication(id uuid.UUID) ([]byte, error)

+ func (maap *MesheryApplicationPersister) GetMesheryApplications(search, order string, page, pageSize uint64) ([]byte, error)

+ func (maap *MesheryApplicationPersister) SaveMesheryApplication(application *MesheryApplication) ([]byte, error)

+ func (maap *MesheryApplicationPersister) SaveMesheryApplications(applications []MesheryApplication) ([]byte, error)

type Provider

+ DeleteMesheryApplication func(req *http.Request, applicationID string) ([]byte, error)

+ GetMesheryApplication func(req *http.Request, applicationID string) ([]byte, error)

+ GetMesheryApplications func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ RemoteApplicationFile func(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

+ SaveMesheryApplication func(tokenString string, application *MesheryApplication) ([]byte, error)

type RemoteProvider

+ func (l *RemoteProvider) DeleteMesheryApplication(req *http.Request, applicationID string) ([]byte, error)

+ func (l *RemoteProvider) GetMesheryApplication(req *http.Request, applicationID string) ([]byte, error)

+ func (l *RemoteProvider) GetMesheryApplications(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) RemoteApplicationFile(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

+ func (l *RemoteProvider) SaveMesheryApplication(tokenString string, application *MesheryApplication) ([]byte, error)

Jun 18, 2021

Changes in this version

+ func GetApplicationName(stringifiedFile string) (string, error)

+ type ApplicationsAPIResponse struct

+ Applications []MesheryApplication

+ Page uint

+ PageSize uint

+ TotalCount uint

type ExtensionInput

+ BrokerConn broker.Handler

+ type MesheryApplication struct

+ ApplicationFile string

+ CreatedAt *time.Time

+ ID *uuid.UUID

+ Location sql.Map

+ Name string

+ UpdatedAt *time.Time

+ UserID *string

type PerformanceResult

+ UserID *uuid.UUID

type RunnerResults

+ LoadGenerator string

+ URL string

Jun 3, 2021

Changes in this version

+ type PerformanceProfilesAPIResponse struct

+ Page uint

+ PageSize uint

+ Profiles []PerformanceProfile

+ TotalCount uint

+ type PerformanceResult struct

+ Mesh string

+ MesheryID *uuid.UUID

+ Name string

+ PerformanceProfile *uuid.UUID

+ RunnerResults RunnerResults

+ ServerBoardConfig interface{}

+ ServerMatrics interface{}

+ TestID string

+ TestStartTime *time.Time

+ type PerformanceResultsAPIResponse struct

+ Page uint

+ PageSize uint

+ Results []PerformanceResult

+ TotalCount uint

+ type RunnerResults struct

+ Duration uint64

+ DurationHistogram struct{ ... }

+ QPS float64

+ StartTime *time.Time

May 12, 2021

Changes in this version

+ func GetFilterName(stringifiedFile string) (string, error)

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) RemoteFilterFile(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

+ type FiltersAPIResponse struct

+ Filters []MesheryFilter

+ Page uint

+ PageSize uint

+ TotalCount uint

type LoadTestOptions

+ Location string

type MesheryFilter

+ Location sql.Map

type MesheryFilterPersister

+ func (mfp *MesheryFilterPersister) GetMesheryFilter(id uuid.UUID) ([]byte, error)

+ func (mfp *MesheryFilterPersister) SaveMesheryFilters(filters []MesheryFilter) ([]byte, error)

type Provider

+ RemoteFilterFile func(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

type RemoteProvider

+ func (l *RemoteProvider) RemoteFilterFile(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

May 7, 2021

Changes in this version

+ type PatternsAPIResponse struct

+ Page uint

+ PageSize uint

+ Patterns []MesheryPattern

+ TotalCount uint

May 2, 2021

Changes in this version

+ func GetPatternName(stringifiedFile string) (string, error)

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) RemotePatternFile(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

type MesheryPattern

+ Location sql.Map

type MesheryPatternPersister

+ func (mpp *MesheryPatternPersister) SaveMesheryPatterns(patterns []MesheryPattern) ([]byte, error)

type Provider

+ RemotePatternFile func(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

type RemoteProvider

+ func (l *RemoteProvider) RemotePatternFile(req *http.Request, resourceURL, path string, save bool) ([]byte, error)

Apr 29, 2021

Changes in this version

type DefaultLocalProvider

+ MesheryFilterPersister *MesheryFilterPersister

+ func (l *DefaultLocalProvider) DeleteMesheryFilter(req *http.Request, filterID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetMesheryFilter(req *http.Request, filterID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetMesheryFilters(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) ImportFilterFileGithub(req *http.Request, owner, repo, path string) ([]byte, error)

+ func (l *DefaultLocalProvider) SaveMesheryFilter(tokenString string, filter *MesheryFilter) ([]byte, error)

type Feature

+ const PersistMesheryFilters

+ const PersistRemoteMesheryFilters

type HandlerInterface

+ DeleteMesheryFilterHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ FilterFileRequestHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GetMesheryFilterHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ ImportFilterFileGithub func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ type MesheryFilter struct

+ CreatedAt *time.Time

+ FilterFile string

+ ID *uuid.UUID

+ Name string

+ UpdatedAt *time.Time

+ UserID *string

+ type MesheryFilterPage struct

+ Filters []*MesheryFilter

+ Page uint64

+ PageSize uint64

+ TotalCount int

+ type MesheryFilterPersister struct

+ DB *database.Handler

+ func (mfp *MesheryFilterPersister) DeleteMesheryFilter(id uuid.UUID) ([]byte, error)

+ func (mfp *MesheryFilterPersister) GetMesheryFilters(search, order string, page, pageSize uint64) ([]byte, error)

+ func (mfp *MesheryFilterPersister) SaveMesheryFilter(filter *MesheryFilter) ([]byte, error)

type Provider

+ DeleteMesheryFilter func(req *http.Request, filterID string) ([]byte, error)

+ GetMesheryFilter func(req *http.Request, filterID string) ([]byte, error)

+ GetMesheryFilters func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ ImportFilterFileGithub func(req *http.Request, owner, repo, path string) ([]byte, error)

+ SaveMesheryFilter func(tokenString string, filter *MesheryFilter) ([]byte, error)

type RemoteProvider

+ func (l *RemoteProvider) DeleteMesheryFilter(req *http.Request, filterID string) ([]byte, error)

+ func (l *RemoteProvider) GetMesheryFilter(req *http.Request, filterID string) ([]byte, error)

+ func (l *RemoteProvider) GetMesheryFilters(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) ImportFilterFileGithub(req *http.Request, owner, repo, path string) ([]byte, error)

+ func (l *RemoteProvider) SaveMesheryFilter(tokenString string, filter *MesheryFilter) ([]byte, error)

Apr 28, 2021

Changes in this version

type Adapter

+ GitCommitSHA string

+ Version string

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) ImportPatternFileGithub(req *http.Request, owner, repo, path string) ([]byte, error)

type Feature

+ const PersistRemoteMesheryPatterns

type HandlerInterface

+ ImportPatternFileGithub func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

type MesheryPattern

+ UserID *string

type Provider

+ ImportPatternFileGithub func(req *http.Request, owner, repo, path string) ([]byte, error)

type RemoteProvider

+ func (l *RemoteProvider) ImportPatternFileGithub(req *http.Request, owner, repo, path string) ([]byte, error)

Apr 8, 2021

Changes in this version

+ func Paginate(page, pageSize uint) func(db *gorm.DB) *gorm.DB

type DefaultLocalProvider

+ GraphqlHandler http.Handler

+ GraphqlPlayground http.Handler

+ KubeClient *mesherykube.Client

+ MesheryPatternPersister *MesheryPatternPersister

+ PerformanceProfilesPersister *PerformanceProfilePersister

+ func (l *DefaultLocalProvider) DeletePerformanceProfile(req *http.Request, performanceProfileID string) ([]byte, error)

+ func (l *DefaultLocalProvider) DeleteSchedule(req *http.Request, scheduleID string) ([]byte, error)

+ func (l *DefaultLocalProvider) FetchAllResults(req *http.Request, page, pageSize, search, order, from, to string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetGraphqlHandler() http.Handler

+ func (l *DefaultLocalProvider) GetGraphqlPlayground() http.Handler

+ func (l *DefaultLocalProvider) GetKubeClient() *mesherykube.Client

+ func (l *DefaultLocalProvider) GetPerformanceProfile(req *http.Request, performanceProfileID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetPerformanceProfiles(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetSchedule(req *http.Request, scheduleID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetSchedules(req *http.Request, page, pageSize, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) SavePerformanceProfile(tokenString string, performanceProfile *PerformanceProfile) ([]byte, error)

+ func (l *DefaultLocalProvider) SaveSchedule(tokenString string, schedule *Schedule) ([]byte, error)

+ func (l *DefaultLocalProvider) SetKubeClient(client *mesherykube.Client)

type ExtensionInput

+ Logger logger.Handler

+ MeshSyncChannel chan struct{}

type Feature

+ const PersistPerformanceProfiles

+ const PersistSchedules

type HandlerInterface

+ DeletePerformanceProfileHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ DeleteScheduleHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ FetchAllResultsHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ GetPerformanceProfileHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GetPerformanceProfilesHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GetScheduleHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GetSchedulesHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GraphqlSystemHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ SavePerformanceProfileHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ SaveScheduleHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

type MesheryPattern

+ CreatedAt *time.Time

+ UpdatedAt *time.Time

+ type MesheryPatternPage struct

+ Page uint64

+ PageSize uint64

+ Patterns []*MesheryPattern

+ TotalCount int

+ type MesheryPatternPersister struct

+ DB *database.Handler

+ func (mpp *MesheryPatternPersister) DeleteMesheryPattern(id uuid.UUID) ([]byte, error)

+ func (mpp *MesheryPatternPersister) GetMesheryPattern(id uuid.UUID) ([]byte, error)

+ func (mpp *MesheryPatternPersister) GetMesheryPatterns(search, order string, page, pageSize uint64) ([]byte, error)

+ func (mpp *MesheryPatternPersister) SaveMesheryPattern(pattern *MesheryPattern) ([]byte, error)

type MesheryResult

+ PerformanceProfile *uuid.UUID

+ PerformanceProfileInfo PerformanceProfile

+ TestID string

+ TestStartTime *time.Time

+ type MesheryResultsPersister struct

+ DB *database.Handler

+ func (mrp *MesheryResultsPersister) GetAllResults(page, pageSize uint64) ([]byte, error)

+ func (mrp *MesheryResultsPersister) GetResult(key uuid.UUID) (*MesheryResult, error)

+ func (mrp *MesheryResultsPersister) GetResults(page, pageSize uint64, profileID string) ([]byte, error)

+ func (mrp *MesheryResultsPersister) WriteResult(key uuid.UUID, result []byte) error

+ type PerformanceProfile struct

+ ConcurrentRequest int

+ ContentType string

+ CreatedAt *time.Time

+ Duration string

+ Endpoints pq.StringArray

+ ID *uuid.UUID

+ LastRun string

+ LoadGenerators pq.StringArray

+ Name string

+ QPS int

+ RequestBody string

+ RequestCookies string

+ RequestHeaders string

+ Schedule *uuid.UUID

+ ServiceMesh string

+ TotalResults int

+ UpdatedAt *time.Time

+ type PerformanceProfilePage struct

+ Page uint64

+ PageSize uint64

+ Profiles []*PerformanceProfile

+ TotalCount int

+ type PerformanceProfilePersister struct

+ DB *database.Handler

+ func (ppp *PerformanceProfilePersister) DeletePerformanceProfile(id uuid.UUID) ([]byte, error)

+ func (ppp *PerformanceProfilePersister) GetPerformanceProfile(id uuid.UUID) (*PerformanceProfile, error)

+ func (ppp *PerformanceProfilePersister) GetPerformanceProfiles(userID, search, order string, page, pageSize uint64) ([]byte, error)

+ func (ppp *PerformanceProfilePersister) SavePerformanceProfile(id uuid.UUID, profile *PerformanceProfile) error

type PerformanceSpec

+ ActualQPS float64

+ EnvID string

+ Latencies *LatenciesMs

+ MeshConfigID string

+ SMPVersion string

+ TestID string

type Provider

+ DeletePerformanceProfile func(req *http.Request, performanceProfileID string) ([]byte, error)

+ DeleteSchedule func(req *http.Request, scheduleID string) ([]byte, error)

+ FetchAllResults func(req *http.Request, page, pageSize, search, order, from, to string) ([]byte, error)

+ GetGraphqlHandler func() http.Handler

+ GetGraphqlPlayground func() http.Handler

+ GetKubeClient func() *mesherykube.Client

+ GetPerformanceProfile func(req *http.Request, performanceProfileID string) ([]byte, error)

+ GetPerformanceProfiles func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ GetSchedule func(req *http.Request, scheduleID string) ([]byte, error)

+ GetSchedules func(req *http.Request, page, pageSize, order string) ([]byte, error)

+ SavePerformanceProfile func(tokenString string, performanceProfile *PerformanceProfile) ([]byte, error)

+ SaveSchedule func(tokenString string, s *Schedule) ([]byte, error)

+ SetKubeClient func(client *mesherykube.Client)

type RemoteProvider

+ GraphqlHandler http.Handler

+ GraphqlPlayground http.Handler

+ KubeClient *mesherykube.Client

+ func (l *RemoteProvider) DeletePerformanceProfile(req *http.Request, performanceProfileID string) ([]byte, error)

+ func (l *RemoteProvider) DeleteSchedule(req *http.Request, scheduleID string) ([]byte, error)

+ func (l *RemoteProvider) FetchAllResults(req *http.Request, page, pageSize, search, order, from, to string) ([]byte, error)

+ func (l *RemoteProvider) GetGraphqlHandler() http.Handler

+ func (l *RemoteProvider) GetGraphqlPlayground() http.Handler

+ func (l *RemoteProvider) GetKubeClient() *mesherykube.Client

+ func (l *RemoteProvider) GetPerformanceProfile(req *http.Request, performanceProfileID string) ([]byte, error)

+ func (l *RemoteProvider) GetPerformanceProfiles(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) GetSchedule(req *http.Request, scheduleID string) ([]byte, error)

+ func (l *RemoteProvider) GetSchedules(req *http.Request, page, pageSize, order string) ([]byte, error)

+ func (l *RemoteProvider) SavePerformanceProfile(tokenString string, pp *PerformanceProfile) ([]byte, error)

+ func (l *RemoteProvider) SaveSchedule(tokenString string, s *Schedule) ([]byte, error)

+ func (l *RemoteProvider) SetKubeClient(client *mesherykube.Client)

+ type Schedule struct

+ CronExpression string

+ ID uuid.UUID

Feb 20, 2021

Changes in this version

+ func TarXZ(gzipStream io.Reader, destination string) error

+ func TarXZF(srcURL, destination string) error

+ type Capabilities []Capability

+ func (caps Capabilities) GetEndpointForFeature(feature Feature) (string, bool)

+ func (caps Capabilities) IsSupported(feature Feature) bool

type Capability

+ Endpoint string

+ Feature Feature

+ type Context struct

+ Adapters []string

+ Channel string

+ Endpoint string

+ Platform string

+ Token Token

type DefaultLocalProvider

+ GenericPersister database.Handler

+ ProviderBaseURL string

+ func (l *DefaultLocalProvider) DeleteMesheryPattern(req *http.Request, patternID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetGenericPersister() *database.Handler

+ func (l *DefaultLocalProvider) GetMesheryPattern(req *http.Request, patternID string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetMesheryPatterns(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetProviderCapabilities(w http.ResponseWriter, r *http.Request)

+ func (l *DefaultLocalProvider) Initialize()

+ func (l *DefaultLocalProvider) PackageLocation() string

+ func (l *DefaultLocalProvider) ReadMeshSyncData() ([]model.Object, error)

+ func (l *DefaultLocalProvider) RecordMeshSyncData(obj model.Object) error

+ func (l *DefaultLocalProvider) SaveMesheryPattern(tokenString string, pattern *MesheryPattern) ([]byte, error)

+ type ExtensionInput struct

+ DBHandler *database.Handler

+ type ExtensionOutput struct

+ Router *Router

+ type Extensions struct

+ GraphQL GraphQLExtensions

+ Navigator NavigatorExtensions

+ UserPrefs UserPrefsExtensions

+ type Feature string

+ const PersistMesheryPatterns

+ const PersistMetrics

+ const PersistResult

+ const PersistResults

+ const PersistSMIResult

+ const PersistSMIResults

+ const PersistSMPTestProfile

+ const SyncPrefs

+ type GraphQLExtension struct

+ Component string

+ Path string

+ type GraphQLExtensions []GraphQLExtension

type HandlerConfig

+ KubeClient *mesherykube.Client

type HandlerInterface

+ DeleteMesheryPatternHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ ExportPatternFile func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ ExtensionsEndpointHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ GetMesheryPatternHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ GetSMPServiceMeshes func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ ImportPatternFile func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ LoadExtensionFromPackage func(w http.ResponseWriter, req *http.Request, provider Provider) error

+ MeshSyncDataHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ OAMRegisterHandler func(rw http.ResponseWriter, r *http.Request)

+ OperatorHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ OperatorStatusHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ PatternFileHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ PatternFileRequestHandler func(rw http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ ProviderCapabilityHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ ProviderComponentsHandler func(w http.ResponseWriter, r *http.Request, prefObj *Preference, user *User, ...)

+ type Href struct

+ External *bool

+ URI string

+ type MesheryCtlConfig struct

+ Contexts map[string]Context

+ CurrentContext string

+ Tokens map[string]Token

+ type MesheryPattern struct

+ ID uuid.UUID

+ Name string

+ PatternFile string

+ type NavigatorExtension struct

+ Children NavigatorExtensions

+ Component string

+ Href Href

+ Icon string

+ Link *bool

+ Show *bool

+ Title string

+ type NavigatorExtensions []NavigatorExtension

type Provider

+ DeleteMesheryPattern func(req *http.Request, patternID string) ([]byte, error)

+ GetGenericPersister func() *database.Handler

+ GetMesheryPattern func(req *http.Request, patternID string) ([]byte, error)

+ GetMesheryPatterns func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ GetProviderCapabilities func(http.ResponseWriter, *http.Request)

+ Initialize func()

+ PackageLocation func() string

+ ReadMeshSyncData func() ([]model.Object, error)

+ RecordMeshSyncData func(model.Object) error

+ SaveMesheryPattern func(tokenString string, pattern *MesheryPattern) ([]byte, error)

type ProviderProperties

+ Extensions Extensions

+ PackageURL string

+ PackageVersion string

+ ProviderDescription []string

+ ProviderName string

+ ProviderType ProviderType

+ type RemoteProvider struct

+ GenericPersister database.Handler

+ Keys []map[string]string

+ LoginCookieDuration time.Duration

+ ProviderVersion string

+ RefCookieName string

+ RemoteProviderURL string

+ SaaSTokenName string

+ SessionName string

+ SmiResultPersister *BitCaskSmiResultsPersister

+ TokenStore map[string]string

+ TokenStoreMut sync.Mutex

+ func (l *RemoteProvider) DecodeTokenData(tokenStringB64 string) (*oauth2.Token, error)

+ func (l *RemoteProvider) DeleteMesheryPattern(req *http.Request, patternID string) ([]byte, error)

+ func (l *RemoteProvider) Description() []string

+ func (l *RemoteProvider) DoRequest(req *http.Request, tokenString string) (*http.Response, error)

+ func (l *RemoteProvider) ExtractToken(w http.ResponseWriter, r *http.Request)

+ func (l *RemoteProvider) FetchResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) FetchSmiResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) GenerateKey(jwk JWK) (*rsa.PublicKey, error)

+ func (l *RemoteProvider) GetGenericPersister() *database.Handler

+ func (l *RemoteProvider) GetJWK(kid string) (JWK, error)

+ func (l *RemoteProvider) GetMesheryPattern(req *http.Request, patternID string) ([]byte, error)

+ func (l *RemoteProvider) GetMesheryPatterns(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) GetProviderCapabilities(w http.ResponseWriter, r *http.Request)

+ func (l *RemoteProvider) GetProviderProperties() ProviderProperties

+ func (l *RemoteProvider) GetProviderToken(req *http.Request) (string, error)

+ func (l *RemoteProvider) GetProviderType() ProviderType

+ func (l *RemoteProvider) GetResult(req *http.Request, resultID uuid.UUID) (*MesheryResult, error)

+ func (l *RemoteProvider) GetSession(req *http.Request) error

+ func (l *RemoteProvider) GetToken(req *http.Request) (string, error)

+ func (l *RemoteProvider) GetUserDetails(req *http.Request) (*User, error)

+ func (l *RemoteProvider) Initialize()

+ func (l *RemoteProvider) InitiateLogin(w http.ResponseWriter, r *http.Request, _ bool)

+ func (l *RemoteProvider) Logout(w http.ResponseWriter, req *http.Request)

+ func (l *RemoteProvider) Name() string

+ func (l *RemoteProvider) PackageLocation() string

+ func (l *RemoteProvider) PublishMetrics(tokenString string, result *MesheryResult) error

+ func (l *RemoteProvider) PublishResults(req *http.Request, result *MesheryResult) (string, error)

+ func (l *RemoteProvider) PublishSmiResults(result *SmiResult) (string, error)

+ func (l *RemoteProvider) ReadMeshSyncData() ([]model.Object, error)

+ func (l *RemoteProvider) RecordMeshSyncData(obj model.Object) error

+ func (l *RemoteProvider) RecordPreferences(req *http.Request, userID string, data *Preference) error

+ func (l *RemoteProvider) SMPTestConfigDelete(req *http.Request, testUUID string) error

+ func (l *RemoteProvider) SMPTestConfigFetch(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *RemoteProvider) SMPTestConfigGet(req *http.Request, testUUID string) (*SMP.PerformanceTestConfig, error)

+ func (l *RemoteProvider) SMPTestConfigStore(req *http.Request, perfConfig *SMP.PerformanceTestConfig) (string, error)

+ func (l *RemoteProvider) SaveMesheryPattern(tokenString string, pattern *MesheryPattern) ([]byte, error)

+ func (l *RemoteProvider) StopSyncPreferences()

+ func (l *RemoteProvider) SyncPreferences()

+ func (l *RemoteProvider) TokenHandler(w http.ResponseWriter, r *http.Request, fromMiddleWare bool)

+ func (l *RemoteProvider) UpdateJWKs() error

+ func (l *RemoteProvider) UpdateToken(w http.ResponseWriter, r *http.Request)

+ func (l *RemoteProvider) VerifyToken(tokenString string) (*jwt.MapClaims, error)

+ type Router struct

+ HTTPHandler http.Handler

+ Path string

+ type Token struct

+ Location string

+ Name string

+ type UserPrefsExtension struct

+ Component string

+ type UserPrefsExtensions []UserPrefsExtension

Oct 28, 2020

Changes in this version

type MesheryRemoteProvider

+ SmiResultPersister *BitCaskSmiResultsPersister

type PerformanceSpec

+ LoadGenerator string

Sep 24, 2020

Changes in this version

+ func SMPPerformanceTestConfigValidator(perfTest *SMP.PerformanceTestConfig) error

+ type BitCaskSmiResultsPersister struct

+ func NewBitCaskSmiResultsPersister(folderName string) (*BitCaskSmiResultsPersister, error)

+ func (s *BitCaskSmiResultsPersister) CloseResultPersister()

+ func (s *BitCaskSmiResultsPersister) GetResults(page, pageSize uint64) ([]byte, error)

+ func (s *BitCaskSmiResultsPersister) WriteResult(key uuid.UUID, result []byte) error

type DefaultLocalProvider

+ SmiResultPersister *BitCaskSmiResultsPersister

+ func (l *DefaultLocalProvider) FetchSmiResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) PublishSmiResults(result *SmiResult) (string, error)

+ func (l *DefaultLocalProvider) SMPTestConfigDelete(req *http.Request, testUUID string) error

+ func (l *DefaultLocalProvider) SMPTestConfigFetch(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) SMPTestConfigGet(req *http.Request, testUUID string) (*SMP.PerformanceTestConfig, error)

+ func (l *DefaultLocalProvider) SMPTestConfigStore(req *http.Request, perfConfig *SMP.PerformanceTestConfig) (string, error)

+ type Detail struct

+ Assertions string

+ Capability string

+ Reason string

+ Result string

+ SmiSpecification string

+ SmiVersion string

+ Status string

+ Time string

type HandlerInterface

+ FetchSmiResultsHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ LoadTestUsingSMPHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

type MesheryRemoteProvider

+ func (l *MesheryRemoteProvider) FetchSmiResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *MesheryRemoteProvider) PublishSmiResults(result *SmiResult) (string, error)

+ func (l *MesheryRemoteProvider) SMPTestConfigDelete(req *http.Request, testUUID string) error

+ func (l *MesheryRemoteProvider) SMPTestConfigFetch(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *MesheryRemoteProvider) SMPTestConfigGet(req *http.Request, testUUID string) (*SMP.PerformanceTestConfig, error)

+ func (l *MesheryRemoteProvider) SMPTestConfigStore(req *http.Request, perfConfig *SMP.PerformanceTestConfig) (string, error)

type Provider

+ FetchSmiResults func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ PublishSmiResults func(result *SmiResult) (string, error)

+ SMPTestConfigDelete func(req *http.Request, testUUID string) error

+ SMPTestConfigFetch func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ SMPTestConfigGet func(req *http.Request, testUUID string) (*SMP.PerformanceTestConfig, error)

+ SMPTestConfigStore func(req *http.Request, perfConfig *SMP.PerformanceTestConfig) (string, error)

+ type SmiResult struct

+ CasesPassed string

+ Date string

+ ID uuid.UUID

+ MeshName string

+ MeshVersion string

+ MoreDetails []*Detail

+ PassingPercentage string

+ Status string

+ type SmiResultPage struct

+ Page uint64

+ PageSize uint64

+ Results []*SmiResult

+ TotalCount int

Aug 27, 2020

Changes in this version

type HandlerInterface

+ ScanPrometheusHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

type LoadGenerator

+ const NighthawkLG

Aug 17, 2020

Changes in this version

+ func SMPSPerformanceTestConfigValidator(perfTest *SMPS.PerformanceTestConfig) error

+ type BitCaskTestProfilesPersister struct

+ func NewBitCaskTestProfilesPersister(folderName string) (*BitCaskTestProfilesPersister, error)

+ func (s *BitCaskTestProfilesPersister) CloseTestConfigsPersister()

+ func (s *BitCaskTestProfilesPersister) DeleteTestConfig(key uuid.UUID) error

+ func (s *BitCaskTestProfilesPersister) GetTestConfig(key uuid.UUID) (*SMPS.PerformanceTestConfig, error)

+ func (s *BitCaskTestProfilesPersister) GetTestConfigs(page, pageSize uint64) ([]byte, error)

+ func (s *BitCaskTestProfilesPersister) WriteTestConfig(key uuid.UUID, result []byte) error

type DefaultLocalProvider

+ TestProfilesPersister *BitCaskTestProfilesPersister

+ func (l *DefaultLocalProvider) SMPSTestConfigDelete(req *http.Request, testUUID string) error

+ func (l *DefaultLocalProvider) SMPSTestConfigFetch(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) SMPSTestConfigGet(req *http.Request, testUUID string) (*SMPS.PerformanceTestConfig, error)

+ func (l *DefaultLocalProvider) SMPSTestConfigStore(req *http.Request, perfConfig *SMPS.PerformanceTestConfig) (string, error)

type HandlerInterface

+ UserTestPreferenceDelete func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ UserTestPreferenceGet func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ UserTestPreferenceHandler func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

+ UserTestPreferenceStore func(w http.ResponseWriter, req *http.Request, prefObj *Preference, user *User, ...)

type MesheryRemoteProvider

+ func (l *MesheryRemoteProvider) SMPSTestConfigDelete(req *http.Request, testUUID string) error

+ func (l *MesheryRemoteProvider) SMPSTestConfigFetch(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *MesheryRemoteProvider) SMPSTestConfigGet(req *http.Request, testUUID string) (*SMPS.PerformanceTestConfig, error)

+ func (l *MesheryRemoteProvider) SMPSTestConfigStore(req *http.Request, perfConfig *SMPS.PerformanceTestConfig) (string, error)

type Provider

+ SMPSTestConfigDelete func(req *http.Request, testUUID string) error

+ SMPSTestConfigFetch func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ SMPSTestConfigGet func(req *http.Request, testUUID string) (*SMPS.PerformanceTestConfig, error)

+ SMPSTestConfigStore func(req *http.Request, perfConfig *SMPS.PerformanceTestConfig) (string, error)

+ type UserTestProfiles struct

+ Page uint64

+ PageSize uint64

+ TestConfigs []*SMPS.PerformanceTestConfig

+ TotalCount int

Jul 5, 2020

Changes in this version

type HandlerInterface

+ ServerVersionHandler func(w http.ResponseWriter, r *http.Request)

type LoadTestOptions

+ SupportedLoadTestMethods SupportedLoadTestMethods

+ type SupportedLoadTestMethods int

+ const HTTP

+ const TCP

Jun 23, 2020

Changes in this version

type LoadTestOptions

+ Body []byte

+ ContentType string

+ Cookies *map[string]string

+ Headers *map[string]string

Apr 30, 2020

Changes in this version

+ func SafeClose(co io.Closer)

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) ExtractToken(w http.ResponseWriter, r *http.Request)

+ func (l *DefaultLocalProvider) TokenHandler(w http.ResponseWriter, r *http.Request, fromMiddleWare bool)

+ func (l *DefaultLocalProvider) UpdateToken(http.ResponseWriter, *http.Request)

type HandlerInterface

+ TokenHandler func(w http.ResponseWriter, r *http.Request, provider Provider, fromMiddleWare bool)

+ type JWK map[string]string

type MesheryRemoteProvider

+ Keys []map[string]string

+ ProviderVersion string

+ TokenStore map[string]string

+ TokenStoreMut sync.Mutex

+ func (l *MesheryRemoteProvider) DecodeTokenData(tokenStringB64 string) (*oauth2.Token, error)

+ func (l *MesheryRemoteProvider) DoRequest(req *http.Request, tokenString string) (*http.Response, error)

+ func (l *MesheryRemoteProvider) ExtractToken(w http.ResponseWriter, r *http.Request)

+ func (l *MesheryRemoteProvider) GenerateKey(jwk JWK) (*rsa.PublicKey, error)

+ func (l *MesheryRemoteProvider) GetJWK(kid string) (JWK, error)

+ func (l *MesheryRemoteProvider) GetToken(req *http.Request) (string, error)

+ func (l *MesheryRemoteProvider) TokenHandler(w http.ResponseWriter, r *http.Request, fromMiddleWare bool)

+ func (l *MesheryRemoteProvider) UpdateJWKs() error

+ func (l *MesheryRemoteProvider) UpdateToken(w http.ResponseWriter, r *http.Request)

+ func (l *MesheryRemoteProvider) VerifyToken(tokenString string) (*jwt.MapClaims, error)

+ type PerformanceSpec struct

+ Client *MeshClientConfig

+ Config *MeshConfig

+ DetailsURI string

+ EndTime time.Time

+ EndpointURL string

+ Env *Environment

+ ExpGroupUUID string

+ ExpUUID string

+ MeshBuild string

+ Metrics *Metrics

+ Profile string

+ ProxyBuild string

+ StartTime time.Time

type Provider

+ ExtractToken func(http.ResponseWriter, *http.Request)

+ TokenHandler func(http.ResponseWriter, *http.Request, bool)

+ UpdateToken func(http.ResponseWriter, *http.Request)

Apr 15, 2020

Changes in this version

type HandlerInterface

+ ScanGrafanaHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ ScanPromGrafanaHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ ScanPromotheusHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

Apr 10, 2020

Changes in this version

+ type Capability struct

+ FeatureName string

+ IsPresent bool

type DefaultLocalProvider

+ func (l *DefaultLocalProvider) GetProviderProperties() ProviderProperties

type MesheryRemoteProvider

+ func (l *MesheryRemoteProvider) GetProviderProperties() ProviderProperties

type Provider

+ GetProviderProperties func() ProviderProperties

+ type ProviderProperties struct

+ Capabilities []Capability

+ Description string

+ DisplayName string

Mar 9, 2020

Changes in this version

+ type BenchmarkSpec struct

+ Client *MeshClientConfig

+ Config *MeshConfig

+ DetailsURI string

+ EndTime time.Time

+ EndpointURL string

+ Env *Environment

+ ExpGroupUUID string

+ ExpUUID string

+ MeshBuild string

+ Metrics *Metrics

+ Profile string

+ ProxyBuild string

+ StartTime time.Time

type BitCaskResultsPersister

+ func (s *BitCaskResultsPersister) GetResult(key uuid.UUID) (*MesheryResult, error)

+ type DefaultLocalProvider struct

+ ResultPersister *BitCaskResultsPersister

+ SaaSBaseURL string

+ func (l *DefaultLocalProvider) Description() string

+ func (l *DefaultLocalProvider) FetchResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *DefaultLocalProvider) GetProviderToken(req *http.Request) (string, error)

+ func (l *DefaultLocalProvider) GetProviderType() ProviderType

+ func (l *DefaultLocalProvider) GetResult(req *http.Request, resultID uuid.UUID) (*MesheryResult, error)

+ func (l *DefaultLocalProvider) GetSession(req *http.Request) (*sessions.Session, error)

+ func (l *DefaultLocalProvider) GetUserDetails(req *http.Request) (*User, error)

+ func (l *DefaultLocalProvider) InitiateLogin(w http.ResponseWriter, r *http.Request, fromMiddleWare bool)

+ func (l *DefaultLocalProvider) Logout(w http.ResponseWriter, req *http.Request)

+ func (l *DefaultLocalProvider) Name() string

+ func (l *DefaultLocalProvider) PublishMetrics(_ string, result *MesheryResult) error

+ func (l *DefaultLocalProvider) PublishResults(req *http.Request, result *MesheryResult) (string, error)

+ func (l *DefaultLocalProvider) RecordPreferences(req *http.Request, userID string, data *Preference) error

+ type Environment struct

+ Kubernetes string

+ NodeCount int

type HandlerConfig

+ ProviderCookieDuration time.Duration

+ ProviderCookieName string

+ Providers map[string]Provider

type HandlerInterface

+ GetResultHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ LoadTestUsingSMPSHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ ProviderHandler func(w http.ResponseWriter, r *http.Request)

+ ProviderMiddleware func(http.Handler) http.Handler

+ ProviderUIHandler func(w http.ResponseWriter, r *http.Request)

+ ProvidersHandler func(w http.ResponseWriter, r *http.Request)

+ type IngressGateway struct

+ Bps float64

+ CPUMCores float64

+ Count int

+ MemMb float64

+ Rps float64

+ type LatenciesMs struct

+ Average float64

+ Max float64

+ Min float64

+ P50 float64

+ P90 float64

+ P99 float64

+ type MeshClientConfig struct

+ Connections int

+ Internal bool

+ LatenciesMs *LatenciesMs

+ Protocol string

+ Rps float64

+ type MeshConfig struct

+ MeshPolicyEnabled bool

+ MeshTelemetryEnabled bool

+ MtlsEnabled bool

+ ProxyConcurrency int

+ type MeshControlPlane struct

+ CPUMCores float64

+ CdsLatencyMs float64

+ Count int

+ DestinationRules int

+ Endpoints int

+ LdsLatencyMs float64

+ MemMb float64

+ Services int

+ Sidecars int

+ VirtualServices int

+ type MeshPolicy struct

+ CPUMCores float64

+ CacheHitRate float64

+ Count int

+ MemMb float64

+ Rps float64

+ type MeshTelemetry struct

+ CPUMCores float64

+ Count int

+ MemMb float64

+ Rps float64

+ type MesheryRemoteProvider struct

+ LoginCookieDuration time.Duration

+ RefCookieName string

+ SaaSBaseURL string

+ SaaSTokenName string

+ SessionName string

+ SessionStore sessions.Store

+ func (l *MesheryRemoteProvider) Description() string

+ func (l *MesheryRemoteProvider) FetchResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *MesheryRemoteProvider) GetProviderToken(req *http.Request) (string, error)

+ func (l *MesheryRemoteProvider) GetProviderType() ProviderType

+ func (l *MesheryRemoteProvider) GetResult(req *http.Request, resultID uuid.UUID) (*MesheryResult, error)

+ func (l *MesheryRemoteProvider) GetSession(req *http.Request) (*sessions.Session, error)

+ func (l *MesheryRemoteProvider) GetUserDetails(req *http.Request) (*User, error)

+ func (l *MesheryRemoteProvider) InitiateLogin(w http.ResponseWriter, r *http.Request, _ bool)

+ func (l *MesheryRemoteProvider) Logout(w http.ResponseWriter, req *http.Request)

+ func (l *MesheryRemoteProvider) Name() string

+ func (l *MesheryRemoteProvider) PublishMetrics(tokenVal string, result *MesheryResult) error

+ func (l *MesheryRemoteProvider) PublishResults(req *http.Request, result *MesheryResult) (string, error)

+ func (l *MesheryRemoteProvider) RecordPreferences(req *http.Request, userID string, data *Preference) error

+ func (l *MesheryRemoteProvider) StopSyncPreferences()

+ func (l *MesheryRemoteProvider) SyncPreferences()

type MesheryResult

+ func (m *MesheryResult) ConvertToSpec() (*BenchmarkSpec, error)

+ type Metrics struct

+ IndividualWorkload *Workload

+ IngressGateway *IngressGateway

+ MeshControlPlane *MeshControlPlane

+ MeshPolicy *MeshPolicy

+ MeshTelemetry *MeshTelemetry

+ Sidecars *Sidecars

type Provider

+ GetResult func(*http.Request, uuid.UUID) (*MesheryResult, error)

+ Name func() string

type ProviderType

+ const ProviderCtxKey

+ const RemoteProviderType

+ type Sidecars struct

+ Bps float64

+ CPUMCores float64

+ Count int

+ MemMb float64

+ Rps float64

type SubmitMetricsConfig

+ Provider Provider

+ type Workload struct

+ CPUMCores float64

+ Count int

+ MemMb float64

+ Name string

Jan 15, 2020

Changes in this version

type HandlerInterface

+ AnonymousStatsHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ LoadTestPrefencesHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ PrometheusPingHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

type LoadGenerator

+ func (l LoadGenerator) Name() string

+ type LoadTestPreferences struct

+ ConcurrentRequests int

+ Duration string

+ LoadGenerator string

+ QueriesPerSecond int

type Preference

+ AnonymousPerfResults bool

+ AnonymousUsageStats bool

+ LoadTestPreferences *LoadTestPreferences

Jan 14, 2020

Changes in this version

type HandlerInterface

+ GetProviderType func() ProviderType

+ GrafanaPingHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

Dec 21, 2019

Changes in this version

+ var GlobalTokenForAnonymousResults = "dev_token"

+ type BitCaskPreferencePersister struct

+ func NewBitCaskPreferencePersister(folderName string) (*BitCaskPreferencePersister, error)

+ func (s *BitCaskPreferencePersister) ClosePersister()

+ func (s *BitCaskPreferencePersister) DeleteFromPersister(userID string) error

+ func (s *BitCaskPreferencePersister) ReadFromPersister(userID string) (*Preference, error)

+ func (s *BitCaskPreferencePersister) WriteToPersister(userID string, data *Preference) error

+ type BitCaskResultsPersister struct

+ func NewBitCaskResultsPersister(folderName string) (*BitCaskResultsPersister, error)

+ func (s *BitCaskResultsPersister) CloseResultPersister()

+ func (s *BitCaskResultsPersister) GetResults(page, pageSize uint64) ([]byte, error)

+ func (s *BitCaskResultsPersister) WriteResult(result []byte) error

+ type CloudProvider struct

+ LoginCookieDuration time.Duration

+ RefCookieName string

+ SaaSBaseURL string

+ SaaSTokenName string

+ SessionName string

+ SessionStore sessions.Store

+ func (l *CloudProvider) FetchResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *CloudProvider) GetProviderToken(req *http.Request) (string, error)

+ func (l *CloudProvider) GetProviderType() ProviderType

+ func (l *CloudProvider) GetSession(req *http.Request) (*sessions.Session, error)

+ func (l *CloudProvider) GetUserDetails(req *http.Request) (*User, error)

+ func (l *CloudProvider) InitiateLogin(w http.ResponseWriter, r *http.Request)

+ func (l *CloudProvider) Logout(w http.ResponseWriter, req *http.Request)

+ func (l *CloudProvider) PublishMetrics(tokenVal string, data []byte) error

+ func (l *CloudProvider) PublishResults(req *http.Request, data []byte) (string, error)

+ func (l *CloudProvider) RecordPreferences(req *http.Request, userID string, data *Preference) error

+ func (l *CloudProvider) StopSyncPreferences()

+ func (l *CloudProvider) SyncPreferences()

type HandlerConfig

+ Provider Provider

+ type LocalProvider struct

+ ResultPersister *BitCaskResultsPersister

+ SaaSBaseURL string

+ SessionName string

+ SessionStore sessions.Store

+ func (l *LocalProvider) FetchResults(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ func (l *LocalProvider) GetProviderToken(req *http.Request) (string, error)

+ func (l *LocalProvider) GetProviderType() ProviderType

+ func (l *LocalProvider) GetSession(req *http.Request) (*sessions.Session, error)

+ func (l *LocalProvider) GetUserDetails(req *http.Request) (*User, error)

+ func (l *LocalProvider) InitiateLogin(w http.ResponseWriter, r *http.Request)

+ func (l *LocalProvider) Logout(w http.ResponseWriter, req *http.Request)

+ func (l *LocalProvider) PublishMetrics(_ string, data []byte) error

+ func (l *LocalProvider) PublishResults(req *http.Request, data []byte) (string, error)

+ func (l *LocalProvider) RecordPreferences(req *http.Request, userID string, data *Preference) error

+ type MapPreferencePersister struct

+ func NewMapPreferencePersister() (*MapPreferencePersister, error)

+ func (s *MapPreferencePersister) ClosePersister()

+ func (s *MapPreferencePersister) DeleteFromPersister(userID string) error

+ func (s *MapPreferencePersister) ReadFromPersister(userID string) (*Preference, error)

+ func (s *MapPreferencePersister) WriteToPersister(userID string, data *Preference) error

+ type MesheryResultPage struct

+ Page uint64

+ PageSize uint64

+ Results []*MesheryResult

+ TotalCount int

+ type Preference struct

+ Grafana *Grafana

+ K8SConfig *K8SConfig

+ MeshAdapters []*Adapter

+ Prometheus *Prometheus

+ UpdatedAt time.Time

+ type PreferencePersister interface

+ ClosePersister func()

+ DeleteFromPersister func(userID string) error

+ ReadFromPersister func(userID string) (*Preference, error)

+ WriteToPersister func(userID string, data *Preference) error

+ type Provider interface

+ FetchResults func(req *http.Request, page, pageSize, search, order string) ([]byte, error)

+ GetProviderToken func(req *http.Request) (string, error)

+ GetProviderType func() ProviderType

+ GetSession func(req *http.Request) (*sessions.Session, error)

+ GetUserDetails func(*http.Request) (*User, error)

+ InitiateLogin func(http.ResponseWriter, *http.Request)

+ Logout func(http.ResponseWriter, *http.Request)

+ PublishMetrics func(tokenVal string, data []byte) error

+ PublishResults func(req *http.Request, data []byte) (string, error)

+ RecordPreferences func(req *http.Request, userID string, data *Preference) error

+ type ProviderType string

+ const CloudProviderType

+ const LocalProviderType

+ type UserPref struct

+ Preferences *Preference

Nov 12, 2019

Changes in this version

+ type LoadGenerator string

+ const FortioLG

+ const Wrk2LG

type LoadTestOptions

+ LoadGenerator LoadGenerator

Nov 7, 2019

Changes in this version

+ type GrafanaClient struct

+ func NewGrafanaClient() *GrafanaClient

+ func NewGrafanaClientForPrometheusWithHTTPClient(client *http.Client) *GrafanaClient

+ func NewGrafanaClientWithHTTPClient(client *http.Client) *GrafanaClient

+ func (g *GrafanaClient) Close()

+ func (g *GrafanaClient) GetGrafanaBoards(ctx context.Context, BaseURL, APIKey, dashboardSearch string) ([]*GrafanaBoard, error)

+ func (g *GrafanaClient) GrafanaQuery(ctx context.Context, BaseURL, APIKey string, queryData *url.Values) ([]byte, error)

+ func (g *GrafanaClient) GrafanaQueryRange(ctx context.Context, BaseURL, APIKey string, queryData *url.Values) ([]byte, error)

+ func (g *GrafanaClient) ProcessBoard(c *sdk.Client, board *sdk.Board, link *sdk.FoundBoard) (*GrafanaBoard, error)

+ func (g *GrafanaClient) Validate(ctx context.Context, BaseURL, APIKey string) error

type HandlerConfig

+ GrafanaClient *GrafanaClient

+ GrafanaClientForQuery *GrafanaClient

+ PrometheusClient *PrometheusClient

+ PrometheusClientForQuery *PrometheusClient

+ type PrometheusClient struct

+ func NewPrometheusClient() *PrometheusClient

+ func NewPrometheusClientWithHTTPClient(client *http.Client) *PrometheusClient

+ func (p *PrometheusClient) Close()

+ func (p *PrometheusClient) ComputeStep(ctx context.Context, start, end time.Time) time.Duration

+ func (p *PrometheusClient) GetClusterStaticBoard(ctx context.Context, promURL string) (*GrafanaBoard, error)

+ func (p *PrometheusClient) GetNodesStaticBoard(ctx context.Context, promURL string) (*GrafanaBoard, error)

+ func (p *PrometheusClient) ImportGrafanaBoard(ctx context.Context, boardData []byte) (*GrafanaBoard, error)

+ func (p *PrometheusClient) Query(ctx context.Context, promURL string, queryData *url.Values) ([]byte, error)

+ func (p *PrometheusClient) QueryRange(ctx context.Context, promURL string, queryData *url.Values) ([]byte, error)

+ func (p *PrometheusClient) QueryRangeUsingClient(ctx context.Context, promURL, query string, startTime, endTime time.Time, ...) (promModel.Value, error)

+ func (p *PrometheusClient) Validate(ctx context.Context, promURL string) error

Oct 23, 2019

Changes in this version

type HandlerInterface

+ InstalledMeshesHandler func(w http.ResponseWriter, req *http.Request, session *sessions.Session, ...)

+ SessionInjectorMiddleware func(func(http.ResponseWriter, *http.Request, *sessions.Session, *User)) http.Handler

+ type LoadTestResponse struct

+ Message string

+ Result *MesheryResult

+ Status LoadTestStatus

+ type LoadTestStatus string

+ const LoadTestError

+ const LoadTestInfo

+ const LoadTestSuccess

Oct 13, 2019

Changes in this version

type HandlerInterface

+ KubernetesPingHandler func(w http.ResponseWriter, req *http.Request)

type K8SConfig

+ Nodes []*K8SNode

+ ServerVersion string

+ type K8SNode struct

+ AllocatableCPU string

+ AllocatableMemory string

+ Architecture string

+ CapacityCPU string

+ CapacityMemory string

+ ContainerRuntimeVersion string

+ HostName string

+ InternalIP string

+ KubeProxyVersion string

+ KubeletVersion string

+ OSImage string

+ OperatingSystem string

Sep 12, 2019

Changes in this version

+ type Adapter struct

+ Location string

+ Name string

+ Ops []*meshes.SupportedOperation

+ type AdaptersTrackerInterface interface

+ AddAdapter func(context.Context, string)

+ GetAdapters func(context.Context) []string

+ RemoveAdapter func(context.Context, string)

+ type Grafana struct

+ GrafanaAPIKey string

+ GrafanaBoards []*SelectedGrafanaConfig

+ GrafanaURL string

+ type GrafanaBoard struct

+ OrgID uint

+ Panels []*sdk.Panel

+ Slug string

+ TemplateVars []*GrafanaTemplateVars

+ Title string

+ UID string

+ URI string

+ type GrafanaDataSource struct

+ ID uint

+ Name string

+ type GrafanaPanel struct

+ ID uint

+ PType string

+ Title string

+ type GrafanaTemplateVars struct

+ Datasource *GrafanaDataSource

+ Hide uint8

+ Name string

+ Query string

+ Value interface{}

type HandlerConfig

+ AdapterTracker AdaptersTrackerInterface

+ KubeConfigFolder string

+ QueryTracker QueryTrackerInterface

+ Queue taskq.Queue

+ SessionPersister SessionPersister

type HandlerInterface

+ AdapterPingHandler func(w http.ResponseWriter, req *http.Request)

+ CollectStaticMetrics func(config *SubmitMetricsConfig) error

+ EventStreamHandler func(w http.ResponseWriter, req *http.Request)

+ FetchResultsHandler func(w http.ResponseWriter, req *http.Request)

+ GetAllAdaptersHandler func(w http.ResponseWriter, req *http.Request)

+ GetContextsFromK8SConfig func(w http.ResponseWriter, req *http.Request)

+ GrafanaBoardImportForPrometheusHandler func(w http.ResponseWriter, req *http.Request)

+ GrafanaBoardsHandler func(w http.ResponseWriter, req *http.Request)

+ GrafanaConfigHandler func(w http.ResponseWriter, req *http.Request)

+ GrafanaQueryHandler func(w http.ResponseWriter, req *http.Request)

+ GrafanaQueryRangeHandler func(w http.ResponseWriter, req *http.Request)

+ MeshAdapterConfigHandler func(w http.ResponseWriter, req *http.Request)

+ PrometheusConfigHandler func(w http.ResponseWriter, req *http.Request)

+ PrometheusQueryHandler func(w http.ResponseWriter, req *http.Request)

+ PrometheusQueryRangeHandler func(w http.ResponseWriter, req *http.Request)

+ PrometheusStaticBoardHandler func(w http.ResponseWriter, req *http.Request)

+ SaveSelectedGrafanaBoardsHandler func(w http.ResponseWriter, req *http.Request)

+ SaveSelectedPrometheusBoardsHandler func(w http.ResponseWriter, req *http.Request)

+ SessionSyncHandler func(w http.ResponseWriter, req *http.Request)

+ type K8SConfig struct

+ ClusterConfigured bool

+ Config []byte

+ ContextName string

+ InClusterConfig bool

+ K8Sfile string

+ Server string

+ type K8SContext struct

+ ClusterName string

+ ContextName string

+ IsCurrentContext bool

+ type LoadTestOptions struct

+ AllowInitialErrors bool

+ CACert string

+ Cert string

+ Duration time.Duration

+ GRPCDoHealth bool

+ GRPCDoPing bool

+ GRPCHealthSvc string

+ GRPCPingDelay time.Duration

+ GRPCStreamsCount int

+ HTTPNumThreads int

+ HTTPQPS float64

+ IsGRPC bool

+ IsInsecure bool

+ Key string

+ Name string

+ URL string

+ type MesheryResult struct

+ ID uuid.UUID

+ Mesh string

+ Name string

+ Result map[string]interface{}

+ ServerBoardConfig interface{}

+ ServerMetrics interface{}

+ type Prometheus struct

+ PrometheusURL string

+ SelectedPrometheusBoardsConfigs []*SelectedGrafanaConfig

+ type QueryTrackerInterface interface

+ AddOrFlagQuery func(ctx context.Context, uuid, query string, flag bool)

+ GetQueriesForUUID func(ctx context.Context, uuid string) map[string]bool

+ RemoveUUID func(ctx context.Context, uuid string)

+ type SelectedGrafanaConfig struct

+ GrafanaBoard *GrafanaBoard

+ GrafanaPanels []*sdk.Panel

+ SelectedTemplateVars []string

+ type Session struct

+ Grafana *Grafana

+ K8SConfig *K8SConfig

+ MeshAdapters []*Adapter

+ Prometheus *Prometheus

+ type SessionPersister interface

+ Close func()

+ Delete func(userID string) error

+ Read func(userID string) (*Session, error)

+ Write func(userID string, data *Session) error

+ type SubmitMetricsConfig struct

+ EndTime time.Time

+ PromURL string

+ ResultID string

+ StartTime time.Time

+ TestUUID string

+ TokenKey string

+ TokenVal string

type User

+ UserID string

Mar 1, 2019

Changes in this version

+ type HandlerConfig struct

+ ByPassAuth bool

+ FortioURL string

+ RefCookieName string

+ SaaSBaseURL string

+ SaaSTokenName string

+ SessionName string

+ SessionStore sessions.Store

+ type HandlerInterface interface

+ AuthMiddleware func(next http.Handler) http.Handler

+ K8SConfigHandler func(ctx context.Context) func(w http.ResponseWriter, r *http.Request)

+ LoadTestHandler func(w http.ResponseWriter, req *http.Request)

+ LoginHandler func(w http.ResponseWriter, r *http.Request)

+ LogoutHandler func(w http.ResponseWriter, req *http.Request)

+ MeshOpsHandler func(ctx context.Context) func(w http.ResponseWriter, req *http.Request)

+ UserHandler func(ctx context.Context) func(w http.ResponseWriter, r *http.Request)

+ type User struct

+ AvatarURL string

+ FirstName string

+ LastName string

+ UserId string