model

package
v0.0.0-...-28249f4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 5, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrNilClientCode                             = "1300"
	ErrCreateDataCode                            = "1301"
	ErrQueryCode                                 = "1302"
	ErrMeshsyncSubscriptionCode                  = "1303"
	ErrMeshplayClientCode                        = "1304"
	ErrSubscribeChannelCode                      = "1305"
	ErrPublishBrokerCode                         = "1306"
	ErrEmptyHandlerCode                          = "1307"
	ErrApplyHelmChartCode                        = "1308"
	ErrMeshplayControllersStatusSubscriptionCode = "1309"
	ErrMeshSyncEventsSubscriptionCode            = "1310"
	ErrMeshplayClientNilCode                     = "1311"
	ErrUpdateDataCode                            = "1312"
	ErrDeleteDataCode                            = "1313"
)

Please reference the following before contributing an error code: https://docs.khulnasoft.com/project/contributing/contributing-error https://github.com/khulnasoft/meshkit/blob/master/errors/errors.go

View Source 
const (
	Namespace                = "meshplay"
	RequestSubject           = "meshplay.meshsync.request"
	MeshsyncSubject          = "meshplay.meshsync.core"
	BrokerQueue              = "meshplay"
	MeshSyncBrokerConnection = "meshsync"
)

Variables

View Source 
var (
	ErrEmptyHandler      = errors.New(ErrEmptyHandlerCode, errors.Alert, []string{"Database handler not initialized"}, []string{"Meshplay Database handler is not accessible to perform operations"}, []string{"Meshplay Database is crashed or not reachable"}, []string{"Restart Meshplay Server", "Please check if Meshplay server is accessible to the Database"})
	ErrMeshplayClientNil = errors.New(ErrMeshplayClientNilCode, errors.Alert, []string{"Meshplay kubernetes client not initialized"}, []string{"Kubernetes config is not initialized with Meshplay 2"}, []string{}, []string{"Upload your kubernetes config via the settings dashboard. If uploaded, wait for a minute for it to get initialized"})
)
View Source 
var AllMeshSyncEventType = []MeshSyncEventType{
	MeshSyncEventTypeAdded,
	MeshSyncEventTypeModified,
	MeshSyncEventTypeDeleted,
}
View Source 
var AllMeshType = []MeshType{
	MeshTypeAllMesh,
	MeshTypeInvalidMesh,
	MeshTypeAppMesh,
	MeshTypeCitrixServiceMesh,
	MeshTypeConsul,
	MeshTypeIstio,
	MeshTypeKuma,
	MeshTypeLinkerd,
	MeshTypeTraefikMesh,
	MeshTypeOctarine,
	MeshTypeNetworkServiceMesh,
	MeshTypeTanzu,
	MeshTypeOpenServiceMesh,
	MeshTypeNginxServiceMesh,
	MeshTypeCiliumServiceMesh,
}
View Source 
var AllMeshplayController = []MeshplayController{
	MeshplayControllerBroker,
	MeshplayControllerOperator,
	MeshplayControllerMeshsync,
}
View Source 
var AllMeshplayControllerStatus = []MeshplayControllerStatus{
	MeshplayControllerStatusDeployed,
	MeshplayControllerStatusNotdeployed,
	MeshplayControllerStatusDeploying,
	MeshplayControllerStatusUnkown,
	MeshplayControllerStatusUndeployed,
	MeshplayControllerStatusEnabled,
	MeshplayControllerStatusRunning,
	MeshplayControllerStatusConnected,
}
View Source 
var AllSeverity = []Severity{
	SeverityAlert,
	SeverityCritical,
	SeverityDebug,
	SeverityEmergency,
	SeverityError,
	SeverityWarning,
	SeverityInformational,
}
View Source 
var AllStatus = []Status{
	StatusEnabled,
	StatusConnected,
	StatusDisabled,
	StatusProcessing,
	StatusUnknown,
}

Functions

func CheckIfBrokerEventExistsInArray 

func CheckIfBrokerEventExistsInArray(event broker.EventType, events []broker.EventType) bool

func ErrApplyHelmChart 

func ErrApplyHelmChart(err error) error

ErrApplyHelmChart is the error which occurs while applying helm chart

