event

Documentation

Index

• func CheckWorkerTimeout(event *api.Event)
• func DeleteEventByRecordID(id string) error
• func GetEvent(id string) (*api.Event, error)
• func Init(opts *options.WorkerOptions, notifyURL, recordURLTemplate string)
• func IsEventFinished(event *api.Event) bool
• func UpdateEvent(event *api.Event) error
• type EventManager
  • func NewEventManager(ds *store.DataStore) EventManager

Functions

func CheckWorkerTimeout

func CheckWorkerTimeout(event *api.Event)

CheckWorkerTimeout ...

func DeleteEventByRecordID

func DeleteEventByRecordID(id string) error

DeleteEventByRecordID deletes the event. If it is running, delete its worker at the same time.

func GetEvent

func GetEvent(id string) (*api.Event, error)

GetEvent get the event by ID.

func Init

func Init(opts *options.WorkerOptions, notifyURL, recordURLTemplate string)

Init init event manager Step1: new event manager Step2: create a goroutine to watch events

func IsEventFinished

func IsEventFinished(event *api.Event) bool

IsEventFinished return true if event is finished.

func UpdateEvent

func UpdateEvent(event *api.Event) error

UpdateEvent updates the event. If it is finished, delete it and trigger the post hook. func (em *eventManager) UpdateEvent(event *api.Event) error {

Types

type EventManager

type EventManager interface {
	HandleEvent(event *api.Event) error
	WatchEvent()
}

EventManager represents the manager of events.

func NewEventManager

func NewEventManager(ds *store.DataStore) EventManager

NewEventManager creates the event manager.