timer

Documentation

Index

• Constants
• func Start(ctx context.Context, logger *zap.Logger, routerUrl string) 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
  • func (ws *TimerSync) AddUpdateTimeTrigger(timeTrigger *fv1.TimeTrigger)
  • func (ws *TimerSync) DeleteTimeTrigger(timeTrigger *fv1.TimeTrigger)
  • func (ws *TimerSync) Run(ctx context.Context)
  • func (ws *TimerSync) TimeTriggerEventHandlers(ctx context.Context)

Constants

const (
	SYNC requestType = iota
)

Functions

func Start

func Start(ctx context.Context, logger *zap.Logger, 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

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)

func (*TimerSync) TimeTriggerEventHandlers

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