func ErrCreateData 

func ErrCreateData(err error) error

func ErrDeleteData 

func ErrDeleteData(err error) error

func ErrMeshSyncEventsSubscription 

func ErrMeshSyncEventsSubscription(err error) error

func ErrMeshplayClient 

func ErrMeshplayClient(err error) error

func ErrMeshplayControllersStatusSubscription 

func ErrMeshplayControllersStatusSubscription(err error) error

func ErrMeshsyncSubscription 

func ErrMeshsyncSubscription(err error) error

func ErrPublishBroker 

func ErrPublishBroker(err error) error

func ErrQuery 

func ErrQuery(err error) error

func ErrSubscribeChannel 

func ErrSubscribeChannel(err error) error

func ErrUpdateData 

func ErrUpdateData(err error) error

func GetMeshplayBrokerEventTypes 

func GetMeshplayBrokerEventTypes(event MeshSyncEventType) broker.EventType

func GetMeshplayBrokerEventTypesFromArray 

func GetMeshplayBrokerEventTypesFromArray(events []MeshSyncEventType) []broker.EventType

func GetOperator 

func GetOperator(kubeclient *meshplaykube.Client) (string, string, error)

func Initialize 

func Initialize(client *meshplaykube.Client, delete bool, adapterTracker models.AdaptersTrackerInterface) error

func SelectivelyFetchNamespaces 

func SelectivelyFetchNamespaces(cids []string, provider models.Provider) ([]string, error)

SelectivelyFetchNamespaces fetches the an array of namespaces from DB based on ClusterIDs (or KubernetesServerIDs) passed as param

func SetOverrideValues 

func SetOverrideValues(delete bool, adapterTracker models.AdaptersTrackerInterface) map[string]interface{}

to be depricated

func SubscribeToBroker 

func SubscribeToBroker(_ models.Provider, meshplayKubeClient *meshplaykube.Client, datach chan *brokerpkg.Message, brokerConn brokerpkg.Handler, ct *K8sConnectionTracker) (string, error)

Types

type AdapterStatusInput 

type AdapterStatusInput struct {
	TargetStatus Status `json:"targetStatus"`
	TargetPort   string `json:"targetPort"`
	Adapter      string `json:"adapter"`
}

type AddonList 

type AddonList struct {
	Name  string `json:"name"`
	Owner string `json:"owner"`
}

func GetAddonsState 

func GetAddonsState(ctx context.Context, selectors []MeshType, provider models.Provider, cid []string) ([]*AddonList, error)

type AddonStatusInput 

type AddonStatusInput struct {
	Selector     *MeshType `json:"selector,omitempty"`
	K8scontextID string    `json:"k8scontextID"`
	TargetStatus Status    `json:"targetStatus"`
}

type ApplicationPage 

type ApplicationPage struct {
	Page         int                  `json:"page"`
	PageSize     int                  `json:"page_size"`
	TotalCount   int                  `json:"total_count"`
	Applications []*ApplicationResult `json:"applications,omitempty"`
}

type ApplicationResult 

type ApplicationResult struct {
	ID              string      `json:"id"`
	Name            string      `json:"name"`
	ApplicationFile string      `json:"application_file"`
	Type            *NullString `json:"type"`
	UserID          string      `json:"user_id"`
	Location        *Location   `json:"location"`
	Visibility      string      `json:"visibility"`
	CreatedAt       *string     `json:"created_at,omitempty"`
	UpdatedAt       *string     `json:"updated_at,omitempty"`
}

type CatalogFilter 

type CatalogFilter struct {
	ID             string                 `json:"id"`
	Name           string                 `json:"name"`
	FilterFile     string                 `json:"filter_file"`
	UserID         string                 `json:"user_id"`
	Location       *Location              `json:"location"`
	FilterResource string                 `json:"filter_resource"`
	Visibility     string                 `json:"visibility"`
	CatalogData    map[string]interface{} `json:"catalog_data,omitempty"`
	CreatedAt      *string                `json:"created_at,omitempty"`
	UpdatedAt      *string                `json:"updated_at,omitempty"`
}

type CatalogPattern 

