Documentation
¶
Index ¶
Constants ¶
const ( // ProviderName specifies the name for the DigitalOcean provider ProviderName string = "digitalocean" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FirewallController ¶ added in v0.1.27
type FirewallController struct {
// contains filtered or unexported fields
}
FirewallController helps to keep cloud provider service firewalls in sync.
func NewFirewallController ¶ added in v0.1.27
func NewFirewallController(kubeClient clientset.Interface, client *godo.Client, serviceInformer coreinformers.ServiceInformer, fwManager *firewallManager) *FirewallController
NewFirewallController returns a new firewall controller to reconcile public access firewall state.
type LBServiceAdmissionHandler ¶ added in v0.1.47
type LBServiceAdmissionHandler struct {
// contains filtered or unexported fields
}
LBServiceAdmissionHandler validates service type LB.
func NewLBServiceAdmissionHandler ¶ added in v0.1.47
func NewLBServiceAdmissionHandler(log *logr.Logger, godoClient *godo.Client) *LBServiceAdmissionHandler
NewLBServiceAdmissionHandler returns a configured instance of LBServiceHandler.
func (*LBServiceAdmissionHandler) Handle ¶ added in v0.1.47
func (h *LBServiceAdmissionHandler) Handle(ctx context.Context, req admission.Request) admission.Response
Handle handles admissions requests for load balancer services.
func (*LBServiceAdmissionHandler) WithClusterID ¶ added in v0.1.47
func (a *LBServiceAdmissionHandler) WithClusterID(clusterID string)
WithClusterID sets the clusterID field of the handler.
func (*LBServiceAdmissionHandler) WithRegion ¶ added in v0.1.47
func (a *LBServiceAdmissionHandler) WithRegion() error
WithRegion sets the region field of the handler.
func (*LBServiceAdmissionHandler) WithVPCID ¶ added in v0.1.47
func (a *LBServiceAdmissionHandler) WithVPCID(vpcID string)
WithVPCID sets the vpcID field of the handler.
type ResourcesController ¶
type ResourcesController struct {
// contains filtered or unexported fields
}
ResourcesController is responsible for managing DigitalOcean cloud resources. It maintains a local state of the resources and synchronizes when needed.
func NewResourcesController ¶
func NewResourcesController(r *resources, inf v1informers.ServiceInformer, client kubernetes.Interface) *ResourcesController
NewResourcesController returns a new resource controller.
func (*ResourcesController) Run ¶
func (r *ResourcesController) Run(stopCh <-chan struct{})
Run starts the resources controller loop.
Source Files