registrar

Documentation

Index

• Constants
• type ClusterClient
• type IDNotProvidedError
  • func (e *IDNotProvidedError) Error() string
  • func (e *IDNotProvidedError) Is(target error) bool
• type ModeNotSupportedError
  • func (e *ModeNotSupportedError) Error() string
  • func (e *ModeNotSupportedError) Is(target error) bool
• type TransitGateway
  • func NewTransitGateway(transitGatewayClient awsclient.TransitGatewayClient, ...) *TransitGateway
  • func (r *TransitGateway) Register(ctx context.Context, cluster *capi.Cluster) error
  • func (r *TransitGateway) Unregister(ctx context.Context, cluster *capi.Cluster) error
• type TransitGatewayNotAvailableError
  • func (e *TransitGatewayNotAvailableError) Error() string
  • func (e *TransitGatewayNotAvailableError) Is(target error) bool
• type VPCNotReadyError
  • func (e *VPCNotReadyError) Error() string
  • func (e *VPCNotReadyError) Is(target error) bool

Constants

const (
	// PREFIX_LIST_MAX_ENTRIES is the maximum number of entries a created prefix list can have.
	// This number counts against a resources quota (regardless of how many actual entries exist)
	// when it is referenced. We're setting the max here to 45 for now so we stay below the
	// default "Routes per route table" quota of 50.
	PREFIX_LIST_MAX_ENTRIES = 45
)

Types

type ClusterClient

type ClusterClient interface {
	Patch(ctx context.Context, cluster *capi.Cluster, patch client.Patch) (*capi.Cluster, error)
	GetManagementCluster(ctx context.Context) (*capi.Cluster, error)
	GetManagementClusterNamespacedName() k8stypes.NamespacedName
	GetAWSCluster(ctx context.Context, namespacedName k8stypes.NamespacedName) (*capa.AWSCluster, error)
	IsManagementCluster(ctx context.Context, cluster *capi.Cluster) bool
}

type IDNotProvidedError

type IDNotProvidedError struct {
	ID string
	// contains filtered or unexported fields
}

func (*IDNotProvidedError) Error

func (e *IDNotProvidedError) Error() string

func (*IDNotProvidedError) Is

func (e *IDNotProvidedError) Is(target error) bool

type ModeNotSupportedError

type ModeNotSupportedError struct {
	Mode string
	// contains filtered or unexported fields
}

func (*ModeNotSupportedError) Error

func (e *ModeNotSupportedError) Error() string

func (*ModeNotSupportedError) Is

func (e *ModeNotSupportedError) Is(target error) bool

type TransitGateway

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

func NewTransitGateway

func NewTransitGateway(transitGatewayClient awsclient.TransitGatewayClient, clusterClient ClusterClient, getTransitGatewayClientForWorkloadCluster func(workloadCluster k8stypes.NamespacedName) awsclient.TransitGatewayClient) *TransitGateway

func (*TransitGateway) Register

func (r *TransitGateway) Register(ctx context.Context, cluster *capi.Cluster) error

func (*TransitGateway) Unregister

func (r *TransitGateway) Unregister(ctx context.Context, cluster *capi.Cluster) error

type TransitGatewayNotAvailableError

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

func (*TransitGatewayNotAvailableError) Error

func (e *TransitGatewayNotAvailableError) Error() string

func (*TransitGatewayNotAvailableError) Is

func (e *TransitGatewayNotAvailableError) Is(target error) bool

type VPCNotReadyError

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

func (*VPCNotReadyError) Error

func (e *VPCNotReadyError) Error() string

func (*VPCNotReadyError) Is

func (e *VPCNotReadyError) Is(target error) bool