type CatalogPattern struct {
	ID          string                 `json:"id"`
	Name        string                 `json:"name"`
	UserID      string                 `json:"user_id"`
	PatternFile string                 `json:"pattern_file"`
	Location    *Location              `json:"location"`
	Visibility  string                 `json:"visibility"`
	CatalogData map[string]interface{} `json:"catalog_data,omitempty"`
	CreatedAt   *string                `json:"created_at,omitempty"`
	UpdatedAt   *string                `json:"updated_at,omitempty"`
}

type CatalogSelector 

type CatalogSelector struct {
	Page     string `json:"page"`
	Pagesize string `json:"pagesize"`
	Search   string `json:"search"`
	Order    string `json:"order"`
}

type ClusterResources 

type ClusterResources struct {
	Resources []*Resource `json:"resources"`
}

type ConfigurationPage 

type ConfigurationPage struct {
	Applications *ApplicationPage   `json:"applications,omitempty"`
	Patterns     *PatternPageResult `json:"patterns,omitempty"`
	Filters      *FilterPage        `json:"filters,omitempty"`
}

type Connections 

type Connections struct {
	Connections []connection `json:"connections"`
}

type Container 

type Container struct {
	ControlPlaneMemberName string           `json:"controlPlaneMemberName"`
	ContainerName          string           `json:"containerName"`
	Image                  string           `json:"image"`
	Status                 *ContainerStatus `json:"status,omitempty"`
	Ports                  []*ContainerPort `json:"ports,omitempty"`
	Resources              interface{}      `json:"resources,omitempty"`
}

type ContainerPort 

type ContainerPort struct {
	Name          *string `json:"name,omitempty"`
	ContainerPort int     `json:"containerPort"`
	Protocol      string  `json:"protocol"`
}

type ContainerStatus 

type ContainerStatus struct {
	ContainerStatusName string      `json:"containerStatusName"`
	Image               string      `json:"image"`
	State               interface{} `json:"state,omitempty"`
	LastState           interface{} `json:"lastState,omitempty"`
	Ready               bool        `json:"ready"`
	RestartCount        interface{} `json:"restartCount,omitempty"`
	Started             bool        `json:"started"`
	ImageID             interface{} `json:"imageID,omitempty"`
	ContainerID         interface{} `json:"containerID,omitempty"`
}

type ControlPlane 

type ControlPlane struct {
	Name    string                `json:"name"`
	Members []*ControlPlaneMember `json:"members"`
}

func GetControlPlaneState 

func GetControlPlaneState(ctx context.Context, selectors []MeshType, provider models.Provider, cid []string) ([]*ControlPlane, error)

type ControlPlaneMember 

type ControlPlaneMember struct {
	Name       string       `json:"name"`
	Component  string       `json:"component"`
	Version    string       `json:"version"`
	Namespace  string       `json:"namespace"`
	DataPlanes []*Container `json:"data_planes,omitempty"`
}

type DataPlane 

type DataPlane struct {
	Name    string       `json:"name"`
	Proxies []*Container `json:"proxies"`
}

func GetDataPlaneState 

func GetDataPlaneState(ctx context.Context, selectors []MeshType, provider models.Provider, cid []string) ([]*DataPlane, error)

type Error 

type Error struct {
	Code        string `json:"code"`
	Description string `json:"description"`
}

type Event 

