reconcilers

Documentation

Index

• type GameServerReconciler
  • func NewGameServerReconciler(store GameServerStore, recorder *record.EventRecorder) *GameServerReconciler
  • func (r *GameServerReconciler) MustReconcile(gs *agonesv1.GameServer) (bool, error)
  • func (r *GameServerReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*agonesv1.GameServer, error)
• type GameServerStore
• type IngressOption
  • func WithCustomAnnotations() IngressOption
  • func WithCustomAnnotationsTemplate() IngressOption
  • func WithIngressRule(mode gameserver.IngressRoutingMode) IngressOption
  • func WithTLS(mode gameserver.IngressRoutingMode) IngressOption
  • func WithTLSCertIssuer(issuerName string) IngressOption
• type IngressReconciler
  • func NewIngressReconciler(store IngressStore, recorder *record.EventRecorder) *IngressReconciler
  • func (r *IngressReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*networkingv1.Ingress, bool, error)
• type IngressStore
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type ServiceOption
  • func WithCustomServiceAnnotations() ServiceOption
  • func WithCustomServiceAnnotationsTemplate() ServiceOption
• type ServiceReconciler
  • func NewServiceReconciler(store ServiceStore, recorder *record.EventRecorder) *ServiceReconciler
  • func (r *ServiceReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*corev1.Service, error)
• type ServiceStore

Types

type GameServerReconciler

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

func NewGameServerReconciler

func NewGameServerReconciler(store GameServerStore, recorder *record.EventRecorder) *GameServerReconciler

func (*GameServerReconciler) MustReconcile

func (r *GameServerReconciler) MustReconcile(gs *agonesv1.GameServer) (bool, error)

func (*GameServerReconciler) Reconcile

func (r *GameServerReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*agonesv1.GameServer, error)

type GameServerStore

type GameServerStore interface {
	UpdateGameServer(ctx context.Context, gs *agonesv1.GameServer) (*agonesv1.GameServer, error)
	GetGameServer(ctx context.Context, name, namespace string) (*agonesv1.GameServer, error)
}

type IngressOption

type IngressOption func(gs *agonesv1.GameServer, ingress *networkingv1.Ingress) error

func WithCustomAnnotations

func WithCustomAnnotations() IngressOption

func WithCustomAnnotationsTemplate

func WithCustomAnnotationsTemplate() IngressOption

func WithIngressRule

func WithIngressRule(mode gameserver.IngressRoutingMode) IngressOption

func WithTLS

func WithTLS(mode gameserver.IngressRoutingMode) IngressOption

func WithTLSCertIssuer

func WithTLSCertIssuer(issuerName string) IngressOption

type IngressReconciler

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

func NewIngressReconciler

func NewIngressReconciler(store IngressStore, recorder *record.EventRecorder) *IngressReconciler

func (*IngressReconciler) Reconcile

func (r *IngressReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*networkingv1.Ingress, bool, error)

type IngressStore

type IngressStore interface {
	CreateIngress(ctx context.Context, ingress *networkingv1.Ingress, options metav1.CreateOptions) (*networkingv1.Ingress, error)
	GetIngress(name, namespace string) (*networkingv1.Ingress, error)
}

type Reconciler

type Reconciler struct {
	Obj runtime.Object
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

Reconciler handles events when resources are reconciled. The interval is configured on the Manager's level.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

TODO: Evaluate is Reconcile should be made an argument for the Controller. Reconcile can be used for general uses cases where control over very specific events matter. Right now it is just a STDOUT output. Reconcile is called on every reconcile event. It does not differ between add, update, delete. Its function is purely informative and events are handled back to the broadcaster specific event handlers.

type ServiceOption

type ServiceOption func(gs *agonesv1.GameServer, service *corev1.Service) error

func WithCustomServiceAnnotations

func WithCustomServiceAnnotations() ServiceOption

func WithCustomServiceAnnotationsTemplate

func WithCustomServiceAnnotationsTemplate() ServiceOption

type ServiceReconciler

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

func NewServiceReconciler

func NewServiceReconciler(store ServiceStore, recorder *record.EventRecorder) *ServiceReconciler

func (*ServiceReconciler) Reconcile

func (r *ServiceReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*corev1.Service, error)

type ServiceStore

type ServiceStore interface {
	CreateService(ctx context.Context, service *corev1.Service, options metav1.CreateOptions) (*corev1.Service, error)
	GetService(name, namespace string) (*corev1.Service, error)
}