controllers

Documentation

Index

• Constants
• Variables
• func ConnectivityTest(clientName, externalIP string) bool
• func ErrDeployController(err error) error
• func ErrGetControllerPublicEndpoint(err error) error
• func ErrGetControllerStatus(err error) error
• func GetBrokerEndpoint(kclient *meshplaykube.Client, broker *v1alpha1.Broker) string
• type Connections
• type IMeshplayController
  • func NewMeshplayBrokerHandler(kubernetesClient *meshplaykube.Client) IMeshplayController
  • func NewMeshplayOperatorHandler(client *meshplaykube.Client, deploymentConf OperatorDeploymentConfig) IMeshplayController
  • func NewMeshsyncHandler(kubernetesClient *meshplaykube.Client) IMeshplayController
• type MeshplayControllerStatus
  • func (mcs MeshplayControllerStatus) String() string
• type OperatorDeploymentConfig

Constants

const (
	MeshSync       = "meshsync"
	MeshplayBroker = "meshplay-broker"
	MeshplayServer = "meshplay-server"
)

const BrokerPingEndpoint = "8222/connz"

Variables

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

Functions

func ConnectivityTest

func ConnectivityTest(clientName, externalIP 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 *meshplaykube.Client, broker *v1alpha1.Broker) string

Types

type Connections

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

type IMeshplayController

type IMeshplayController interface {
	GetName() string
	GetStatus() MeshplayControllerStatus
	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 NewMeshplayBrokerHandler

func NewMeshplayBrokerHandler(kubernetesClient *meshplaykube.Client) IMeshplayController

func NewMeshplayOperatorHandler

func NewMeshplayOperatorHandler(client *meshplaykube.Client, deploymentConf OperatorDeploymentConfig) IMeshplayController

func NewMeshsyncHandler

func NewMeshsyncHandler(kubernetesClient *meshplaykube.Client) IMeshplayController

type MeshplayControllerStatus

type MeshplayControllerStatus int

const (
	Deployed    MeshplayControllerStatus = 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 (MeshplayControllerStatus) String

func (mcs MeshplayControllerStatus) String() string

type OperatorDeploymentConfig

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