clustermesh

Documentation

Index

• Variables
• func NewCmd(h *hive.Hive) *cobra.Command
• type ExternalWorkloadsConfig
  • func (def ExternalWorkloadsConfig) 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 identity.IdentityMap)

Variables

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

	cell.Config(option.DefaultLegacyClusterMeshConfig),

	cell.Config(cmtypes.DefaultClusterInfo),
	cell.Invoke(cmtypes.ClusterInfo.InitClusterIDMax),
	cell.Invoke(cmtypes.ClusterInfo.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(ss syncstate.SyncState) *kvstore.ExtraOptions {
		return &kvstore.ExtraOptions{
			BootstrapComplete: ss.WaitChannel(),
		}
	}),
	store.Cell,

	synced.Cell,

	cell.Provide(func() synced.CRDSyncResourceNames { return synced.ClusterMeshAPIServerResourceNames() }),

	synced.CRDSyncCell,

	heartbeat.Cell,
	HealthAPIEndpointsCell,
	health.HealthAPIServerCell,

	cmmetrics.Cell,

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

var HealthAPIEndpointsCell = cell.Module(
	"health-api-endpoints",
	"ClusterMesh Health API Endpoints",

	syncstate.Cell,
	cell.Provide(healthEndpoints),
)

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 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 identity.IdentityMap)

UpdateIdentities will be called when identities have changed