controllers

package

v0.7.19 Latest Latest Go to latest Published: Apr 7, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/MUzairS15/meshkit

Links

Open Source Insights

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
type MesheryControllerStatus
- func (mcs MesheryControllerStatus) String() string
type OperatorDeploymentConfig

Constants ¶

View Source

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

View Source

const BrokerPingEndpoint = "/connz"

Variables ¶

View Source

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL