controller

package
v1.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 29, 2024 License: Apache-2.0 Imports: 59 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AgentAppId byte = 1

	AgentIdHeader      = 10
	AgentAddrHeader    = 11
	AgentIsVoterHeader = 12
)
View Source 
const (
	VersionV1 = "v1"

	RestApiV1 = "/" + VersionV1

	RestApiRootPath       = "/edge"
	ClientRestApiBase     = "/edge/client"
	ManagementRestApiBase = "/edge/management"

	LegacyClientRestApiBaseUrlV1 = RestApiRootPath + RestApiV1
	ClientRestApiBaseUrlV1       = ClientRestApiBase + RestApiV1
	ManagementRestApiBaseUrlV1   = ManagementRestApiBase + RestApiV1

	ClientRestApiBaseUrlLatest     = ClientRestApiBaseUrlV1
	ManagementRestApiBaseUrlLatest = ManagementRestApiBaseUrlV1

	ClientRestApiSpecUrl     = ClientRestApiBaseUrlLatest + "/swagger.json"
	ManagementRestApiSpecUrl = ManagementRestApiBaseUrlLatest + "/swagger.json"

	LegacyClientApiBinding = "edge"
	ClientApiBinding       = "edge-client"
	ManagementApiBinding   = "edge-management"
	OidcApiBinding         = "edge-oidc"
)

Variables

View Source 
var AllApiBindingVersions = map[string]map[string]string{
	ClientApiBinding: {
		VersionV1: ClientRestApiBaseUrlV1,
	},
	ManagementApiBinding: {
		VersionV1: ManagementRestApiBaseUrlV1,
	},
}

AllApiBindingVersions is a map of: API Binding -> Api Version -> API Path Adding values here will add them to the /versions REST API endpoint

Functions

This section is empty.

Types

type Controller 

type Controller struct {
	// contains filtered or unexported fields
}

func NewController 

func NewController(cfg *config.Config, versionProvider versions.VersionProvider) (*Controller, error)

func (*Controller) GetApiAddresses added in v0.34.2 

func (c *Controller) GetApiAddresses() (map[string][]event.ApiAddress, []byte)

func (*Controller) GetCloseNotify 

func (c *Controller) GetCloseNotify() <-chan struct{}

func (*Controller) GetCloseNotifyChannel 

func (c *Controller) GetCloseNotifyChannel() <-chan struct{}

func (*Controller) GetCommandDispatcher 

func (c *Controller) GetCommandDispatcher() command.Dispatcher

func (*Controller) GetCommandRateLimiterConfig added in v0.31.0 

func (c *Controller) GetCommandRateLimiterConfig() command.RateLimiterConfig

func (*Controller) GetConfig added in v1.1.6 

func (c *Controller) GetConfig() *config.Config

func (*Controller) GetDb 

func (c *Controller) GetDb() boltz.Db

func (*Controller) GetEnv added in v1.1.6 

func (c *Controller) GetEnv() *env.AppEnv

func (*Controller) GetEventDispatcher 

func (c *Controller) GetEventDispatcher() event.Dispatcher

func (*Controller) GetHelloHeaderProviders added in v0.34.2 

func (c *Controller) GetHelloHeaderProviders() []mesh.HeaderProvider

func (*Controller) GetId 

func (c *Controller) GetId() *identity.TokenId

func (*Controller) GetMetricsRegistry 

func (c *Controller) GetMetricsRegistry() metrics.Registry

func (*Controller) GetNetwork 

func (c *Controller) GetNetwork() *network.Network

func (*Controller) GetOptions 

func (c *Controller) GetOptions() *config.NetworkConfig

func (*Controller) GetPeerAddresses added in v0.34.0 

func (c *Controller) GetPeerAddresses() []string

func (*Controller) GetPeerSigners 

func (c *Controller) GetPeerSigners() []*x509.Certificate

func (*Controller) GetRaftConfig 

func (c *Controller) GetRaftConfig() *config.RaftConfig

func (*Controller) GetRaftIndex added in v0.34.0 