type Event struct {
	ID          string                 `json:"id"`
	UserID      string                 `json:"userID"`
	ActedUpon   string                 `json:"actedUpon"`
	OperationID string                 `json:"operationID"`
	SystemID    string                 `json:"systemID"`
	Severity    Severity               `json:"severity"`
	Action      string                 `json:"action"`
	Status      string                 `json:"status"`
	Category    string                 `json:"category"`
	Description string                 `json:"description"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt   time.Time              `json:"createdAt"`
	UpdatedAt   time.Time              `json:"updatedAt"`
	DeletedAt   *time.Time             `json:"deletedAt,omitempty"`
}

type FilterPage 

type FilterPage struct {
	Page       int             `json:"page"`
	PageSize   int             `json:"page_size"`
	TotalCount int             `json:"total_count"`
	Filters    []*FilterResult `json:"filters,omitempty"`
}

type FilterResult 

type FilterResult struct {
	ID             string                 `json:"id"`
	Name           string                 `json:"name"`
	FilterFile     string                 `json:"filter_file"`
	FilterResource string                 `json:"filter_resource"`
	UserID         string                 `json:"user_id"`
	Location       *Location              `json:"location"`
	Visibility     string                 `json:"visibility"`
	CatalogData    map[string]interface{} `json:"catalog_data,omitempty"`
	CreatedAt      *string                `json:"created_at,omitempty"`
	UpdatedAt      *string                `json:"updated_at,omitempty"`
}

type K8sConnectionTracker 

type K8sConnectionTracker struct {
	// contains filtered or unexported fields
}

K8sConnectionTracker keeps track of BrokerURLs per kubernetes context

func NewK8sConnctionTracker 

func NewK8sConnctionTracker() *K8sConnectionTracker

func (*K8sConnectionTracker) Get 

func (k *K8sConnectionTracker) Get(id string) (url string)

func (*K8sConnectionTracker) ListBrokerEndpoints 

func (k *K8sConnectionTracker) ListBrokerEndpoints() (a []string)

func (*K8sConnectionTracker) Log 

func (k *K8sConnectionTracker) Log(l logger.Handler)

Takes the meshkit Logger and logs a comma separated list of currently tracked Broker Endpoints

func (*K8sConnectionTracker) ResetEndpoints 

func (k *K8sConnectionTracker) ResetEndpoints(available map[string]bool)

Takes a set of endpoints and discard the current endpoint if its not present in the set

func (*K8sConnectionTracker) Set 

func (k *K8sConnectionTracker) Set(id string, url string)

type K8sContext 

type K8sContext struct {
	ID                 string `json:"id"`
	Name               string `json:"name"`
	Server             string `json:"server"`
	Owner              string `json:"owner"`
	CreatedBy          string `json:"created_by"`
	MeshplayInstanceID string `json:"meshplay_instance_id"`
	KubernetesServerID string `json:"kubernetes_server_id"`
	DeploymentType     string `json:"deployment_type"`
	Version            string `json:"version"`
	UpdatedAt          string `json:"updated_at"`
	CreatedAt          string `json:"created_at"`
	ConnectionID       string `json:"connection_id"`
}

type K8sContextsPage 

type K8sContextsPage struct {
	TotalCount int           `json:"total_count"`
	Contexts   []*K8sContext `json:"contexts"`
}

type KctlDescribeDetails 

type KctlDescribeDetails struct {
	Describe *string `json:"describe,omitempty"`
	Ctxid    *string `json:"ctxid,omitempty"`
}

type Location 

type Location struct {
	Branch *string `json:"branch,omitempty"`
	Host   *string `json:"host,omitempty"`
	Path   *string `json:"path,omitempty"`
	Type   *string `json:"type,omitempty"`
}

type MeshModelComponent 

type MeshModelComponent struct {
	Name  string `json:"name"`
	Count int    `json:"count"`
}

type MeshModelRelationship 

type MeshModelRelationship struct {
	Name  string `json:"name"`
	Count int    `json:"count"`
}

type MeshModelSummary 

type MeshModelSummary struct {
	Components    []*MeshModelComponent    `json:"components,omitempty"`
	Relationships []*MeshModelRelationship `json:"relationships,omitempty"`
}

type MeshModelSummarySelector 

type MeshModelSummarySelector struct {
	Type string `json:"type"`
}

type MeshSyncEvent 

type MeshSyncEvent struct {
	Type      string      `json:"type"`
	Object    interface{} `json:"object"`
	ContextID string      `json:"contextId"`
}

type MeshSyncEventType 

type MeshSyncEventType string
const (
	MeshSyncEventTypeAdded    MeshSyncEventType = "ADDED"
	MeshSyncEventTypeModified MeshSyncEventType = "MODIFIED"
	MeshSyncEventTypeDeleted  MeshSyncEventType = "DELETED"
)

func (MeshSyncEventType) IsValid 

func (e MeshSyncEventType) IsValid() bool

func (MeshSyncEventType) MarshalGQL 

func (e MeshSyncEventType) MarshalGQL(w io.Writer)

func (MeshSyncEventType) String 

func (e MeshSyncEventType) String() string

func (*MeshSyncEventType) UnmarshalGQL 

func (e *MeshSyncEventType) UnmarshalGQL(v interface{}) error

type MeshType 

type MeshType string
const (
	MeshTypeAllMesh            MeshType = "ALL_MESH"
	MeshTypeInvalidMesh        MeshType = "INVALID_MESH"
	MeshTypeAppMesh            MeshType = "APP_MESH"
	MeshTypeCitrixServiceMesh  MeshType = "CITRIX_SERVICE_MESH"
	MeshTypeConsul             MeshType = "CONSUL"
	MeshTypeIstio              MeshType = "ISTIO"
	MeshTypeKuma               MeshType = "KUMA"
	MeshTypeLinkerd            MeshType = "LINKERD"
	MeshTypeTraefikMesh        MeshType = "TRAEFIK_MESH"
	MeshTypeOctarine           MeshType = "OCTARINE"
	MeshTypeNetworkServiceMesh MeshType = "NETWORK_SERVICE_MESH"
	MeshTypeTanzu              MeshType = "TANZU"
	MeshTypeOpenServiceMesh    MeshType = "OPEN_SERVICE_MESH"
	MeshTypeNginxServiceMesh   MeshType = "NGINX_SERVICE_MESH"
	MeshTypeCiliumServiceMesh  MeshType = "CILIUM_SERVICE_MESH"
)

func (MeshType) IsValid 

func (e MeshType) IsValid() bool

func (MeshType) MarshalGQL 

func (e MeshType) MarshalGQL(w io.Writer)

func (MeshType) String 

func (e MeshType) String() string

func (*MeshType) UnmarshalGQL 

func (e *MeshType) UnmarshalGQL(v interface{}) error

type MeshplayController 

type MeshplayController string
const (
	MeshplayControllerBroker   MeshplayController = "BROKER"
	MeshplayControllerOperator MeshplayController = "OPERATOR"
	MeshplayControllerMeshsync MeshplayController = "MESHSYNC"
)

func GetInternalController 

func GetInternalController(controller models.MeshplayController) MeshplayController

func (MeshplayController) IsValid 

func (e MeshplayController) IsValid() bool

func (MeshplayController) MarshalGQL 

func (e MeshplayController) MarshalGQL(w io.Writer)

func (MeshplayController) String 

func (e MeshplayController) String() string

func (*MeshplayController) UnmarshalGQL 

func (e *MeshplayController) UnmarshalGQL(v interface{}) error

type MeshplayControllerStatus 

type MeshplayControllerStatus string
const (
	MeshplayControllerStatusDeployed    MeshplayControllerStatus = "DEPLOYED"
	MeshplayControllerStatusNotdeployed MeshplayControllerStatus = "NOTDEPLOYED"
	MeshplayControllerStatusDeploying   MeshplayControllerStatus = "DEPLOYING"
	MeshplayControllerStatusUnkown      MeshplayControllerStatus = "UNKOWN"
	MeshplayControllerStatusUndeployed  MeshplayControllerStatus = "UNDEPLOYED"
	MeshplayControllerStatusEnabled     MeshplayControllerStatus = "ENABLED"
	MeshplayControllerStatusRunning     MeshplayControllerStatus = "RUNNING"
	MeshplayControllerStatusConnected   MeshplayControllerStatus = "CONNECTED"
)

func GetInternalControllerStatus 

func GetInternalControllerStatus(status controllers.MeshplayControllerStatus) MeshplayControllerStatus

func (MeshplayControllerStatus) IsValid 

func (e MeshplayControllerStatus) IsValid() bool

func (MeshplayControllerStatus) MarshalGQL 

func (e MeshplayControllerStatus) MarshalGQL(w io.Writer)

func (MeshplayControllerStatus) String 

func (e MeshplayControllerStatus) String() string

func (*MeshplayControllerStatus) UnmarshalGQL 

func (e *MeshplayControllerStatus) UnmarshalGQL(v interface{}) error

type MeshplayControllersStatusListItem 

type MeshplayControllersStatusListItem struct {
	ContextID  string                   `json:"contextId"`
	Controller MeshplayController       `json:"controller"`
	Status     MeshplayControllerStatus `json:"status"`
	Version    *string                  `json:"version,omitempty"`
}

type MeshplayResult 

type MeshplayResult struct {
	MeshplayID         *string                `json:"meshplay_id,omitempty"`
	Name               *string                `json:"name,omitempty"`
	Mesh               *string                `json:"mesh,omitempty"`
	PerformanceProfile *string                `json:"performance_profile,omitempty"`
	TestID             *string                `json:"test_id,omitempty"`
	RunnerResults      map[string]interface{} `json:"runner_results,omitempty"`
	ServerMetrics      *string                `json:"server_metrics,omitempty"`
	ServerBoardConfig  *string                `json:"server_board_config,omitempty"`
	TestStartTime      *string                `json:"test_start_time,omitempty"`
	UserID             *string                `json:"user_id,omitempty"`
	UpdatedAt          *string                `json:"updated_at,omitempty"`
	CreatedAt          *string                `json:"created_at,omitempty"`
}

type Mutation 

type Mutation struct {
}

type NameSpace 

type NameSpace struct {
	Namespace string `json:"namespace"`
}

type NullString 

type NullString struct {
	String string `json:"String"`
	Valid  bool   `json:"Valid"`
}

type OAMCapability 

type OAMCapability struct {
	OamDefinition interface{} `json:"oam_definition,omitempty"`
	ID            *string     `json:"id,omitempty"`
	OamRefSchema  *string     `json:"oam_ref_schema,omitempty"`
	Host          *string     `json:"host,omitempty"`
	Restricted    *bool       `json:"restricted,omitempty"`
	Metadata      interface{} `json:"metadata,omitempty"`
}

type OperatorControllerStatus 

type OperatorControllerStatus struct {
	Name      string `json:"name"`
	Version   string `json:"version"`
	Status    Status `json:"status"`
	Error     *Error `json:"error,omitempty"`
	ContextID string `json:"contextID"`
}

func GetBrokerInfo 

func GetBrokerInfo(meshplayKubeClient *meshplaykube.Client) OperatorControllerStatus

func GetControllersInfo 

func GetControllersInfo(meshplayKubeClient *meshplaykube.Client, brokerConn brokerpkg.Handler) ([]*OperatorControllerStatus, error)

func GetMeshSyncInfo 

func GetMeshSyncInfo(meshplayKubeClient *meshplaykube.Client, broker controllers.IMeshplayController) OperatorControllerStatus

type OperatorControllerStatusPerK8sContext 

type OperatorControllerStatusPerK8sContext struct {
	ContextID                string                    `json:"contextID"`
	OperatorControllerStatus *OperatorControllerStatus `json:"OperatorControllerStatus"`
}

type OperatorStatus 

type OperatorStatus struct {
	Status      Status                      `json:"status"`
	Version     string                      `json:"version"`
	Controllers []*OperatorControllerStatus `json:"controllers"`
	Error       *Error                      `json:"error,omitempty"`
	ContextID   string                      `json:"contextID"`
}

type OperatorStatusInput 

type OperatorStatusInput struct {
	TargetStatus Status `json:"targetStatus"`
	ContextID    string `json:"contextID"`
}

type OperatorStatusPerK8sContext 

type OperatorStatusPerK8sContext struct {
	ContextID      string          `json:"contextID"`
	OperatorStatus *OperatorStatus `json:"operatorStatus"`
}

type PageFilter 

type PageFilter struct {
	Page         string   `json:"page"`
	PageSize     string   `json:"pageSize"`
	Order        *string  `json:"order,omitempty"`
	Search       *string  `json:"search,omitempty"`
	From         *string  `json:"from,omitempty"`
	To           *string  `json:"to,omitempty"`
	UpdatedAfter *string  `json:"updated_after,omitempty"`
	Visibility   []string `json:"visibility,omitempty"`
}

type PatternPageResult 

type PatternPageResult struct {
	Page       int              `json:"page"`
	PageSize   int              `json:"page_size"`
	TotalCount int              `json:"total_count"`
	Patterns   []*PatternResult `json:"patterns,omitempty"`
}

type PatternResult 

type PatternResult struct {
	ID          string                 `json:"id"`
	Name        string                 `json:"name"`
	UserID      string                 `json:"user_id"`
	Location    *Location              `json:"location"`
	PatternFile string                 `json:"pattern_file"`
	Visibility  string                 `json:"visibility"`
	CatalogData map[string]interface{} `json:"catalog_data,omitempty"`
	CanSupport  bool                   `json:"canSupport"`
	Errmsg      *string                `json:"errmsg,omitempty"`
	CreatedAt   *string                `json:"created_at,omitempty"`
	UpdatedAt   *string                `json:"updated_at,omitempty"`
	Type        *NullString            `json:"type,omitempty"`
}

type PerfPageProfiles 

type PerfPageProfiles struct {
	Page       int            `json:"page"`
	PageSize   int            `json:"page_size"`
	TotalCount int            `json:"total_count"`
	Profiles   []*PerfProfile `json:"profiles,omitempty"`
}

type PerfPageResult 

type PerfPageResult struct {
	Page       int               `json:"page"`
	PageSize   int               `json:"page_size"`
	TotalCount int               `json:"total_count"`
	Results    []*MeshplayResult `json:"results,omitempty"`
}

type PerfProfile 

type PerfProfile struct {
	ConcurrentRequest int                    `json:"concurrent_request"`
	CreatedAt         *string                `json:"created_at,omitempty"`
	Duration          string                 `json:"duration"`
	Endpoints         []*string              `json:"endpoints,omitempty"`
	ID                string                 `json:"id"`
	LastRun           *string                `json:"last_run,omitempty"`
	LoadGenerators    []*string              `json:"load_generators,omitempty"`
	Name              *string                `json:"name,omitempty"`
	QPS               *int                   `json:"qps,omitempty"`
	TotalResults      *int                   `json:"total_results,omitempty"`
	UpdatedAt         *string                `json:"updated_at,omitempty"`
	UserID            string                 `json:"user_id"`
	RequestHeaders    *string                `json:"request_headers,omitempty"`
	RequestCookies    *string                `json:"request_cookies,omitempty"`
	RequestBody       *string                `json:"request_body,omitempty"`
	ContentType       *string                `json:"content_type,omitempty"`
	ServiceMesh       *string                `json:"service_mesh,omitempty"`
	Metadata          map[string]interface{} `json:"metadata,omitempty"`
}

type Query 

type Query struct {
}

type ReSyncActions 

type ReSyncActions struct {
	ClearDb   string `json:"clearDB"`
	ReSync    string `json:"ReSync"`
	HardReset string `json:"hardReset"`
}

type Resource 

type Resource struct {
	Kind  string `json:"kind"`
	Count int    `json:"count"`
}

type ServiceMeshFilter 

type ServiceMeshFilter struct {
	Type          *MeshType `json:"type,omitempty"`
	K8sClusterIDs []string  `json:"k8sClusterIDs,omitempty"`
}

type Severity 

type Severity string
const (
	SeverityAlert         Severity = "alert"
	SeverityCritical      Severity = "critical"
	SeverityDebug         Severity = "debug"
	SeverityEmergency     Severity = "emergency"
	SeverityError         Severity = "error"
	SeverityWarning       Severity = "warning"
	SeverityInformational Severity = "informational"
)

func (Severity) IsValid 

func (e Severity) IsValid() bool

func (Severity) MarshalGQL 

func (e Severity) MarshalGQL(w io.Writer)

func (Severity) String 

func (e Severity) String() string

func (*Severity) UnmarshalGQL 

func (e *Severity) UnmarshalGQL(v interface{}) error

type Status 

type Status string
const (
	StatusEnabled    Status = "ENABLED"
	StatusConnected  Status = "CONNECTED"
	StatusDisabled   Status = "DISABLED"
	StatusProcessing Status = "PROCESSING"
	StatusUnknown    Status = "UNKNOWN"
)

func (Status) IsValid 

func (e Status) IsValid() bool

func (Status) MarshalGQL 

func (e Status) MarshalGQL(w io.Writer)

func (Status) String 

func (e Status) String() string

func (*Status) UnmarshalGQL 

func (e *Status) UnmarshalGQL(v interface{}) error

type Subscription 

type Subscription struct {
}

type TelemetryComp 

type TelemetryComp struct {
	Name   string `json:"name"`
	Spec   string `json:"spec"`
	Status string `json:"status"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.