model

package
v0.6.0-rc.6fd Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2022 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrInvalidRequestCode                       = "1000"
	ErrNilClientCode                            = "1001"
	ErrCreateDataCode                           = "1002"
	ErrQueryCode                                = "1003"
	ErrMeshsyncSubscriptionCode                 = "1004"
	ErrOperatorSubscriptionCode                 = "1005"
	ErrAddonSubscriptionCode                    = "1006"
	ErrControlPlaneSubscriptionCode             = "1007"
	ErrMesheryClientCode                        = "1008"
	ErrSubscribeChannelCode                     = "1009"
	ErrPublishBrokerCode                        = "1010"
	ErrNoMeshSyncCode                           = "1011"
	ErrNoExternalEndpointCode                   = "1012"
	ErrApplyHelmChartCode                       = "2155"
	ErrMesheryControllersStatusSubscriptionCode = "2239"
	ErrMeshSyncEventsSubscriptionCode           = "2240"
)
View Source 
const (
	Namespace       = "meshery"
	RequestSubject  = "meshery.meshsync.request"
	MeshsyncSubject = "meshery.meshsync.core"
	BrokerQueue     = "meshery"
)

Variables

View Source 
var AllMeshType = []MeshType{
	MeshTypeAllMesh,
	MeshTypeInvalidMesh,
	MeshTypeAppMesh,
	MeshTypeCitrixServiceMesh,
	MeshTypeConsul,
	MeshTypeIstio,
	MeshTypeKuma,
	MeshTypeLinkerd,
	MeshTypeTraefikMesh,
	MeshTypeOctarine,
	MeshTypeNetworkServiceMesh,
	MeshTypeTanzu,
	MeshTypeOpenServiceMesh,
	MeshTypeNginxServiceMesh,
	MeshTypeCiliumServiceMesh,
}
View Source 
var AllMesheryController = []MesheryController{
	MesheryControllerBroker,
	MesheryControllerOperator,
	MesheryControllerMeshsync,
}
View Source 
var AllMesheryControllerStatus = []MesheryControllerStatus{
	MesheryControllerStatusDeployed,
	MesheryControllerStatusNotdeployed,
	MesheryControllerStatusDeploying,
	MesheryControllerStatusUnkown,
}
View Source 
var AllStatus = []Status{
	StatusEnabled,
	StatusConnected,
	StatusDisabled,
	StatusProcessing,
	StatusUnknown,
}
View Source 
var (
	ErrEmptyHandler = errors.New(ErrNoMeshSyncCode, errors.Alert, []string{"Database handler not initialized"}, []string{"Meshery Database handler is not accessible to perform operations"}, []string{"Meshery Database is crashed or not reachable"}, []string{"Restart Meshery Server", "Please check if Meshery server is accessible to the Database"})
)

Functions

func ErrApplyHelmChart 

func ErrApplyHelmChart(err error) error

ErrApplyHelmChart is the error which occurs while applying helm chart

func ErrCreateData added in v0.5.40 

func ErrCreateData(err error) error

func ErrDeleteData added in v0.5.40 

func ErrDeleteData(err error) error

func ErrMeshSyncEventsSubscription 

func ErrMeshSyncEventsSubscription(err error) error

func ErrMesheryClient added in v0.5.40 

func ErrMesheryClient(err error) error

func ErrMesheryControllersStatusSubscription 

func ErrMesheryControllersStatusSubscription(err error) error

func ErrMeshsyncSubscription added in v0.5.40 

func ErrMeshsyncSubscription(err error) error

func ErrPublishBroker added in v0.5.40 

func ErrPublishBroker(err error) error

func ErrQuery added in v0.5.40 

func ErrQuery(err error) error

func ErrSubscribeChannel added in v0.5.40 

func ErrSubscribeChannel(err error) error

func ErrUpdateData added in v0.5.40 

func ErrUpdateData(err error) error

func GetOperator added in v0.5.40 

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

func Initialize added in v0.5.40 

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

func ListernToEvents added in v0.5.40 

func ListernToEvents(log logger.Handler,
	handler *database.Handler,
	datach chan *broker.Message,
	meshsyncCh chan struct{},
	broadcast broadcast.Broadcaster,
)

listernToEvents - scale this function with the number of channels

func PersistClusterNames 

func PersistClusterNames(
	ctx context.Context,
	log logger.Handler,
	handler *database.Handler,
	meshsyncCh chan struct{},
)

func SetOverrideValues 

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

to be depricated

func SubscribeToBroker added in v0.5.40 

func SubscribeToBroker(provider models.Provider, mesheryKubeClient *mesherykube.Client, datach chan *brokerpkg.Message, brokerConn brokerpkg.Handler, ct *K8sConnectionTracker) (string, error)

Types

type AddonList 

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

func GetAddonsState added in v0.5.40 

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