func (c *Controller) GetRaftIndex() uint64

func (*Controller) GetRaftInfo added in v0.34.2 

func (c *Controller) GetRaftInfo() (string, string, string)

func (*Controller) GetVersionProvider 

func (c *Controller) GetVersionProvider() versions.VersionProvider

func (*Controller) GetXWebInstance 

func (c *Controller) GetXWebInstance() xweb.Instance

func (*Controller) HandleCustomAgentAsyncOp 

func (self *Controller) HandleCustomAgentAsyncOp(conn net.Conn) error

func (*Controller) Identity 

func (c *Controller) Identity() identity.Identity

func (*Controller) InitializeRaftFromBoltDb 

func (c *Controller) InitializeRaftFromBoltDb(sourceDbPath string) error

func (*Controller) IsRaftEnabled 

func (c *Controller) IsRaftEnabled() bool

func (*Controller) IsRaftLeader added in v0.34.0 

func (c *Controller) IsRaftLeader() bool

func (*Controller) RegisterAgentBindHandler 

func (self *Controller) RegisterAgentBindHandler(bindHandler channel.BindHandler)

func (*Controller) RegisterXctrl 

func (c *Controller) RegisterXctrl(x xctrl.Xctrl) error

func (*Controller) RegisterXmgmt 

func (c *Controller) RegisterXmgmt(x xmgmt.Xmgmt) error

func (*Controller) RenderJsonConfig 

func (c *Controller) RenderJsonConfig() (string, error)

func (*Controller) Run 

func (c *Controller) Run() error

func (*Controller) Shutdown 

func (c *Controller) Shutdown()

func (*Controller) TryInitializeRaftFromBoltDb 

func (c *Controller) TryInitializeRaftFromBoltDb() error

func (*Controller) ValidateMigrationEnvironment added in v1.1.1 

func (c *Controller) ValidateMigrationEnvironment() error

type OnConnectCtrlAddressesUpdateHandler 

type OnConnectCtrlAddressesUpdateHandler struct {
	// contains filtered or unexported fields
}

func NewOnConnectCtrlAddressesUpdateHandler 

func NewOnConnectCtrlAddressesUpdateHandler(ctrlAddress string, raft *raft.Controller) *OnConnectCtrlAddressesUpdateHandler

func (OnConnectCtrlAddressesUpdateHandler) RouterConnected 

func (o OnConnectCtrlAddressesUpdateHandler) RouterConnected(r *model.Router)

func (*OnConnectCtrlAddressesUpdateHandler) RouterDisconnected 

func (o *OnConnectCtrlAddressesUpdateHandler) RouterDisconnected(r *model.Router)

type OnConnectSettingsHandler 

type OnConnectSettingsHandler struct {
	// contains filtered or unexported fields
}

OnConnectSettingsHandler sends a ctrl_pb.ContentType_SettingsType message when routers connect if necessary Settings are a map of int32 -> []byte data. The type should be used to determine how the setting's []byte array is consumed.

func (OnConnectSettingsHandler) RouterConnected 

func (o OnConnectSettingsHandler) RouterConnected(r *model.Router)

func (*OnConnectSettingsHandler) RouterDisconnected 

func (o *OnConnectSettingsHandler) RouterDisconnected(r *model.Router)

Source Files

View all Source files

Directories

Path Synopsis
internal
permissions
policy
routes
Package ioc provides a simple generics based registry which allows registering instance providers for a name and then instantiating instances, returning instances of the requested type.
 Package ioc provides a simple generics based registry which allows registering instance providers for a name and then instantiating instances, returning instances of the requested type.
mesh
circuit
database
inspect
link
raft
router
service
terminator
Package rest_server Ziti Fabric
 Package rest_server Ziti Fabric
operations
operations/circuit
operations/database
operations/inspect
operations/link
operations/raft
operations/router
operations/service
operations/terminator
Package rest_util provides helper functions to generate a client for the Ziti Fabric REST APIs.
 Package rest_util provides helper functions to generate a client for the Ziti Fabric REST APIs.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.