controller

Documentation

Index

• func BuildUpstreamClusterState(c *huawei_cce_model.ShowClusterResponse, ...) (*ccev1.CCEClusterConfigSpec, error)
• func BuildUpstreamNodePoolConfigs(nodePools *huawei_cce_model.ListNodePoolsResponse) ([]ccev1.CCENodePool, error)
• func NewHuaweiClientAuth(secretsCache wranglerv1.SecretCache, spec *ccev1.CCEClusterConfigSpec) (*common.ClientAuth, error)
• func Register(ctx context.Context, secrets wranglerv1.SecretController, ...)
• type Handler
  • func (h *Handler) OnCCEConfigChanged(_ string, config *ccev1.CCEClusterConfig) (*ccev1.CCEClusterConfig, error)
  • func (h *Handler) OnCCEConfigRemoved(_ string, config *ccev1.CCEClusterConfig) (*ccev1.CCEClusterConfig, error)
• type HuaweiDriver
  • func NewHuaweiDriver(auth *common.ClientAuth) *HuaweiDriver

Functions

func BuildUpstreamClusterState

func BuildUpstreamClusterState(
	c *huawei_cce_model.ShowClusterResponse,
	nodePools *huawei_cce_model.ListNodePoolsResponse,
) (*ccev1.CCEClusterConfigSpec, error)

func BuildUpstreamNodePoolConfigs

func BuildUpstreamNodePoolConfigs(
	nodePools *huawei_cce_model.ListNodePoolsResponse,
) ([]ccev1.CCENodePool, error)

func NewHuaweiClientAuth

func NewHuaweiClientAuth(
	secretsCache wranglerv1.SecretCache, spec *ccev1.CCEClusterConfigSpec,
) (*common.ClientAuth, error)

func Register

func Register(
	ctx context.Context,
	secrets wranglerv1.SecretController,
	cce ccecontrollers.CCEClusterConfigController,
)

Types

type Handler

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

func (*Handler) OnCCEConfigChanged

func (h *Handler) OnCCEConfigChanged(_ string, config *ccev1.CCEClusterConfig) (*ccev1.CCEClusterConfig, error)

func (*Handler) OnCCEConfigRemoved

func (h *Handler) OnCCEConfigRemoved(_ string, config *ccev1.CCEClusterConfig) (*ccev1.CCEClusterConfig, error)

type HuaweiDriver

type HuaweiDriver struct {
	VPC   *huawei_vpc.VpcClient
	EIP   *huawei_eip.EipClient
	ELB   *huawei_elb.ElbClient
	CCE   *huawei_cce.CceClient
	VPCEP *huawei_vpcep.VpcepClient
	DNS   *huawei_dns.DnsClient
	NAT   *huawei_nat.NatClient
}

func NewHuaweiDriver

func NewHuaweiDriver(auth *common.ClientAuth) *HuaweiDriver