type AddonStatusInput added in v0.5.15 

type AddonStatusInput struct {
	Selector     *MeshType `json:"selector"`
	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"`
}

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"`
	CreatedAt       *string     `json:"created_at"`
	UpdatedAt       *string     `json:"updated_at"`
}

type ConfigurationPage 

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

type Container added in v0.5.50 

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

type ContainerPort added in v0.5.50 

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

type ContainerStatus added in v0.5.50 

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

type ControlPlane 

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

func GetControlPlaneState added in v0.5.40 

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"`
}

type DataPlane added in v0.5.50 

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

func GetDataPlaneState added in v0.5.50 

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 FilterPage 

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

type FilterResult 

type FilterResult struct {
	ID         string    `json:"id"`
	Name       string    `json:"name"`
	FilterFile string    `json:"filter_file"`
	UserID     string    `json:"user_id"`
	Location   *Location `json:"location"`
	CreatedAt  *string   `json:"created_at"`
	UpdatedAt  *string   `json:"updated_at"`
}

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 KctlDescribeDetails 

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

type Location 

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

type MeshSyncEvent 

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

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 MesheryController 

type MesheryController string
const (
	MesheryControllerBroker   MesheryController = "BROKER"
	MesheryControllerOperator MesheryController = "OPERATOR"
	MesheryControllerMeshsync MesheryController = "MESHSYNC"
)

func GetInternalController 

func GetInternalController(controller models.MesheryController) MesheryController

func (MesheryController) IsValid 

func (e MesheryController) IsValid() bool

func (MesheryController) MarshalGQL 

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

func (MesheryController) String 

func (e MesheryController) String() string

func (*MesheryController) UnmarshalGQL 

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

type MesheryControllerStatus 

type MesheryControllerStatus string
const (
	MesheryControllerStatusDeployed    MesheryControllerStatus = "DEPLOYED"
	MesheryControllerStatusNotdeployed MesheryControllerStatus = "NOTDEPLOYED"
	MesheryControllerStatusDeploying   MesheryControllerStatus = "DEPLOYING"
	MesheryControllerStatusUnkown      MesheryControllerStatus = "UNKOWN"
)

func GetInternalControllerStatus 

func GetInternalControllerStatus(status controllers.MesheryControllerStatus) MesheryControllerStatus

func (MesheryControllerStatus) IsValid 

func (e MesheryControllerStatus) IsValid() bool

func (MesheryControllerStatus) MarshalGQL 

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

func (MesheryControllerStatus) String 

func (e MesheryControllerStatus) String() string

func (*MesheryControllerStatus) UnmarshalGQL 

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

type MesheryControllersStatusListItem 

type MesheryControllersStatusListItem struct {
	ContextID  string                  `json:"contextId"`
	Controller MesheryController       `json:"controller"`
	Status     MesheryControllerStatus `json:"status"`
}

type MesheryResult added in v0.5.46 

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

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"`
	ID            *string     `json:"id"`
	OamRefSchema  *string     `json:"oam_ref_schema"`
	Host          *string     `json:"host"`
	Restricted    *bool       `json:"restricted"`
	Metadata      interface{} `json:"metadata"`
}

type OperatorControllerStatus 

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

func GetBrokerInfo added in v0.5.58 

func GetBrokerInfo(mesheryclient operatorClient.Interface, mesheryKubeClient *mesherykube.Client, brokerConn brokerpkg.Handler) (OperatorControllerStatus, error)

func GetControllersInfo added in v0.5.40 

func GetControllersInfo(mesheryKubeClient *mesherykube.Client, brokerConn brokerpkg.Handler) ([]*OperatorControllerStatus, error)

func GetMeshSyncInfo added in v0.5.58 

func GetMeshSyncInfo(mesheryclient operatorClient.Interface, mesheryKubeClient *mesherykube.Client) (OperatorControllerStatus, error)

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"`
	ContextID   string                      `json:"contextID"`
}

type OperatorStatusInput added in v0.5.15 

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 added in v0.5.46 

type PageFilter struct {
	Page     string  `json:"page"`
	PageSize string  `json:"pageSize"`
	Order    *string `json:"order"`
	Search   *string `json:"search"`
	From     *string `json:"from"`
	To       *string `json:"to"`
}

type PatternPageResult 

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

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"`
	CanSupport  bool      `json:"canSupport"`
	Errmsg      *string   `json:"errmsg"`
	CreatedAt   *string   `json:"created_at"`
	UpdatedAt   *string   `json:"updated_at"`
}

type PerfPageProfiles added in v0.5.64 

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

type PerfPageResult added in v0.5.46 

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

type PerfProfile added in v0.5.64 

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

type ReSyncActions added in v0.5.39 

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

type ServiceMeshFilter added in v0.5.50 

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

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

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.