cloudscale_slb_controller

type Action struct {
	ActionType ActionType
	Service    *v1.Service
}

type ActionType string

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

type CloudscaleClient interface {
	// returns the ID and name of the server this client is running on
	GetServerId() (string, string, error)
	// returns the ID of the server with the given name
	GetServerIdForNode(ctx context.Context, name string) (string, error)
	// returns the name of the server with the given id
	GetServerNameForServerId(ctx context.Context, id string) (string, error)
	// creates a new floating IP attached to the given server
	CreateFloatingIp(ctx context.Context, serverId string) (FloatingIp, error)
	// returns all floating IPs in the cloudscale.ch account
	ListFloatingIps(ctx context.Context) ([]FloatingIp, error)
	// returns the floating IP with the given IP address
	GetFloatingIp(ctx context.Context, ip string) (FloatingIp, error)
	// updates the floating IP to point to the given server
	UpdateFloatingIp(ctx context.Context, ip string, serverId string) (FloatingIp, error)
	// deletes the floating IP
	DeleteFloatingIp(ctx context.Context, ip string) error
}

type ControllerConfig struct {
	CloudscaleToken         string
	UseFakeCloudscaleClient bool
	UseFakeNetwork          bool
	ChaosChance             float64
	ControllerId            string
	IpLimit                 int
}

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

type ElectionConfig struct {
	Hostname           string
	ConfigMapNamespace string
	ConfigMapName      string
	TTL                time.Duration
	ElectionId         string
	Callbacks          leaderelection.LeaderCallbacks
}

type EventProcessor struct {
	Repository Repository
	// contains filtered or unexported fields
}

type FloatingIp struct {
	Ip       string
	Netmask  string
	ServerId string
}

type FloatingIpInformation struct {
	FloatingIp       string
	ServerName       string
	ServiceNamespace string
	ServiceName      string
}

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

type Repository interface {
	Clear()

	GetService(namespace string, name string) bool
	PutService(namespace string, name string)
	DeleteService(namespace string, name string)

	GetFloatingIpForService(namespace string, name string) (FloatingIpInformation, bool)
	GetFloatingIp(ip string) (FloatingIpInformation, bool)
	PutFloatingIp(serviceNamespace string, serviceName string, ip string, serverName string) FloatingIpInformation
	DeleteFloatingIp(ip string)
}

type RetryEntry struct {
	Service      *v1.Service
	ActionType   ActionType
	WasDeleted   bool
	BlockedUntil time.Time
	Retries      int
}

type RetryManager interface {
	IsEndpointsAffectedByRetry(namespace string, name string) bool
	IsAffectedByRetry(svc *v1.Service, actionType ActionType, wasDeleted bool) bool
	SubmitForUpdate(svc *v1.Service, actionType ActionType, wasDeleted bool)
	Start()
	Stop()
}

type ServiceWatcher struct {
	Repository Repository
	// contains filtered or unexported fields
}

type WatchResult struct {
	ResourceVersion string
	Error           error
}