Documentation
¶
Index ¶
- Constants
- func BuildGameServer(gsSet *carrierv1alpha1.GameServerSet) *carrierv1alpha1.GameServer
- func GetDeletionCostFromGameServerAnnotations(annotations map[string]string) (int64, error)
- func GetGameServerSetInplaceUpdateStatus(gsSet *carrierv1alpha1.GameServerSet) int32
- func IsGameServerSetInPlaceUpdating(gsSet *carrierv1alpha1.GameServerSet) (bool, int)
- func IsGameServerSetScaling(gsSet *carrierv1alpha1.GameServerSet) bool
- func ListGameServersByGameServerSetOwner(gameServerLister listerv1.GameServerLister, ...) ([]*carrierv1alpha1.GameServer, error)
- type Controller
- type Counter
Constants ¶
const (
// BurstReplicas is a rate limiter for booting pods on a lot of pods.
BurstReplicas = 64
)
Variables ¶
This section is empty.
Functions ¶
func BuildGameServer ¶
func BuildGameServer(gsSet *carrierv1alpha1.GameServerSet) *carrierv1alpha1.GameServer
BuildGameServer build a GameServerFrom GameServerSet
func GetDeletionCostFromGameServerAnnotations ¶
GetDeletionCostFromGameServerAnnotations returns the integer value of gs-deletion-cost. Returns int64 max if not set or the value is invalid.
func GetGameServerSetInplaceUpdateStatus ¶
func GetGameServerSetInplaceUpdateStatus(gsSet *carrierv1alpha1.GameServerSet) int32
GetGameServerSetInplaceUpdateStatus get the current number of updated replicas
func IsGameServerSetInPlaceUpdating ¶
func IsGameServerSetInPlaceUpdating(gsSet *carrierv1alpha1.GameServerSet) (bool, int)
IsGameServerSetInPlaceUpdating check if the GameServerSet is updating GameServer in place.
func IsGameServerSetScaling ¶
func IsGameServerSetScaling(gsSet *carrierv1alpha1.GameServerSet) bool
IsGameServerSetScaling check if the GameServerSet is scaling GameServer.
func ListGameServersByGameServerSetOwner ¶
func ListGameServersByGameServerSetOwner(gameServerLister listerv1.GameServerLister, gsSet *carrierv1alpha1.GameServerSet) ([]*carrierv1alpha1.GameServer, error)
ListGameServersByGameServerSetOwner lists the GameServers for a given GameServerSet
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is a the GameServerSet controller
func NewController ¶
func NewController( kubeClient kubernetes.Interface, carrierClient versioned.Interface, carrierInformerFactory externalversions.SharedInformerFactory) *Controller
NewController returns a new GameServerSet crd controller
func (*Controller) Run ¶
func (c *Controller) Run(workers int, stop <-chan struct{}) error
Run the GameServer controller. Will block until stop is closed. Runs threadiness number workers to process the rate limited queue
Source Files