controllers

Documentation

Index

• Constants
• Variables
• func ConnectivityTest(clientName, hostPort string) bool
• func ErrDeployController(err error) error
• func ErrGetControllerPublicEndpoint(err error) error
• func ErrGetControllerStatus(err error) error
• func GetBrokerEndpoint(kclient *mesherykube.Client, broker *v1alpha1.Broker) string
• type Connections
• type IMesheryController
  • func NewMesheryBrokerHandler(kubernetesClient *mesherykube.Client) IMesheryController
  • func NewMesheryOperatorHandler(client *mesherykube.Client, deploymentConf OperatorDeploymentConfig) IMesheryController
  • func NewMeshsyncHandler(kubernetesClient *mesherykube.Client) IMesheryController
• type MesheryControllerStatus
  • func (mcs MesheryControllerStatus) String() string
• type OperatorDeploymentConfig

Constants

const (
	MeshSync      = "meshsync"
	MesheryBroker = "meshery-broker"
	MesheryServer = "meshery-server"
)

const BrokerPingEndpoint = "/connz"

Variables

var (
	ErrGetControllerStatusCode         = "meshkit-11141"
	ErrDeployControllerCode            = "meshkit-11142"
	ErrGetControllerPublicEndpointCode = "meshkit-11143"
)

Functions

func ConnectivityTest

func ConnectivityTest(clientName, hostPort string) bool

func ErrDeployController

func ErrDeployController(err error) error

func ErrGetControllerPublicEndpoint

func ErrGetControllerPublicEndpoint(err error) error

func ErrGetControllerStatus

func ErrGetControllerStatus(err error) error

func GetBrokerEndpoint

func GetBrokerEndpoint(kclient *mesherykube.Client, broker *v1alpha1.Broker) string

Types

type Connections

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

type IMesheryController

type IMesheryController interface {
	GetName() string
	GetStatus() MesheryControllerStatus
	Deploy(force bool) error //If force is set to false && controller is in "Undeployed", then Deployment will be skipped. Set force=true for explicit install.
	Undeploy() error
	GetPublicEndpoint() (string, error)
	GetVersion() (string, error)
	GetEndpointForPort(portName string) (string, error)
}

func NewMesheryBrokerHandler

func NewMesheryBrokerHandler(kubernetesClient *mesherykube.Client) IMesheryController

func NewMesheryOperatorHandler

func NewMesheryOperatorHandler(client *mesherykube.Client, deploymentConf OperatorDeploymentConfig) IMesheryController

func NewMeshsyncHandler

func NewMeshsyncHandler(kubernetesClient *mesherykube.Client) IMesheryController

type MesheryControllerStatus

type MesheryControllerStatus int

const (
	Deployed    MesheryControllerStatus = iota //The controller is deployed(default behavior)
	Deploying                                  //The controller is being deployed
	NotDeployed                                //The controller is not deployed yet
	Undeployed                                 //The controller has been intentionally undeployed. This state is useful to avoid automatic redeployment.
	// we don't know since we have not checked yet
	Enabled
	Running
	Connected
	Unknown
)

func (MesheryControllerStatus) String

func (mcs MesheryControllerStatus) String() string

type OperatorDeploymentConfig

type OperatorDeploymentConfig struct {
	GetHelmOverrides      func(delete bool) map[string]interface{}
	HelmChartRepo         string
	MesheryReleaseVersion string
}