gameserversets

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
  • func NewController(kubeClient kubernetes.Interface, carrierClient versioned.Interface, ...) *Controller
  • func (c *Controller) Run(workers int, stop <-chan struct{}) error
• type Counter

Constants

const (
	// BurstReplicas is a rate limiter for booting pods on a lot of pods.
	BurstReplicas = 64
)

Functions

func BuildGameServer

func BuildGameServer(gsSet *carrierv1alpha1.GameServerSet) *carrierv1alpha1.GameServer

BuildGameServer build a GameServerFrom GameServerSet

func GetDeletionCostFromGameServerAnnotations

func GetDeletionCostFromGameServerAnnotations(annotations map[string]string) (int64, error)

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

type Counter

type Counter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Counter caches the node GameServer location