clustermesh

Documentation

Index

• Variables
• func NewCmd(h *hive.Hive) *cobra.Command
• type ExternalWorkloadsConfig
  • func (def ExternalWorkloadsConfig) Flags(flags *pflag.FlagSet)
• type HealthAPIServerConfig
  • func (HealthAPIServerConfig) Flags(flags *pflag.FlagSet)
• type UsersManagementConfig
  • func (UsersManagementConfig) Flags(flags *pflag.FlagSet)
• type VMManager
  • func (m *VMManager) AllocateNodeIdentity(n *nodeTypes.RegisterNode) *identity.Identity
  • func (m *VMManager) GetNodeSuffix() string
  • func (m *VMManager) LookupNodeIdentity(n *nodeTypes.RegisterNode) *identity.Identity
  • func (m *VMManager) OnDelete(k store.NamedKey)
  • func (m *VMManager) OnUpdate(k store.Key)
  • func (m *VMManager) UpdateCiliumEndpointResource(name string, id *identity.Identity, ipAddresses []nodeTypes.Address, ...)
  • func (m *VMManager) UpdateCiliumNodeResource(n *nodeTypes.RegisterNode, cew *ciliumv2.CiliumExternalWorkload)
  • func (m *VMManager) UpdateIdentities(added, deleted identityCache.IdentityCache)

Variables

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