reconcilers

Documentation

Index

• Constants
• type EventRecorder
  • func NewEventRecorder(recorder record.EventRecorder) *EventRecorder
  • func (r *EventRecorder) RecordCreating(gs *agonesv1.GameServer, kind string)
  • func (r *EventRecorder) RecordFailed(gs *agonesv1.GameServer, kind string, err error)
  • func (r *EventRecorder) RecordSuccess(gs *agonesv1.GameServer, kind string)
• type IngressOption
  • func WithCustomAnnotations() IngressOption
  • func WithIngressRule(mode gameserver.IngressRoutingMode) IngressOption
  • func WithTLS(mode gameserver.IngressRoutingMode) IngressOption
  • func WithTLSCertIssuer(issuerName string) IngressOption
• type IngressReconciler
  • func NewIngressReconciler(client *kubernetes.Clientset, recorder record.EventRecorder) *IngressReconciler
  • func (r *IngressReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*networkingv1.Ingress, error)
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type ServiceReconciler
  • func NewServiceReconciler(client *kubernetes.Clientset, recorder record.EventRecorder) *ServiceReconciler
  • func (r *ServiceReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*corev1.Service, error)

Constants

const (
	EventTypeNormal         string = "Normal"
	EventTypeWarning               = "Warning"
	ReasonReconcileFailed          = "Failed"
	ReasonReconciled               = "Created"
	ReasonReconcileCreating        = "Creating"
)

const (
	IngressKind = "Ingress"
	ServiceKind = "Service"
)

Types

type EventRecorder

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

func NewEventRecorder

func NewEventRecorder(recorder record.EventRecorder) *EventRecorder

func (*EventRecorder) RecordCreating

func (r *EventRecorder) RecordCreating(gs *agonesv1.GameServer, kind string)

func (*EventRecorder) RecordFailed

func (r *EventRecorder) RecordFailed(gs *agonesv1.GameServer, kind string, err error)

func (*EventRecorder) RecordSuccess

func (r *EventRecorder) RecordSuccess(gs *agonesv1.GameServer, kind string)

type IngressOption

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

func WithCustomAnnotations

func WithCustomAnnotations() 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 {
	Client *kubernetes.Clientset
	// contains filtered or unexported fields
}

func NewIngressReconciler

func NewIngressReconciler(client *kubernetes.Clientset, recorder record.EventRecorder) *IngressReconciler

func (*IngressReconciler) Reconcile

func (r *IngressReconciler) Reconcile(ctx context.Context, gs *agonesv1.GameServer) (*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 ServiceReconciler

type ServiceReconciler struct {
	Client *kubernetes.Clientset
	// contains filtered or unexported fields
}

func NewServiceReconciler

func NewServiceReconciler(client *kubernetes.Clientset, recorder record.EventRecorder) *ServiceReconciler

func (*ServiceReconciler) Reconcile

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