timer

Documentation

Index

• type Timer
  • func NewTimer(clientSet *kubernetes.Clientset, log logr.Logger, reporter *reporter.Reporter, ...) (*Timer, error)
  • func (t *Timer) SyncTimers(room *hubv1.Room)

Types

type Timer

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

func NewTimer

func NewTimer(clientSet *kubernetes.Clientset, log logr.Logger, reporter *reporter.Reporter, client *client.Client) (*Timer, error)

func (*Timer) SyncTimers

func (t *Timer) SyncTimers(room *hubv1.Room)

SyncTimers StartTimer initiates a timer for every actor/director pod if necessary At the moment, every pod timer is supplied with the same threshold value but the code is ready to accept various values as threshold for any pod.