timer

Documentation

Index

• Constants
• func Start(ctx context.Context, clientGen crd.ClientGeneratorInterface, ...) error
• type Timer
  • func MakeTimer(logger *zap.Logger, publisher publisher.Publisher) *Timer
• type TimerSync
  • func MakeTimerSync(ctx context.Context, logger *zap.Logger, fissionClient versioned.Interface, ...) (*TimerSync, error)
  • func (ws *TimerSync) AddUpdateTimeTrigger(timeTrigger *fv1.TimeTrigger)
  • func (ws *TimerSync) DeleteTimeTrigger(timeTrigger *fv1.TimeTrigger)
  • func (ws *TimerSync) Run(ctx context.Context, mgr manager.Interface)
  • func (ws *TimerSync) TimeTriggerEventHandlers(ctx context.Context) error

Constants

const (
	SYNC requestType = iota
)

Functions

func Start

func Start(ctx context.Context, clientGen crd.ClientGeneratorInterface, logger *zap.Logger, mgr manager.Interface, routerUrl string) error

Types

type Timer

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

func MakeTimer

func MakeTimer(logger *zap.Logger, publisher publisher.Publisher) *Timer

type TimerSync

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

func MakeTimerSync

func MakeTimerSync(ctx context.Context, logger *zap.Logger, fissionClient versioned.Interface, timer *Timer) (*TimerSync, error)

func (*TimerSync) AddUpdateTimeTrigger

func (ws *TimerSync) AddUpdateTimeTrigger(timeTrigger *fv1.TimeTrigger)

func (*TimerSync) DeleteTimeTrigger

func (ws *TimerSync) DeleteTimeTrigger(timeTrigger *fv1.TimeTrigger)

func (*TimerSync) Run

func (ws *TimerSync) Run(ctx context.Context, mgr manager.Interface)

func (*TimerSync) TimeTriggerEventHandlers

func (ws *TimerSync) TimeTriggerEventHandlers(ctx context.Context) error