clustermesh

package
v1.15.4 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2024 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Cell = cell.Module(
	"clustermesh",
	"Cilium ClusterMesh",

	cell.Config(option.DefaultLegacyClusterMeshConfig),

	cell.Config(cmtypes.DefaultClusterInfo),
	cell.Invoke(func(cinfo cmtypes.ClusterInfo) error { return cinfo.InitClusterIDMax() }),
	cell.Invoke(func(cinfo cmtypes.ClusterInfo) error { return cinfo.Validate() }),

	pprof.Cell,
	cell.Config(pprof.Config{
		PprofAddress: option.PprofAddress,
		PprofPort:    option.PprofPortClusterMesh,
	}),
	controller.Cell,

	gops.Cell(defaults.GopsPortApiserver),

	k8sClient.Cell,
	cmk8s.ResourcesCell,

	kvstore.Cell(kvstore.EtcdBackendName),
	cell.Provide(func() *kvstore.ExtraOptions { return nil }),
	store.Cell,

	heartbeat.Cell,
	healthAPIServerCell,

	cmmetrics.Cell,

	usersManagementCell,
	cell.Invoke(registerHooks),
	externalWorkloadsCell,
)

Functions

func NewCmd 

func NewCmd(h *hive.Hive) *cobra.Command

Types

type ExternalWorkloadsConfig 

type ExternalWorkloadsConfig struct {
	EnableExternalWorkloads bool
}

func (ExternalWorkloadsConfig) Flags 

func (def ExternalWorkloadsConfig) Flags(flags *pflag.FlagSet)

type HealthAPIServerConfig 

type HealthAPIServerConfig struct {
	ClusterMeshHealthPort int
}

func (HealthAPIServerConfig) Flags 

func (HealthAPIServerConfig) Flags(flags *pflag.FlagSet)

type UsersManagementConfig 

type UsersManagementConfig struct {
	ClusterUsersEnabled    bool
	ClusterUsersConfigPath string
}

func (UsersManagementConfig) Flags 

func (UsersManagementConfig) Flags(flags *pflag.FlagSet)

type VMManager 

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

func (*VMManager) AllocateNodeIdentity 

func (m *VMManager) AllocateNodeIdentity(n *nodeTypes.RegisterNode) *identity.Identity

func (*VMManager) GetNodeSuffix 

func (m *VMManager) GetNodeSuffix() string

GetNodeSuffix must return the node specific suffix to use

func (*VMManager) LookupNodeIdentity 

func (m *VMManager) LookupNodeIdentity(n *nodeTypes.RegisterNode) *identity.Identity

func (*VMManager) OnDelete 

func (m *VMManager) OnDelete(k store.NamedKey)

func (*VMManager) OnUpdate 

func (m *VMManager) OnUpdate(k store.Key)

func (*VMManager) UpdateCiliumEndpointResource 

func (m *VMManager) UpdateCiliumEndpointResource(name string, id *identity.Identity, ipAddresses []nodeTypes.Address, nodeIP net.IP)

UpdateCiliumEndpointResource updates the CiliumNode resource representing the local node

func (*VMManager) UpdateCiliumNodeResource 

func (m *VMManager) UpdateCiliumNodeResource(n *nodeTypes.RegisterNode, cew *ciliumv2.CiliumExternalWorkload)

UpdateCiliumNodeResource updates the CiliumNode resource representing the local node

func (*VMManager) UpdateIdentities 

func (m *VMManager) UpdateIdentities(added, deleted identityCache.IdentityCache)

UpdateIdentities will be called when identities have changed

Source Files

View all Source files

Directories

Path Synopsis

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.