Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cloudscale_slb_controller

package

Go to main page

Versions in this module

v0

v0.3.1

Apr 11, 2023

v0.3.0

Dec 21, 2022

Changes in this version

+ const PreserveIpAnnotation

v0.2.2

Jun 22, 2022

v0.2.1

Jun 17, 2022

v0.2.0

Jun 17, 2022

v0.1.0

May 13, 2022

Changes in this version

+ const ControllerAnnotation

+ const ExistingIpAnnotation

+ func CreateNewElection(k8sClient kubernetes.Interface, config ElectionConfig) (*leaderelection.LeaderElector, error)

+ func RunController(k8sClient kubernetes.Interface, config ControllerConfig, done <-chan struct{}) error

+ type Action struct

+ ActionType ActionType

+ Service *v1.Service

+ type ActionType string

+ const CreateIp

+ const DeleteIp

+ const Ignore

+ const VerifyIp

+ type AdapterCloudscaleClient struct

+ func NewCloudscaleClient(token string, ipLimit int) (*AdapterCloudscaleClient, error)

+ func (adapter *AdapterCloudscaleClient) CreateFloatingIp(ctx context.Context, serverId string) (FloatingIp, error)

+ func (adapter *AdapterCloudscaleClient) DeleteFloatingIp(ctx context.Context, ip string) error

+ func (adapter *AdapterCloudscaleClient) GetFloatingIp(ctx context.Context, ip string) (FloatingIp, error)

+ func (adapter *AdapterCloudscaleClient) GetServerId() (string, string, error)

+ func (adapter *AdapterCloudscaleClient) GetServerIdForNode(ctx context.Context, name string) (string, error)

+ func (adapter *AdapterCloudscaleClient) GetServerNameForServerId(ctx context.Context, serverId string) (string, error)

+ func (adapter *AdapterCloudscaleClient) ListFloatingIps(ctx context.Context) ([]FloatingIp, error)

+ func (adapter *AdapterCloudscaleClient) UpdateFloatingIp(ctx context.Context, ip string, serverId string) (FloatingIp, error)

+ type CloudscaleClient interface

+ CreateFloatingIp func(ctx context.Context, serverId string) (FloatingIp, error)

+ DeleteFloatingIp func(ctx context.Context, ip string) error

+ GetFloatingIp func(ctx context.Context, ip string) (FloatingIp, error)

+ GetServerId func() (string, string, error)

+ GetServerIdForNode func(ctx context.Context, name string) (string, error)

+ GetServerNameForServerId func(ctx context.Context, id string) (string, error)

+ ListFloatingIps func(ctx context.Context) ([]FloatingIp, error)

+ UpdateFloatingIp func(ctx context.Context, ip string, serverId string) (FloatingIp, error)

+ type ControllerConfig struct

+ ChaosChance float64

+ CloudscaleToken string

+ ControllerId string

+ IpLimit int

+ UseFakeCloudscaleClient bool

+ UseFakeNetwork bool

+ type DefaultRetryManager struct

+ func NewRetryManager(processor *EventProcessor, repository Repository) *DefaultRetryManager

+ func (m *DefaultRetryManager) IsAffectedByRetry(svc *v1.Service, actionType ActionType, wasDeleted bool) bool

+ func (m *DefaultRetryManager) IsEndpointsAffectedByRetry(namespace string, name string) bool

+ func (m *DefaultRetryManager) Start()

+ func (m *DefaultRetryManager) Stop()

+ func (m *DefaultRetryManager) SubmitForUpdate(svc *v1.Service, actionType ActionType, wasDeleted bool)

+ type ElectionConfig struct

+ Callbacks leaderelection.LeaderCallbacks

+ ConfigMapName string

+ ConfigMapNamespace string

+ ElectionId string

+ Hostname string

+ TTL time.Duration

+ type EventProcessor struct

+ Repository Repository

+ func NewEventProcessor(client CloudscaleClient, k8sClient kubernetes.Interface, serverId string, ...) *EventProcessor

+ func (processor *EventProcessor) CreateIp(svc *v1.Service) error

+ func (processor *EventProcessor) DeleteIp(svc *v1.Service, wasDeleted bool) error

+ func (processor *EventProcessor) ReAttach(namespace string, name string) (*v1.Service, error)

+ func (processor *EventProcessor) VerifyIp(svc *v1.Service) error

+ type FloatingIp struct

+ Ip string

+ Netmask string

+ ServerId string

+ type FloatingIpInformation struct

+ FloatingIp string

+ ServerName string

+ ServiceName string

+ ServiceNamespace string

+ type HashMapRepository struct

+ func (repo *HashMapRepository) Clear()

+ func (repo *HashMapRepository) DeleteFloatingIp(ip string)

+ func (repo *HashMapRepository) DeleteService(namespace string, name string)

+ func (repo *HashMapRepository) GetFloatingIp(ip string) (FloatingIpInformation, bool)

+ func (repo *HashMapRepository) GetFloatingIpForService(namespace string, name string) (FloatingIpInformation, bool)

+ func (repo *HashMapRepository) GetService(namespace string, name string) bool

+ func (repo *HashMapRepository) PutFloatingIp(serviceNamespace string, serviceName string, ip string, serverName string) FloatingIpInformation

+ func (repo *HashMapRepository) PutService(namespace string, name string)

+ type Repository interface

+ Clear func()

+ DeleteFloatingIp func(ip string)

+ DeleteService func(namespace string, name string)

+ GetFloatingIp func(ip string) (FloatingIpInformation, bool)

+ GetFloatingIpForService func(namespace string, name string) (FloatingIpInformation, bool)

+ GetService func(namespace string, name string) bool

+ PutFloatingIp func(serviceNamespace string, serviceName string, ip string, serverName string) FloatingIpInformation

+ PutService func(namespace string, name string)

+ func NewRepository() Repository

+ type RetryEntry struct

+ ActionType ActionType

+ BlockedUntil time.Time

+ Retries int

+ Service *v1.Service

+ WasDeleted bool

+ type RetryManager interface

+ IsAffectedByRetry func(svc *v1.Service, actionType ActionType, wasDeleted bool) bool

+ IsEndpointsAffectedByRetry func(namespace string, name string) bool

+ Start func()

+ Stop func()

+ SubmitForUpdate func(svc *v1.Service, actionType ActionType, wasDeleted bool)

+ type ServiceWatcher struct

+ Repository Repository

+ func (s ServiceWatcher) Watch(controllerId string, servicesChannel <-chan watch.Event, ...)

+ type WatchResult struct

+ Error error

+ ResourceVersion string