controllers

Documentation

Index

• Variables
• 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 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

Variables

var (
	ErrGetControllerStatusCode         = "11080"
	ErrDeployControllerCode            = "11081"
	ErrGetControllerPublicEndpointCode = "11082"
)

Functions

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 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)
}

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