resolver

Documentation

Index

• Constants
• Variables
• func ErrAddonSubscription(err error) error
• func ErrApplicationsSubscription(err error) error
• func ErrClusterResourcesSubscription(err error) error
• func ErrControlPlaneSubscription(err error) error
• func ErrDataPlaneSubscription(err error) error
• func ErrDeleteData(err error) error
• func ErrFetchingPatterns(err error) error
• func ErrFiltersSubscription(err error) error
• func ErrGettingClusterResources(err error) error
• func ErrGettingNamespace(err error) error
• func ErrInvalidOAMType() error
• func ErrK8sContextSubscription(err error) error
• func ErrKubectlDescribe(err error) error
• func ErrMesheryClient(err error) error
• func ErrMeshsyncSubscription(err error) error
• func ErrOperatorSubscription(err error) error
• func ErrPatternsSubscription(err error) error
• func ErrPerformanceProfilesSubscription(err error) error
• func ErrPerformanceResultSubscription(err error) error
• func ErrPublishBroker(err error) error
• func ErrUpdateData(err error) error
• type Resolver
  • func (r *Resolver) Mutation() generated.MutationResolver
  • func (r *Resolver) Query() generated.QueryResolver
  • func (r *Resolver) Subscription() generated.SubscriptionResolver

Constants

const (
	ErrResolverInvalidRequestCode           = "2222"
	ErrResolverNilClientCode                = "2223"
	ErrResolverCreateDataCode               = "2224"
	ErrResolverQueryCode                    = "2225"
	ErrResolverMeshsyncSubscriptionCode     = "2226"
	ErrResolverOperatorSubscriptionCode     = "2227"
	ErrResolverAddonSubscriptionCode        = "2228"
	ErrResolverControlPlaneSubscriptionCode = "2229"
	ErrResolverMesheryClientCode            = "2230"
	ErrResolverSubscribeChannelCode         = "2231"
	ErrResolverPublishBrokerCode            = "2232"
	ErrResolverNoMeshSyncCode               = "2233"
	ErrResolverNoExternalEndpointCode       = "2234"
	ErrDataPlaneSubscriptionCode            = "1013"
	ErrBrokerNotConnectedCode               = "2221"
	ErrGettingNamespaceCode                 = "1014"
	ErrFetchingPatternsCode                 = "1015"
	ErrInvalidOAMTypeCode                   = "2178"
	ErrKubectlDescribeCode                  = "2179"
	ErrEmptyCurrentK8sContextCode           = "2180"
	ErrConfigurationPatternsCode            = "2242"
	ErrConfigurationApplicationsCode        = "2243"
	ErrConfigurationFiltersCode             = "2244"
	ErrK8sContextCode                       = "2245"
	ErrClusterResourcesSubscriptionCode     = "2246"
	ErrGettingClusterResourcesCode          = "2247"
)

Variables

var (
	ErrNilClient              = errors.New(ErrResolverNilClientCode, errors.Alert, []string{"Kubernetes client not initialized"}, []string{"Kubernetes config is not initialized with Meshery"}, []string{}, []string{"Upload your kubernetes config via the settings dashboard. If uploaded, wait for a minute for it to get initialized"})
	ErrInvalidRequest         = errors.New(ErrResolverInvalidRequestCode, errors.Alert, []string{"Invalid query, please check syntax"}, []string{"The Graphql query requested is invalid"}, []string{}, []string{"Check the query parameters and syntax of the query being run"})
	ErrNoMeshSync             = errors.New(ErrResolverNoMeshSyncCode, errors.Alert, []string{"MeshSync disabled"}, []string{"MeshSync custom controller is not running in your kubernetes cluster"}, []string{"Meshery Operator is not running in your cluster or is crashing"}, []string{"Enable Meshery Operator from the settings page in the UI", "Check for logs in the meshery-operator pods from inside the application for more information"})
	ErrEmptyHandler           = errors.New(ErrResolverNoMeshSyncCode, 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"})
	ErrBrokerNotConnected     = errors.New(ErrBrokerNotConnectedCode, errors.Alert, []string{"Broker not connected"}, []string{"Meshery Broker is not connected to Meshery Server"}, []string{"Meshery Broker is crashed or not reachable"}, []string{"Restart Meshery Server", "Please check if Meshery server has access to the Broker"})
	ErrEmptyCurrentK8sContext = errors.New(ErrEmptyCurrentK8sContextCode, errors.Alert, []string{"Current kubernetes context is empty"}, []string{"Meshery is not able to get the current kubernetes context"}, []string{"Meshery is crashed or not reachable"}, []string{"Restart Meshery Server", "Please check if Meshery server is accessible to the Database"})
)

var (
	MeshSyncSubscriptionError = model.Error{
		Description: "Failed to get MeshSync data",
		Code:        ErrResolverMeshsyncSubscriptionCode,
	}
	MeshSyncMesheryClientMissingError = model.Error{
		Code:        ErrResolverMeshsyncSubscriptionCode,
		Description: "Cannot find Meshery Client",
	}
)

Functions

func ErrAddonSubscription

func ErrAddonSubscription(err error) error

func ErrApplicationsSubscription

func ErrApplicationsSubscription(err error) error

func ErrClusterResourcesSubscription

func ErrClusterResourcesSubscription(err error) error

func ErrControlPlaneSubscription

func ErrControlPlaneSubscription(err error) error

func ErrDataPlaneSubscription

func ErrDataPlaneSubscription(err error) error

func ErrDeleteData

func ErrDeleteData(err error) error

func ErrFetchingPatterns

func ErrFetchingPatterns(err error) error

func ErrFiltersSubscription

func ErrFiltersSubscription(err error) error

func ErrGettingClusterResources

func ErrGettingClusterResources(err error) error

func ErrGettingNamespace

func ErrGettingNamespace(err error) error

func ErrInvalidOAMType

func ErrInvalidOAMType() error

func ErrK8sContextSubscription

func ErrK8sContextSubscription(err error) error

func ErrKubectlDescribe

func ErrKubectlDescribe(err error) error

func ErrMesheryClient

func ErrMesheryClient(err error) error

func ErrMeshsyncSubscription

func ErrMeshsyncSubscription(err error) error

func ErrOperatorSubscription

func ErrOperatorSubscription(err error) error

func ErrPatternsSubscription

func ErrPatternsSubscription(err error) error

func ErrPerformanceProfilesSubscription

func ErrPerformanceProfilesSubscription(err error) error

func ErrPerformanceResultSubscription

func ErrPerformanceResultSubscription(err error) error

func ErrPublishBroker

func ErrPublishBroker(err error) error

func ErrUpdateData

func ErrUpdateData(err error) error

Types

type Resolver

type Resolver struct {
	Log                          logger.Handler
	BrokerConn                   broker.Handler
	MeshSyncChannelPerK8sContext map[string]chan struct{}
	Config                       *models.HandlerConfig
	Broadcast                    broadcast.Broadcaster
	// contains filtered or unexported fields
}

func (*Resolver) Mutation

func (r *Resolver) Mutation() generated.MutationResolver

Mutation returns generated.MutationResolver implementation.

func (*Resolver) Query

func (r *Resolver) Query() generated.QueryResolver

Query returns generated.QueryResolver implementation.

func (*Resolver) Subscription

func (r *Resolver) Subscription() generated.SubscriptionResolver

Subscription returns generated.SubscriptionResolver implementation.