controllers

package

Go to main page

Versions in this module

v0

v0.6.0

Oct 12, 2022

Changes in this version

+ var Allocations404ErrorsCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var Allocations409ErrorsCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var Allocations429ErrorsCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var Allocations500ErrorsCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var AllocationsRetriesCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var AllocationsTimeTakenDuration = registry.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

type GameServerBuildReconciler

+ func NewGameServerBuildReconciler(mgr manager.Manager, portRegistry *PortRegistry) *GameServerBuildReconciler

+ type GameServerExpectations struct

+ func NewGameServerExpectations(c client.Reader) *GameServerExpectations

type GameServerReconciler

+ InitContainerImageLinux string

+ InitContainerImageWin string

+ func NewGameServerReconciler(mgr manager.Manager, portRegistry *PortRegistry, ...) *GameServerReconciler

type PortRegistry

+ FreePortsCount int

+ HostPortsPerGameServer map[string][]int32

+ HostPortsUsage map[int32]int

+ func (pr *PortRegistry) DeregisterPorts(namespace, name string) ([]int32, error)

+ func (pr *PortRegistry) GetNewPorts(namespace, name string, count int) ([]int32, error)

v0.5.0

Jul 25, 2022

Changes in this version

+ var GameServersUnhealthyCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ type ByState []mpsv1alpha1.GameServer

+ func (gs ByState) Len() int

+ func (gs ByState) Less(i, j int) bool

+ func (gs ByState) Swap(i, j int)

v0.4.1

Jun 6, 2022

v0.4.0

May 25, 2022

Changes in this version

+ const CertificatesDirectoryWin

+ const DataVolumeMountPathWin

+ const GameSharedContentDirectoryWin

+ const GsdkConfigFileWin

+ const LogDirectoryWin

+ const SafeToEvictPodAttribute

+ var InitContainerImageWin string

+ func GetNodeDetails(ctx context.Context, r client.Reader, nodeName string) (string, int, error)

+ type AllocateArgs struct

+ BuildID string

+ InitialPlayers []string

+ SessionCookie string

+ SessionID string

+ type AllocationApiServer struct

+ Client client.Client

+ CrtBytes []byte

+ KeyBytes []byte

+ func NewAllocationApiServer(crt, key []byte, cl client.Client) *AllocationApiServer

+ func (s *AllocationApiServer) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (s *AllocationApiServer) SetupWithManager(mgr ctrl.Manager) error

+ func (s *AllocationApiServer) Start(ctx context.Context) error

+ type GameServerForQueue struct

+ BuildID string

+ Name string

+ Namespace string

+ NodeAge int

+ ResourceVersion string

+ type GameServerQueue []*GameServerForQueue

+ func (h *GameServerQueue) Pop() interface{}

+ func (h *GameServerQueue) PopFromQueue() *GameServerForQueue

+ func (h *GameServerQueue) Push(x interface{})

+ func (h *GameServerQueue) PushToQueue(gs *GameServerForQueue)

+ func (h GameServerQueue) Len() int

+ func (h GameServerQueue) Less(i, j int) bool

+ func (h GameServerQueue) Swap(i, j int)

+ type GameServerQueueForBuild struct

+ func NewGameServersPerBuildQueue() *GameServerQueueForBuild

+ func (gsqb *GameServerQueueForBuild) PopFromQueue() *GameServerForQueue

+ func (gsqb *GameServerQueueForBuild) PushToQueue(gs *GameServerForQueue)

+ func (gsqb *GameServerQueueForBuild) RemoveFromQueue(namespace, name string)

type GameServerReconciler

+ GetNodeDetailsProvider func(ctx context.Context, r client.Reader, nodeName string) (string, int, error)

+ type GameServersQueue struct

+ func NewGameServersQueue() *GameServersQueue

+ func (gsq *GameServersQueue) PopFromQueue(buildID string) *GameServerForQueue

+ func (gsq *GameServersQueue) PushToQueue(gs *GameServerForQueue)

+ func (gsq *GameServersQueue) RemoveFromQueue(namespace, name string)

+ type MutexMap struct

+ type RequestMultiplayerServerResponse struct

+ IPV4Address string

+ Ports string

+ SessionID string

v0.3.2

Apr 7, 2022

v0.3.1

Mar 31, 2022

v0.3.0

Mar 18, 2022

Changes in this version

+ const LabelGameServerNode

+ func IsNodeReadyAndSchedulable(node *corev1.Node) bool

type PortRegistry

+ HostPortsPerNode map[int32]int

+ NodeCount int

+ func (pr *PortRegistry) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (pr *PortRegistry) SetupWithManager(mgr ctrl.Manager) error

v0.2.0

Jan 13, 2022

Changes in this version

+ const ActiveServerStatus

+ const CertificatesDirectory

+ const DaemonSetPort

+ const DataVolumeMountPath

+ const DataVolumeName

+ const GameServerBuildKind

+ const GameServerKind

+ const GameSharedContentDirectory

+ const GsdkConfigFile

+ const InitContainerName

+ const InitializingServerStatus

+ const LabelBuildID

+ const LabelBuildName

+ const LabelNodeName

+ const LabelOwningGameServer

+ const LabelOwningOperator

+ const LogDirectory

+ const MaxPort

+ const MinPort

+ const PendingServerStatus

+ const RandStringSize

+ const StandingByServerStatus

+ var AllocationsCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var CurrentGameServerGauge = registry.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var GameServersCrashedCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var GameServersCreatedCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var GameServersDeletedCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var GameServersSessionEndedCounter = registry.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var InitContainerImage string

+ func GetPublicIPForNode(ctx context.Context, r client.Reader, nodeName string) (string, error)

+ func NewGameServerForGameServerBuild(gsb *mpsv1alpha1.GameServerBuild, portRegistry *PortRegistry) (*mpsv1alpha1.GameServer, error)

+ func NewPodForGameServer(gs *mpsv1alpha1.GameServer) *corev1.Pod

+ type GameServerBuildReconciler struct

+ PortRegistry *PortRegistry

+ Recorder record.EventRecorder

+ Scheme *runtime.Scheme

+ func (r *GameServerBuildReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *GameServerBuildReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type GameServerReconciler struct

+ GetPublicIpForNodeProvider func(ctx context.Context, r client.Reader, nodeName string) (string, error)

+ PortRegistry *PortRegistry

+ Recorder record.EventRecorder

+ Scheme *runtime.Scheme

+ func (r *GameServerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *GameServerReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type PortRegistry struct

+ HostPorts map[int32]bool

+ Indexes []int32

+ Max int32

+ Min int32

+ NextFreePortIndex int32

+ func NewPortRegistry(gameServers mpsv1alpha1.GameServerList, min, max int32, setupLog logr.Logger) (*PortRegistry, error)

+ func (pr *PortRegistry) DeregisterServerPorts(ports []int32)

+ func (pr *PortRegistry) GetNewPort() (int32, error)

+ func (pr *PortRegistry) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL